events_store

Documentation

Index

• func NewCmdEventsStore(ctx context.Context, cfg *config.Config) *cobra.Command
• func NewCmdEventsStoreAttach(ctx context.Context, cfg *config.Config) *cobra.Command
• func NewCmdEventsStoreList(ctx context.Context, cfg *config.Config) *cobra.Command
• func NewCmdEventsStoreReceive(ctx context.Context, cfg *config.Config) *cobra.Command
• func NewCmdEventsStoreSend(ctx context.Context, cfg *config.Config) *cobra.Command
• type AttachOptions
  • func (o *AttachOptions) Complete(args []string) error
  • func (o *AttachOptions) Run(ctx context.Context) error
  • func (o *AttachOptions) Validate() error
• type Client
• type ListOptions
  • func (o *ListOptions) Complete(args []string) error
  • func (o *ListOptions) Run(ctx context.Context) error
  • func (o *ListOptions) Validate() error
• type Queue
• type Queues
• type ReceiveOptions
  • func (o *ReceiveOptions) Complete(args []string) error
  • func (o *ReceiveOptions) Run(ctx context.Context) error
  • func (o *ReceiveOptions) Validate() error
• type Response
• type SendOptions
  • func (o *SendOptions) Complete(args []string) error
  • func (o *SendOptions) Run(ctx context.Context) error
  • func (o *SendOptions) Validate() error

Functions

func NewCmdEventsStore

func NewCmdEventsStore(ctx context.Context, cfg *config.Config) *cobra.Command

func NewCmdEventsStoreAttach

func NewCmdEventsStoreAttach(ctx context.Context, cfg *config.Config) *cobra.Command

func NewCmdEventsStoreList

func NewCmdEventsStoreList(ctx context.Context, cfg *config.Config) *cobra.Command

func NewCmdEventsStoreReceive

func NewCmdEventsStoreReceive(ctx context.Context, cfg *config.Config) *cobra.Command

func NewCmdEventsStoreSend

func NewCmdEventsStoreSend(ctx context.Context, cfg *config.Config) *cobra.Command

Types

type AttachOptions

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

func (*AttachOptions) Complete

func (o *AttachOptions) Complete(args []string) error

func (*AttachOptions) Run

func (o *AttachOptions) Run(ctx context.Context) error

func (*AttachOptions) Validate

func (o *AttachOptions) Validate() error

type Client

type Client struct {
	ClientId         string `json:"client_id"`
	Active           bool   `json:"active"`
	LastSequenceSent int64  `json:"last_sequence_sent"`
	IsStalled        bool   `json:"is_stalled"`
	Pending          int64  `json:"pending"`
}

type ListOptions

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

func (*ListOptions) Complete

func (o *ListOptions) Complete(args []string) error

func (*ListOptions) Run

func (o *ListOptions) Run(ctx context.Context) error

func (*ListOptions) Validate

func (o *ListOptions) Validate() error

type Queue

type Queue struct {
	Name          string    `json:"name"`
	Messages      int64     `json:"messages"`
	Bytes         int64     `json:"bytes"`
	FirstSequence int64     `json:"first_sequence"`
	LastSequence  int64     `json:"last_sequence"`
	Clients       []*Client `json:"clients"`
}

type Queues

type Queues struct {
	Now    time.Time `json:"now"`
	Total  int       `json:"total"`
	Queues []*Queue  `json:"queues"`
}

type ReceiveOptions

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

func (*ReceiveOptions) Complete

func (o *ReceiveOptions) Complete(args []string) error

func (*ReceiveOptions) Run

func (o *ReceiveOptions) Run(ctx context.Context) 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) Run

func (o *SendOptions) Run(ctx context.Context) error

func (*SendOptions) Validate

func (o *SendOptions) Validate() error