sqs

Documentation

Index

• type Handler
  • func New() *Handler
  • func NewHandler(config *viper.Viper) Handler
  • func (handler *Handler) CreateHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) CreateHandleParseInput(r *http.Request) (*sqs.CreateQueueInput, error)
  • func (handler *Handler) DeleteHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) DeleteHandleParseInput(r *http.Request) (*sqs.DeleteQueueInput, error)
  • func (handler *Handler) DeleteMessageBatchHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) DeleteMessageBatchHandleParseInput(r *http.Request) (*sqs.DeleteMessageBatchInput, error)
  • func (handler *Handler) DeleteMessageHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) DeleteMessageHandleParseInput(r *http.Request) (*sqs.DeleteMessageInput, error)
  • func (handler *Handler) GetConfig() *viper.Viper
  • func (handler *Handler) GetContext() *context.Context
  • func (handler *Handler) GetGCPClient() kinesis.GCPClient
  • func (handler *Handler) GetSqsClient() *sqs.SQS
  • func (handler *Handler) Handle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) ListHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) ListHandleParseInput(r *http.Request) (*sqs.ListQueuesInput, error)
  • func (handler *Handler) PurgeHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) PurgeHandleParseInput(r *http.Request) (*sqs.PurgeQueueInput, error)
  • func (handler *Handler) ReceiveHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) ReceiveHandleParseInput(r *http.Request) (*sqs.ReceiveMessageInput, error)
  • func (handler *Handler) Register(mux *mux.Router)
  • func (handler *Handler) SendBatchHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) SendBatchHandleParseInput(r *http.Request) (*sqs.SendMessageBatchInput, error)
  • func (handler *Handler) SendHandle(writer http.ResponseWriter, request *http.Request)
  • func (handler *Handler) SendHandleParseInput(r *http.Request) (*sqs.SendMessageInput, error)
  • func (handler *Handler) SetConfig(config *viper.Viper)
  • func (handler *Handler) SetContext(context *context.Context)
  • func (handler *Handler) SetGCPClient(gcpClient kinesis.GCPClient)
  • func (handler *Handler) SetSqsClient(sqsClient *sqs.SQS)
  • func (handler *Handler) Shutdown()
• type HandlerInterface
• type MessageAttributeNameAndValue

Types

type Handler

type Handler struct {
	SqsClient               *sqs.SQS
	GCPClient               kinesis.GCPClient
	GCPClientToTopic        func(topic string, client kinesis.GCPClient) kinesis.GCPTopic
	GCPResultWrapper        func(result *pubsub.PublishResult) kinesis.GCPPublishResult
	GCPKMSClient            *kms.KeyManagementClient
	GCPClientToSubscription func(client kinesis.GCPClient, id string)
	Context                 *context.Context
	Config                  *viper.Viper
	ToAck                   map[string]chan bool
}

func New

func New() *Handler

func NewHandler

func NewHandler(config *viper.Viper) Handler

func (*Handler) CreateHandle

func (handler *Handler) CreateHandle(writer http.ResponseWriter, request *http.Request)

func (*Handler) CreateHandleParseInput

func (handler *Handler) CreateHandleParseInput(r *http.Request) (*sqs.CreateQueueInput, error)

func (*Handler) DeleteHandle

func (handler *Handler) DeleteHandle(writer http.ResponseWriter, request *http.Request)

func (*Handler) DeleteHandleParseInput

func (handler *Handler) DeleteHandleParseInput(r *http.Request) (*sqs.DeleteQueueInput, error)

func (*Handler) DeleteMessageBatchHandle

func (handler *Handler) DeleteMessageBatchHandle(writer http.ResponseWriter, request *http.Request)

func (*Handler) DeleteMessageBatchHandleParseInput

func (handler *Handler) DeleteMessageBatchHandleParseInput(r *http.Request) (*sqs.DeleteMessageBatchInput, error)

func (*Handler) DeleteMessageHandle

func (handler *Handler) DeleteMessageHandle(writer http.ResponseWriter, request *http.Request)

func (*Handler) DeleteMessageHandleParseInput

func (handler *Handler) DeleteMessageHandleParseInput(r *http.Request) (*sqs.DeleteMessageInput, error)

func (*Handler) GetConfig

func (handler *Handler) GetConfig() *viper.Viper

func (*Handler) GetContext

func (handler *Handler) GetContext() *context.Context

func (*Handler) GetGCPClient

func (handler *Handler) GetGCPClient() kinesis.GCPClient

func (*Handler) GetSqsClient

