sqs

Documentation

Index

• func New(p client.ConfigProvider, opts ...*aws.Config) api.Endpoint
• type API
• type GetQueueAttributes
  • func (fn *GetQueueAttributes) New(name string, config interface{}) ([]api.Request, error)
• type GetQueueAttributesOutput
  • func (o *GetQueueAttributesOutput) Records() (records []*api.Record)

Functions

func New

func New(p client.ConfigProvider, opts ...*aws.Config) api.Endpoint

New implements api.ServiceFunc

Types

type API

type API interface {
	ListQueuesPagesWithContext(context.Context, *sqs.ListQueuesInput, func(*sqs.ListQueuesOutput, bool) bool, ...request.Option) error
	GetQueueAttributesWithContext(context.Context, *sqs.GetQueueAttributesInput, ...request.Option) (*sqs.GetQueueAttributesOutput, error)
}

API documents the subset of AWS API we actually call

type GetQueueAttributes

type GetQueueAttributes struct {
	API
}

func (*GetQueueAttributes) New

func (fn *GetQueueAttributes) New(name string, config interface{}) ([]api.Request, error)

New implements api.RequestBuilder

type GetQueueAttributesOutput

type GetQueueAttributesOutput struct {
	*sqs.GetQueueAttributesOutput
}

func (*GetQueueAttributesOutput) Records

func (o *GetQueueAttributesOutput) Records() (records []*api.Record)