adapter

Documentation

Index

• type FakeYandexMessageQueueAdapter
  • func (r *FakeYandexMessageQueueAdapter) Create(_ context.Context, _ *sqs.SQS, attributes map[string]*string, name string) (string, error)
  • func (r *FakeYandexMessageQueueAdapter) Delete(_ context.Context, _ *sqs.SQS, queueURL string) error
  • func (r *FakeYandexMessageQueueAdapter) GetAttributes(_ context.Context, _ *sqs.SQS, queueURL string) (map[string]*string, error)
  • func (r *FakeYandexMessageQueueAdapter) GetURL(_ context.Context, _ *sqs.SQS, queueName string) (string, error)
  • func (r *FakeYandexMessageQueueAdapter) List(_ context.Context, _ *sqs.SQS) ([]*string, error)
  • func (r *FakeYandexMessageQueueAdapter) UpdateAttributes(_ context.Context, _ *sqs.SQS, attributes map[string]*string, queueURL string) error
• type YandexMessageQueueAdapter
  • func NewFakeYandexMessageQueueAdapter() YandexMessageQueueAdapter
  • func NewYandexMessageQueueAdapterSDK() YandexMessageQueueAdapter
• type YandexMessageQueueAdapterSDK
  • func (r *YandexMessageQueueAdapterSDK) Create(_ context.Context, sdk *sqs.SQS, attributes map[string]*string, name string) (string, error)
  • func (r *YandexMessageQueueAdapterSDK) Delete(_ context.Context, sdk *sqs.SQS, queueURL string) error
  • func (r *YandexMessageQueueAdapterSDK) GetAttributes(_ context.Context, sdk *sqs.SQS, queueURL string) (map[string]*string, error)
  • func (r *YandexMessageQueueAdapterSDK) GetURL(_ context.Context, sdk *sqs.SQS, queueName string) (string, error)
  • func (r *YandexMessageQueueAdapterSDK) List(ctx context.Context, sdk *sqs.SQS) ([]*string, error)
  • func (r *YandexMessageQueueAdapterSDK) UpdateAttributes(_ context.Context, sdk *sqs.SQS, attributes map[string]*string, ...) error

Types

type FakeYandexMessageQueueAdapter

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

func (*FakeYandexMessageQueueAdapter) Create

func (r *FakeYandexMessageQueueAdapter) Create(
	_ context.Context, _ *sqs.SQS, attributes map[string]*string, name string,
) (string, error)

func (*FakeYandexMessageQueueAdapter) Delete

func (r *FakeYandexMessageQueueAdapter) Delete(_ context.Context, _ *sqs.SQS, queueURL string) error

func (*FakeYandexMessageQueueAdapter) GetAttributes

func (r *FakeYandexMessageQueueAdapter) GetAttributes(
	_ context.Context, _ *sqs.SQS, queueURL string,
) (map[string]*string, error)

func (*FakeYandexMessageQueueAdapter) GetURL

func (r *FakeYandexMessageQueueAdapter) GetURL(_ context.Context, _ *sqs.SQS, queueName string) (string, error)

func (*FakeYandexMessageQueueAdapter) List

func (r *FakeYandexMessageQueueAdapter) List(_ context.Context, _ *sqs.SQS) ([]*string, error)

func (*FakeYandexMessageQueueAdapter) UpdateAttributes

func (r *FakeYandexMessageQueueAdapter) UpdateAttributes(
	_ context.Context, _ *sqs.SQS, attributes map[string]*string, queueURL string,
) error

type YandexMessageQueueAdapter

type YandexMessageQueueAdapter interface {
	Create(ctx context.Context, sdk *sqs.SQS, attributes map[string]*string, queueName string) (string, error)
	GetURL(ctx context.Context, sdk *sqs.SQS, queueName string) (string, error)
	GetAttributes(ctx context.Context, sdk *sqs.SQS, queueURL string) (map[string]*string, error)
	List(ctx context.Context, sdk *sqs.SQS) ([]*string, error)
	UpdateAttributes(ctx context.Context, sdk *sqs.SQS, attributes map[string]*string, queueName string) error
	Delete(ctx context.Context, sdk *sqs.SQS, queueURL string) error
}

func NewFakeYandexMessageQueueAdapter

func NewFakeYandexMessageQueueAdapter() YandexMessageQueueAdapter

func NewYandexMessageQueueAdapterSDK

func NewYandexMessageQueueAdapterSDK() YandexMessageQueueAdapter

type YandexMessageQueueAdapterSDK

type YandexMessageQueueAdapterSDK struct {
}

func (*YandexMessageQueueAdapterSDK) Create

func (r *YandexMessageQueueAdapterSDK) Create(
	_ context.Context, sdk *sqs.SQS, attributes map[string]*string, name string,
) (string, error)

func (*YandexMessageQueueAdapterSDK) Delete

func (r *YandexMessageQueueAdapterSDK) Delete(_ context.Context, sdk *sqs.SQS, queueURL string) error

func (*YandexMessageQueueAdapterSDK) GetAttributes

func (r *YandexMessageQueueAdapterSDK) GetAttributes(
	_ context.Context,
	sdk *sqs.SQS,
	queueURL string,
) (map[string]*string, error)

func (*YandexMessageQueueAdapterSDK) GetURL

func (r *YandexMessageQueueAdapterSDK) GetURL(_ context.Context, sdk *sqs.SQS, queueName string) (string, error)

func (*YandexMessageQueueAdapterSDK) List

func (r *YandexMessageQueueAdapterSDK) List(ctx context.Context, sdk *sqs.SQS) ([]*string, error)

func (*YandexMessageQueueAdapterSDK) UpdateAttributes

func (r *YandexMessageQueueAdapterSDK) UpdateAttributes(
	_ context.Context, sdk *sqs.SQS, attributes map[string]*string, queueURL string,
) error