func (handler *Handler) GetSqsClient() *sqs.SQS

func (*Handler) Handle

func (handler *Handler) Handle(writer http.ResponseWriter, request *http.Request)

func (*Handler) ListHandle

func (handler *Handler) ListHandle(writer http.ResponseWriter, request *http.Request)

func (*Handler) ListHandleParseInput

func (handler *Handler) ListHandleParseInput(r *http.Request) (*sqs.ListQueuesInput, error)

func (*Handler) PurgeHandle

func (handler *Handler) PurgeHandle(writer http.ResponseWriter, request *http.Request)

func (*Handler) PurgeHandleParseInput

func (handler *Handler) PurgeHandleParseInput(r *http.Request) (*sqs.PurgeQueueInput, error)

func (*Handler) ReceiveHandle

func (handler *Handler) ReceiveHandle(writer http.ResponseWriter, request *http.Request)

func (*Handler) ReceiveHandleParseInput

func (handler *Handler) ReceiveHandleParseInput(r *http.Request) (*sqs.ReceiveMessageInput, error)

func (*Handler) Register

func (handler *Handler) Register(mux *mux.Router)

func (*Handler) SendBatchHandle

func (handler *Handler) SendBatchHandle(writer http.ResponseWriter, request *http.Request)

func (*Handler) SendBatchHandleParseInput

func (handler *Handler) SendBatchHandleParseInput(r *http.Request) (*sqs.SendMessageBatchInput, error)

func (*Handler) SendHandle

func (handler *Handler) SendHandle(writer http.ResponseWriter, request *http.Request)

func (*Handler) SendHandleParseInput

func (handler *Handler) SendHandleParseInput(r *http.Request) (*sqs.SendMessageInput, error)

func (*Handler) SetConfig

func (handler *Handler) SetConfig(config *viper.Viper)

func (*Handler) SetContext

func (handler *Handler) SetContext(context *context.Context)

func (*Handler) SetGCPClient

func (handler *Handler) SetGCPClient(gcpClient kinesis.GCPClient)

func (*Handler) SetSqsClient

func (handler *Handler) SetSqsClient(sqsClient *sqs.SQS)

func (*Handler) Shutdown

func (handler *Handler) Shutdown()

type HandlerInterface

type HandlerInterface interface {
	GetSqsClient() *sqs.SQS
	GetGCPClient() kinesis.GCPClient
	GetContext() *context.Context
	GetConfig() *viper.Viper
	SetSqsClient(sqsClient *sqs.SQS)
	SetGCPClient(gcpClient kinesis.GCPClient)
	SetContext(context *context.Context)
	SetConfig(config *viper.Viper)

	Register(mux *mux.Router)
	New(handler *Handler) *Handler
	Handle(writer http.ResponseWriter, request *http.Request)
	ListHandle(writer http.ResponseWriter, request *http.Request)
	ListHandleParseInput(r *http.Request) (*sqs.ListQueuesInput, error)
	CreateHandle(writer http.ResponseWriter, request *http.Request)
	CreateHandleParseInput(r *http.Request) (*sqs.CreateQueueInput, error)
	PurgeHandle(writer http.ResponseWriter, request *http.Request)
	PurgeHandleParseInput(r *http.Request) (*sqs.PurgeQueueInput, error)
	DeleteHandle(writer http.ResponseWriter, request *http.Request)
	DeleteHandleParseInput(r *http.Request) (*sqs.DeleteQueueInput, error)
	SendHandle(writer http.ResponseWriter, request *http.Request)
	SendHandleParseInput(r *http.Request) (*sqs.SendMessageInput, error)
	SendBatchHandle(writer http.ResponseWriter, request *http.Request)
	SendBatchHandleParseInput(r *http.Request) (*sqs.SendMessageBatchInput, error)
	ReceiveHandle(writer http.ResponseWriter, request *http.Request)
	ReceiveHandleParseInput(r *http.Request) (*sqs.ReceiveMessageInput, error)
	DeleteMessageHandle(writer http.ResponseWriter, request *http.Request)
	DeleteMessageHandleParseInput(r *http.Request) (*sqs.DeleteMessageInput, error)
	DeleteMessageBatchHandle(writer http.ResponseWriter, request *http.Request)
	DeleteMessageBatchHandleParseInput(r *http.Request) (*sqs.DeleteMessageBatchInput, error)
}

type MessageAttributeNameAndValue

type MessageAttributeNameAndValue struct {
	Name  *string
	Value *sqs.MessageAttributeValue
}