queue

Documentation

Index

• type Message
• type SQS
  • func NewVAASQS(producer *sqs.Producer, consumer *sqs.Consumer, logger *zap.Logger, ...) *SQS
  • func (q *SQS) Close()
  • func (q *SQS) Consume(ctx context.Context) <-chan Message
  • func (q *SQS) Publish(ctx context.Context, v *vaa.VAA, data []byte) error
• type SQSOption
  • func WithChannelSize(size int) SQSOption
• type VAAInMemory
  • func NewVAAInMemory(opts ...VAAInMemoryOption) *VAAInMemory
  • func (i *VAAInMemory) Consume(_ context.Context) <-chan Message
  • func (i *VAAInMemory) Publish(_ context.Context, v *vaa.VAA, data []byte) error
• type VAAInMemoryOption
  • func WithSize(v int) VAAInMemoryOption

Types

type Message

type Message interface {
	Data() []byte
	Done(context.Context)
	Failed()
	IsExpired() bool
}

Message represents a message from a queue.

type SQS

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

SQS represents a VAA queue in SQS.

func NewVAASQS

func NewVAASQS(producer *sqs.Producer, consumer *sqs.Consumer, logger *zap.Logger, opts ...SQSOption) *SQS

NewVAASQS creates a VAA queue in SQS instances.

func (*SQS) Close

func (q *SQS) Close()

Close closes all consumer resources.

func (*SQS) Consume

func (q *SQS) Consume(ctx context.Context) <-chan Message

Consume returns the channel with the received messages from SQS queue.

func (*SQS) Publish

func (q *SQS) Publish(ctx context.Context, v *vaa.VAA, data []byte) error

Publish sends the message to a SQS queue.

type SQSOption

type SQSOption func(*SQS)

SQSOption represents a VAA queue in SQS option function.

func WithChannelSize

func WithChannelSize(size int) SQSOption

WithChannelSize allows to specify an channel size when setting a value.

type VAAInMemory

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

VAAInMemory represents VAA queue in memory.

func NewVAAInMemory

func NewVAAInMemory(opts ...VAAInMemoryOption) *VAAInMemory

NewVAAInMemory creates a VAA queue in memory instances.

func (*VAAInMemory) Consume

func (i *VAAInMemory) Consume(_ context.Context) <-chan Message

Consume returns the channel with the received messages.

func (*VAAInMemory) Publish

func (i *VAAInMemory) Publish(_ context.Context, v *vaa.VAA, data []byte) error

Publish sends the message to a channel.

type VAAInMemoryOption

type VAAInMemoryOption func(*VAAInMemory)

VAAInMemoryOption represents a VAA queue in memory option function.

func WithSize

func WithSize(v int) VAAInMemoryOption

WithSize allows to specify an channel size when setting a value.