client

Documentation

Index

• Constants
• type Client
  • func New(endpoint string, accessKey string, secretKey string) *Client
  • func (cli *Client) Queue(name string, squad string) (*QueueClient, error)
• type Message
• type Option
• type QueueClient
  • func (cli *QueueClient) ApplyNode() error
  • func (cli *QueueClient) PullMessages(handler func([]Message) error) error
  • func (cli *QueueClient) PushMessage(content string) error

Constants

const (

	// DefaultSquad is the default squad name
	DefaultSquad = "default"
)

Types

type Client

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

Client for one sqs client

func New

func New(endpoint string, accessKey string, secretKey string) *Client

New allocates a new Client

func (*Client) Queue

func (cli *Client) Queue(name string, squad string) (*QueueClient, error)

Queue returns a new QueueClient with the given name

type Message

type Message struct {
	MessageID int64  `json:"message_id"`
	Content   string `json:"content"`
}

Message for a message entry

type Option

type Option struct {
	// Endpoint for main server
	Endpoint string
	models.UserAuth
}

Option for Client options

type QueueClient

type QueueClient struct {
	*Client

	BaseInfo models.NodeRequestParams
	// contains filtered or unexported fields
}

QueueClient for one query client

func (*QueueClient) ApplyNode

func (cli *QueueClient) ApplyNode() error

ApplyNode applies for a available node

func (*QueueClient) PullMessages

func (cli *QueueClient) PullMessages(handler func([]Message) error) error

PullMessages for pull message request

func (*QueueClient) PushMessage

func (cli *QueueClient) PushMessage(content string) error

PushMessage pushes a message