client

Documentation

Index

• func GenerateClientID() string
• type NatsStreamingClient
  • func (n *NatsStreamingClient) Close()
  • func (n *NatsStreamingClient) GetEndOfDayMsg(channelName string) (*stan.Msg, error)
  • func (n *NatsStreamingClient) List(channelName string, startAt, limit uint64) ([]string, error)
  • func (n *NatsStreamingClient) Publish(channelName string, content []byte) error
• type NatsStreamingMonitor
  • func (n *NatsStreamingMonitor) GetChannelInfo(channelName string, subs bool) ([]byte, error)
  • func (n *NatsStreamingMonitor) GetChannelsInfo(subs bool, offset, limit uint64) ([]byte, error)
  • func (n *NatsStreamingMonitor) GetClientInfo(clientName string, subs bool) ([]byte, error)
  • func (n *NatsStreamingMonitor) GetClientsInfo(subs bool, offset, limit uint64) ([]byte, error)
  • func (n *NatsStreamingMonitor) GetClusterID() (string, error)
  • func (n *NatsStreamingMonitor) GetServerInfo() ([]byte, error)
  • func (n *NatsStreamingMonitor) GetStoreInfo() ([]byte, error)
• type Serverz

Functions

func GenerateClientID

func GenerateClientID() string

Types

type NatsStreamingClient

type NatsStreamingClient struct {
	Host      string
	Port      int
	ID        string
	ClusterID string
	// contains filtered or unexported fields
}

func (*NatsStreamingClient) Close

func (n *NatsStreamingClient) Close()

func (*NatsStreamingClient) GetEndOfDayMsg

func (n *NatsStreamingClient) GetEndOfDayMsg(channelName string) (*stan.Msg, error)

func (*NatsStreamingClient) List

func (n *NatsStreamingClient) List(channelName string, startAt, limit uint64) ([]string, error)

func (*NatsStreamingClient) Publish

func (n *NatsStreamingClient) Publish(channelName string, content []byte) error

type NatsStreamingMonitor

type NatsStreamingMonitor struct {
	Host      string
	HttpPort  int
	HttpsPort int
	UseHttps  bool
}

func (*NatsStreamingMonitor) GetChannelInfo

func (n *NatsStreamingMonitor) GetChannelInfo(channelName string, subs bool) ([]byte, error)

func (*NatsStreamingMonitor) GetChannelsInfo

func (n *NatsStreamingMonitor) GetChannelsInfo(subs bool, offset, limit uint64) ([]byte, error)

func (*NatsStreamingMonitor) GetClientInfo

func (n *NatsStreamingMonitor) GetClientInfo(clientName string, subs bool) ([]byte, error)

func (*NatsStreamingMonitor) GetClientsInfo

func (n *NatsStreamingMonitor) GetClientsInfo(subs bool, offset, limit uint64) ([]byte, error)

func (*NatsStreamingMonitor) GetClusterID

func (n *NatsStreamingMonitor) GetClusterID() (string, error)

func (*NatsStreamingMonitor) GetServerInfo

func (n *NatsStreamingMonitor) GetServerInfo() ([]byte, error)

func (*NatsStreamingMonitor) GetStoreInfo

func (n *NatsStreamingMonitor) GetStoreInfo() ([]byte, error)

type Serverz

type Serverz struct {
	ClusterID     string `json:"cluster_id"`
	State         string `json:"state"`
	Uptime        string `json:"uptime"`
	Role          string `json:"role"`
	Clients       uint32 `json:"clients"`
	Channels      uint32 `json:"channels"`
	Subscriptions uint32 `json:"subscriptions"`
}