compression

package module

Go to main page

Versions in this module

v1

v1.1.0

Oct 25, 2022

Changes in this version

type CompressionSQSProducer

+ func (producer *CompressionSQSProducer) BatchProduceMessage(ctx context.Context, messageBatchInput *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)

type MockSQSProducer

+ func (m *MockSQSProducer) BatchProduceMessage(ctx context.Context, messageBatchInput *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)

type MockSQSProducerMockRecorder

+ func (mr *MockSQSProducerMockRecorder) BatchProduceMessage(ctx, messageBatchInput interface{}) *gomock.Call

v1.0.0

Apr 25, 2022

Changes in this version

type CompressionSQSProducer

+ func (producer *CompressionSQSProducer) QueueURL() string

type MockSQSProducer

+ func (m *MockSQSProducer) QueueURL() string

type MockSQSProducerMockRecorder

+ func (mr *MockSQSProducerMockRecorder) QueueURL() *gomock.Call

v0

v0.0.1

Jul 6, 2021

v0.0.0

Jul 6, 2021

Changes in this version

+ func NewDecompressionMessageConsumer() func(runsqs.SQSMessageConsumer) runsqs.SQSMessageConsumer

+ type CompressionSQSProducer struct

+ Wrapped runsqs.SQSProducer

+ func (producer *CompressionSQSProducer) ProduceMessage(message []byte) error

+ type DecompressionMessageConsumer struct

+ func (t DecompressionMessageConsumer) ConsumeMessage(ctx context.Context, message *sqs.Message) runsqs.SQSMessageConsumerError

+ func (t DecompressionMessageConsumer) DeadLetter(ctx context.Context, message *sqs.Message)

+ type DecompressionMessageConsumerComponent struct

+ func NewComponent() *DecompressionMessageConsumerComponent

+ func (*DecompressionMessageConsumerComponent) Settings() *DecompressionMessageConsumerConfig

+ func (c *DecompressionMessageConsumerComponent) New(_ context.Context, conf *DecompressionMessageConsumerConfig) (func(runsqs.SQSMessageConsumer) runsqs.SQSMessageConsumer, error)

+ type DecompressionMessageConsumerConfig struct

+ func (*DecompressionMessageConsumerConfig) Name() string

+ type DecompressionMessageConsumerError struct

+ func (e DecompressionMessageConsumerError) Error() string

+ func (e DecompressionMessageConsumerError) IsRetryable() bool

+ func (e DecompressionMessageConsumerError) RetryAfter() int64

+ type MockSQSConsumer struct

+ func NewMockSQSConsumer(ctrl *gomock.Controller) *MockSQSConsumer

+ func (m *MockSQSConsumer) EXPECT() *MockSQSConsumerMockRecorder

+ func (m *MockSQSConsumer) GetSQSMessageConsumer() runsqs.SQSMessageConsumer

+ func (m *MockSQSConsumer) StartConsuming(ctx context.Context) error

+ func (m *MockSQSConsumer) StopConsuming(ctx context.Context) error

+ type MockSQSConsumerMockRecorder struct

+ func (mr *MockSQSConsumerMockRecorder) GetSQSMessageConsumer() *gomock.Call

+ func (mr *MockSQSConsumerMockRecorder) StartConsuming(ctx interface{}) *gomock.Call

+ func (mr *MockSQSConsumerMockRecorder) StopConsuming(ctx interface{}) *gomock.Call

+ type MockSQSMessageConsumer struct

+ func NewMockSQSMessageConsumer(ctrl *gomock.Controller) *MockSQSMessageConsumer

+ func (m *MockSQSMessageConsumer) ConsumeMessage(ctx context.Context, message *sqs.Message) runsqs.SQSMessageConsumerError

+ func (m *MockSQSMessageConsumer) DeadLetter(ctx context.Context, message *sqs.Message)

+ func (m *MockSQSMessageConsumer) EXPECT() *MockSQSMessageConsumerMockRecorder

+ type MockSQSMessageConsumerError struct

+ func NewMockSQSMessageConsumerError(ctrl *gomock.Controller) *MockSQSMessageConsumerError

+ func (m *MockSQSMessageConsumerError) EXPECT() *MockSQSMessageConsumerErrorMockRecorder

+ func (m *MockSQSMessageConsumerError) Error() string

+ func (m *MockSQSMessageConsumerError) IsRetryable() bool

+ func (m *MockSQSMessageConsumerError) RetryAfter() int64

+ type MockSQSMessageConsumerErrorMockRecorder struct

+ func (mr *MockSQSMessageConsumerErrorMockRecorder) Error() *gomock.Call

+ func (mr *MockSQSMessageConsumerErrorMockRecorder) IsRetryable() *gomock.Call

+ func (mr *MockSQSMessageConsumerErrorMockRecorder) RetryAfter() *gomock.Call

+ type MockSQSMessageConsumerMockRecorder struct

+ func (mr *MockSQSMessageConsumerMockRecorder) ConsumeMessage(ctx, message interface{}) *gomock.Call

+ func (mr *MockSQSMessageConsumerMockRecorder) DeadLetter(ctx, message interface{}) *gomock.Call

+ type MockSQSProducer struct

+ func NewMockSQSProducer(ctrl *gomock.Controller) *MockSQSProducer

+ func (m *MockSQSProducer) EXPECT() *MockSQSProducerMockRecorder

+ func (m *MockSQSProducer) ProduceMessage(message []byte) error

+ type MockSQSProducerMockRecorder struct

+ func (mr *MockSQSProducerMockRecorder) ProduceMessage(message interface{}) *gomock.Call

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL