listen

Documentation

Index

• Constants
• type Event
• type Listener
• type SQS
  • func NewSQS(cfg aws.Config, id xid.ID) (*SQS, error)
  • func (s *SQS) Listen(ctx context.Context)
  • func (s *SQS) Shutdown(ctx context.Context) error

Constants

const (
	SQSQueuePrefix = "eb-listener"
)

Types

type Event

type Event struct {
	Version    string          `json:"version"`
	ID         string          `json:"id"`
	DetailType string          `json:"detail-type"`
	Source     string          `json:"source"`
	Account    string          `json:"account"`
	Time       time.Time       `json:"time"`
	Region     string          `json:"region"`
	Resources  []interface{}   `json:"resources"`
	Detail     json.RawMessage `json:"detail"`
}

type Listener

type Listener interface{}

type SQS

type SQS struct {
	QueueURL string
	QueueARN string
	// contains filtered or unexported fields
}

func NewSQS

func NewSQS(cfg aws.Config, id xid.ID) (*SQS, error)

func (*SQS) Listen

func (s *SQS) Listen(ctx context.Context)

func (*SQS) Shutdown

func (s *SQS) Shutdown(ctx context.Context) error