api

package
v0.0.0-...-eb7ac2c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 11, 2023 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TIMEOUT_MESSAGE    = `{"error": {"code": 503,"message": "Request timeout."}}`
	QUERY_PARAM_SEP    = byte('&')
	QUERY_PARAM_KV_SEP = byte('=')
)

Functions

This section is empty.

Types

type ApiApp 

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

func New 

func New() *ApiApp

func (*ApiApp) CloseQueues 

func (s *ApiApp) CloseQueues()

func (*ApiApp) SetupInterruptListener 

func (s *ApiApp) SetupInterruptListener()

func (*ApiApp) StartServer 

func (s *ApiApp) StartServer()

type AppContext 

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

func (*AppContext) ChangeMessageVisibility 

func (appCtx *AppContext) ChangeMessageVisibility(ctx *fasthttp.RequestCtx)

func (*AppContext) CreateQueue 

func (appCtx *AppContext) CreateQueue(ctx *fasthttp.RequestCtx)

func (*AppContext) DeleteMessage 

func (appCtx *AppContext) DeleteMessage(ctx *fasthttp.RequestCtx)

func (*AppContext) DeleteMessageBatch 

func (appCtx *AppContext) DeleteMessageBatch(ctx *fasthttp.RequestCtx)

func (*AppContext) DeleteQueue 

func (appCtx *AppContext) DeleteQueue(ctx *fasthttp.RequestCtx)

func (*AppContext) GetQueueAttributes 

func (appCtx *AppContext) GetQueueAttributes(ctx *fasthttp.RequestCtx)

func (*AppContext) GetQueueUrl 

func (appCtx *AppContext) GetQueueUrl(ctx *fasthttp.RequestCtx)

func (*AppContext) ListDeadLetterSourceQueues 

func (appCtx *AppContext) ListDeadLetterSourceQueues(ctx *fasthttp.RequestCtx)

func (*AppContext) ListQueueTags 

func (appCtx *AppContext) ListQueueTags(ctx *fasthttp.RequestCtx)

func (*AppContext) ListQueues 

func (appCtx *AppContext) ListQueues(ctx *fasthttp.RequestCtx)

func (*AppContext) PurgeQueue 

func (appCtx *AppContext) PurgeQueue(ctx *fasthttp.RequestCtx)

func (*AppContext) ReceiveMessage 

func (appCtx *AppContext) ReceiveMessage(ctx *fasthttp.RequestCtx)

func (*AppContext) SendMessage 

func (appCtx *AppContext) SendMessage(ctx *fasthttp.RequestCtx)

func (*AppContext) SendMessageBatch 

func (appCtx *AppContext) SendMessageBatch(ctx *fasthttp.RequestCtx)

func (*AppContext) SetQueueAttributes 

func (appCtx *AppContext) SetQueueAttributes(ctx *fasthttp.RequestCtx)

func (*AppContext) TagQueue 

func (appCtx *AppContext) TagQueue(ctx *fasthttp.RequestCtx)

func (*AppContext) UntagQueue 

func (appCtx *AppContext) UntagQueue(ctx *fasthttp.RequestCtx)

type CreateQueueInput 

type CreateQueueInput struct {
	QueueName  string          `validate:"required,min=5,max=50"`
	Attributes QueueAttributes `validate:"required"`
	Tags       *[][2]string    ``
}

type CreateQueueResult 

type CreateQueueResult struct {
	QueueUrl  string
	RequestId string
}

type ErrorResponse 

type ErrorResponse struct {
	XMLName   xml.Name           `xml:"http://queue.amazonaws.com/doc/2012-11-05/ ErrorResponse"`
	Error     ErrorResponseError `xml:"Error"`
	RequestId string             `xml:"RequestId"`
}

type ErrorResponseError 

type ErrorResponseError struct {
	Code    string `xml:"Code"`
	Detail  string `xml:"Detail"`
	Message string `xml:"Message"`
	Type    string `xml:"Type"`
}

type FormValues 

type FormValues map[string]string

func (FormValues) Reset 

func (f FormValues) Reset() FormValues

func (FormValues) Set 

func (f FormValues) Set(key, value string)

type MessageAttribute 

type MessageAttribute struct {
	DataType string
	Value    []byte
}

type MessageAttributes 

type MessageAttributes map[string]MessageAttribute

type Middleware 

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

func (*Middleware) WrapHandler 

func (m *Middleware) WrapHandler(h fasthttp.RequestHandler) fasthttp.RequestHandler

type QueueAttributes 

type QueueAttributes struct {
	DelaySeconds                  uint16 `validate:"min=0,max=900"`
	MaximumMessageSize            uint32 `validate:"min=1024,max=262144"`
	MessageRetentionPeriod        uint32 `validate:"min=60,max=1209600"`
	ReceiveMessageWaitTimeSeconds uint16 `validate:"min=0,max=20"`
	VisibilityTimeout             uint16 `validate:"min=0,max=43200"`
}

type ReceiveMessage 

type ReceiveMessage struct {
	MessageId              string
	ReceiptHandle          string
	Body                   string
	MD5OfBody              string
	MD5OfMessageAttributes string
	RequestId              string
}

type ReceiveMessageInput 

type ReceiveMessageInput struct {
	AttributeName        string `validate:"required"`
	MaxNumberOfMessages  uint8  `validate:"min=1,max=10"`
	QueueName            string `validate:"required"`
	AccountId            string `validate:"required"`
	MessageAttributeName string `validate:"required"`
}

type ResponseMetadata 

type ResponseMetadata struct {
	RequestId string `xml:"RequestId"`
}

func NewResponseMetadata 

func NewResponseMetadata() ResponseMetadata

type SendMessageInput 

type SendMessageInput struct {
	DelaySeconds            uint16            `validate:"min=0,max=900"`
	MessageBody             string            `validate:"required,min=1,max=262144"`
	QueueName               string            `validate:"required"`
	AccountId               string            `validate:"required"`
	MessageAttributes       MessageAttributes `validate:"required"`
	MessageSystemAttributes MessageAttributes ``
}

type SendMessageResult 

type SendMessageResult struct {
	MessageId                    string
	MD5OfMessageBody             string
	MD5OfMessageAttributes       string
	MD5OfMessageSystemAttributes string
	RequestId                    string
}

type StreamWriter 

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

func (StreamWriter) Write 

func (s StreamWriter) Write(p []byte) (n int, err error)

type VQSError 

type VQSError struct {
	Code      string
	Detail    string
	Message   string
	Type      string
	RequestId string
}

func NewVQSError 

func NewVQSError(code, message, detail string) *VQSError

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.