Documentation ¶
Index ¶
- func NewCmdQueue(ctx context.Context, cfg *config.Config) *cobra.Command
- func NewCmdQueueAck(ctx context.Context, cfg *config.Config) *cobra.Command
- func NewCmdQueueAttach(ctx context.Context, cfg *config.Config) *cobra.Command
- func NewCmdQueueList(ctx context.Context, cfg *config.Config) *cobra.Command
- func NewCmdQueuePeek(ctx context.Context, cfg *config.Config) *cobra.Command
- func NewCmdQueueReceive(ctx context.Context, cfg *config.Config) *cobra.Command
- func NewCmdQueueSend(ctx context.Context, cfg *config.Config) *cobra.Command
- func NewCmdQueueStream(ctx context.Context, cfg *config.Config) *cobra.Command
- type AckOptions
- type AttachOptions
- type Client
- type ListOptions
- type PeekOptions
- type Queue
- type Queues
- type ReceiveOptions
- type Response
- type SendOptions
- type StreamOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCmdQueueAttach ¶
func NewCmdQueueReceive ¶
Types ¶
type AckOptions ¶
type AckOptions struct {
// contains filtered or unexported fields
}
func (*AckOptions) Complete ¶
func (o *AckOptions) Complete(args []string) error
func (*AckOptions) Validate ¶
func (o *AckOptions) Validate() error
type AttachOptions ¶
type AttachOptions struct {
// contains filtered or unexported fields
}
func (*AttachOptions) Complete ¶
func (o *AttachOptions) Complete(args []string) error
func (*AttachOptions) Validate ¶
func (o *AttachOptions) Validate() error
type ListOptions ¶
type ListOptions struct {
// contains filtered or unexported fields
}
func (*ListOptions) Complete ¶
func (o *ListOptions) Complete(args []string) error
func (*ListOptions) Validate ¶
func (o *ListOptions) Validate() error
type PeekOptions ¶
type PeekOptions struct {
// contains filtered or unexported fields
}
func (*PeekOptions) Complete ¶
func (o *PeekOptions) Complete(args []string) error
func (*PeekOptions) Validate ¶
func (o *PeekOptions) Validate() error
type ReceiveOptions ¶
type ReceiveOptions struct {
// contains filtered or unexported fields
}
func (*ReceiveOptions) Complete ¶
func (o *ReceiveOptions) Complete(args []string) error
func (*ReceiveOptions) Validate ¶
func (o *ReceiveOptions) Validate() error
type Response ¶
type Response struct { Node string `json:"node"` Error bool `json:"error"` ErrorString string `json:"error_string"` Data json.RawMessage `json:"data"` }
type SendOptions ¶
type SendOptions struct {
// contains filtered or unexported fields
}
func (*SendOptions) Complete ¶
func (o *SendOptions) Complete(args []string) error
func (*SendOptions) Validate ¶
func (o *SendOptions) Validate() error
type StreamOptions ¶
type StreamOptions struct {
// contains filtered or unexported fields
}
func (*StreamOptions) Complete ¶
func (o *StreamOptions) Complete(args []string) error
func (*StreamOptions) Validate ¶
func (o *StreamOptions) Validate() error
Click to show internal directories.
Click to hide internal directories.