core_message_queue

type Attribute struct {
	Key   string
	Value string
	Type  string
}

type ClientParams struct {
	Region                      *string
	Endpoint                    *string
	AwsProfile                  *string
	AwsId                       *string
	AwsSecret                   *string
	Urls                        *QueueUrlSet
	WriteOperationTimeout       *time.Duration
	MaxNumberOfMessagesToIngest *int
	ReadOperationTimeout        *time.Duration
	Attributes                  *[]string
}

type Config struct {
	Address string
	Region  string
	Profile string
	ID      string
	Secret  string
}

type HandleConfig struct {
	MaxNumberOfMessages *int
	MaxWaitTimeSeconds  *time.Duration
	Attributes          *[]string
}

type Message struct {
	ID            string
	ReceiptHandle string
	Body          string
	Attributes    map[string]string
}

type MessageClientInterface interface {
	// Sends a message to a queue
	Send(ctx context.Context, req *SendRequest) (string, error)
	// Sends a message to a queue
	SendMessage(ctx context.Context, msg *sqs.SendMessageInput) (*string, error)
	// Long polls given amount of messages from a queue.
	Receive(ctx context.Context, queueURL string) ([]*Message, error)
	// Deletes a message from a queue.
	Delete(ctx context.Context, queueURL, rcvHandle string) error
}

type QueueUrlSet struct {
	AlgoliaSearchUrl *string
	SendgridUrl      *string
	GetStreamUrl     *string
}

type SendRequest struct {
	QueueURL   string
	Body       string
	Attributes []Attribute
}

type SqsQueueHandle struct {
	Client    sqsiface.SQSAPI
	QueueUrls *QueueUrlSet

	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	Config       *HandleConfig
	// contains filtered or unexported fields
}