queue

type AwsSQSConfig struct {
	Name              string `koanf:"name"`
	VisibilityTimeout int64  `koanf:"visibility_timeout"`
	Endpoint          string `koanf:"endpoint"`
	Region            string `koanf:"region"`
}

type AwsSQSMessage struct {
	// contains filtered or unexported fields
}

type AwsSQSQueue struct {
	// contains filtered or unexported fields
}

type GcpPubSubConfig struct {
	SubscriptionId     string `koanf:"subscription_id"`
	AckDeadlineSeconds int64  `koanf:"ack_deadline_seconds"`
	Endpoint           string `koanf:"endpoint"`
}

type GcpPubSubMessage struct {
	// contains filtered or unexported fields
}

type GcpPubSubQueue struct {
	// contains filtered or unexported fields
}

type Message interface {
	Id() string
	QueueId() string
	Data() []byte
}

type Queue interface {
	QueueId() string
	ReceiveMessage() (Message, error)
	DeleteMessage(m Message) error
	ReturnMessage(m Message) error
}