client

Documentation

Index

• type CancelRequest
• type CompletedRequest
• type ConsumeRequest
• type Error
• type FailedRequest
• type HeartbeatRequest
• type MessageClient
  • func NewMessageClient(httpClient *http.Client, baseURL string, adminToken string) *MessageClient
  • func (c *MessageClient) Cancel(ctx context.Context, messageID int64, cancelRequest CancelRequest) error
  • func (c *MessageClient) Complete(ctx context.Context, messageID int64, completedRequest CompletedRequest) error
  • func (c *MessageClient) Consume(ctx context.Context, messageID int64, lease string) (MessageResponse, error)
  • func (c *MessageClient) Create(ctx context.Context, content string, priority int, data model.MessageAttr) (MessageResponse, error)
  • func (c *MessageClient) Failed(ctx context.Context, messageID int64, failedRequest FailedRequest) error
  • func (c *MessageClient) Get(ctx context.Context, messageID int64) (MessageResponse, error)
  • func (c *MessageClient) Heartbeat(ctx context.Context, messageID int64, heartbeatRequest HeartbeatRequest) error
  • func (c *MessageClient) List(ctx context.Context) ([]MessageResponse, error)
  • func (c *MessageClient) Watch(ctx context.Context, messageID int64) (chan MessageResponse, error)
  • func (c *MessageClient) WatchList(ctx context.Context) (chan MessageResponse, error)
• type MessageRequest
• type MessageResponse

Types

type CancelRequest

type CancelRequest struct {
	Lease string `json:"lease"`
}

type CompletedRequest

type CompletedRequest struct {
	Lease string `json:"lease"`
}

type ConsumeRequest

type ConsumeRequest struct {
	Lease string `json:"lease"`
}

type Error

type Error struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type FailedRequest

type FailedRequest struct {
	Lease string            `json:"lease"`
	Data  model.MessageAttr `json:"data"`
}

type HeartbeatRequest

type HeartbeatRequest struct {
	Data  model.MessageAttr `json:"data"`
	Lease string            `json:"lease"`
}

type MessageClient

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

func NewMessageClient

func NewMessageClient(httpClient *http.Client, baseURL string, adminToken string) *MessageClient

func (*MessageClient) Cancel

func (c *MessageClient) Cancel(ctx context.Context, messageID int64, cancelRequest CancelRequest) error

func (*MessageClient) Complete

func (c *MessageClient) Complete(ctx context.Context, messageID int64, completedRequest CompletedRequest) error

func (*MessageClient) Consume

func (c *MessageClient) Consume(ctx context.Context, messageID int64, lease string) (MessageResponse, error)

func (*MessageClient) Create

func (c *MessageClient) Create(ctx context.Context, content string, priority int, data model.MessageAttr) (MessageResponse, error)

func (*MessageClient) Failed

func (c *MessageClient) Failed(ctx context.Context, messageID int64, failedRequest FailedRequest) error

func (*MessageClient) Get

func (c *MessageClient) Get(ctx context.Context, messageID int64) (MessageResponse, error)

func (*MessageClient) Heartbeat

func (c *MessageClient) Heartbeat(ctx context.Context, messageID int64, heartbeatRequest HeartbeatRequest) error

func (*MessageClient) List

func (c *MessageClient) List(ctx context.Context) ([]MessageResponse, error)

func (*MessageClient) Watch

func (c *MessageClient) Watch(ctx context.Context, messageID int64) (chan MessageResponse, error)

func (*MessageClient) WatchList

func (c *MessageClient) WatchList(ctx context.Context) (chan MessageResponse, error)

type MessageRequest

type MessageRequest struct {
	Content  string `json:"content"`
	Priority int    `json:"priority"`

	Data model.MessageAttr `json:"data,omitempty"`
}

type MessageResponse

type MessageResponse struct {
	MessageID     int64               `json:"id"`
	Content       string              `json:"content"`
	Priority      int                 `json:"priority"`
	Status        model.MessageStatus `json:"status"`
	Data          model.MessageAttr   `json:"data,omitempty"`
	LastHeartbeat time.Time           `json:"last_heartbeat"`
}