queue

Documentation

Index

• type Event
• type EventName
• type Queue
  • func NewSQSQueue(cfg *SQSConfig) Queue
• type SQSConfig

Types

type Event

type Event struct {
	ID   string
	Name EventName
	Data []byte

	RetryCount int
	// contains filtered or unexported fields
}

type EventName

type EventName string

type Queue

type Queue interface {
	Pop(ctx context.Context, size int64) ([]*Event, error)

	Push(ctx context.Context, event *Event, delay int64) error
	Retry(ctx context.Context, event *Event, delay int64) error
	Remove(ctx context.Context, event *Event) error
}

func NewSQSQueue

func NewSQSQueue(cfg *SQSConfig) Queue

type SQSConfig

type SQSConfig struct {
	QueueURL          string
	Client            *sqs.Client
	PollInterval      time.Duration
	VisibilityTimeout time.Duration
}