sqs

Documentation

Index

• type SQSClient
  • func (h *SQSClient) HealthStatus() v1.HealthStatus
  • func (c *SQSClient) Iter(ctx context.Context, next v1.NextMessage) error
  • func (c *SQSClient) Produce(context context.Context, m *v1.RawMessage) error
• type SQSClientFactory
  • func (factory *SQSClientFactory) CreateConsumer(cfg *viper.Viper, logger *zerolog.Logger) v1.Consumer
  • func (factory *SQSClientFactory) CreateProducer(cfg *viper.Viper, logger *zerolog.Logger) v1.Producer
• type SQSMessage
  • func (m *SQSMessage) Abort(error) bool
  • func (m *SQSMessage) Complete() error
  • func (m *SQSMessage) Data() string
  • func (m *SQSMessage) Id() string
• type SnsMessage

Types

type SQSClient

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

func (*SQSClient) HealthStatus

func (h *SQSClient) HealthStatus() v1.HealthStatus

func (*SQSClient) Iter

func (c *SQSClient) Iter(ctx context.Context, next v1.NextMessage) error

func (*SQSClient) Produce

func (c *SQSClient) Produce(context context.Context, m *v1.RawMessage) error

type SQSClientFactory

type SQSClientFactory struct {
}

func (*SQSClientFactory) CreateConsumer

func (factory *SQSClientFactory) CreateConsumer(cfg *viper.Viper, logger *zerolog.Logger) v1.Consumer

func (*SQSClientFactory) CreateProducer

func (factory *SQSClientFactory) CreateProducer(cfg *viper.Viper, logger *zerolog.Logger) v1.Producer

type SQSMessage

type SQSMessage struct {
	*sqs.Message
	// contains filtered or unexported fields
}

func (*SQSMessage) Abort

func (m *SQSMessage) Abort(error) bool

func (*SQSMessage) Complete

func (m *SQSMessage) Complete() error

func (*SQSMessage) Data

func (m *SQSMessage) Data() string

func (*SQSMessage) Id

func (m *SQSMessage) Id() string

type SnsMessage

type SnsMessage struct {
	Message string `json:"Message"`
}