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

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

Jump to

Keyboard shortcuts

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