sysclient

package

v0.2.0-preview.1 Latest Latest Go to latest Published: Mar 20, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

View Source

const (
	DefaultRequestTimeout = 60 * time.Second
)

View Source

var (
	ErrValidation      = errors.New("validation error")
	ErrInvalidServerID = errors.New("server with given ID does not exist")
)

This section is empty.

type FetchOpt func(*FetchOpts) error

type FetchOpts struct {
	Timeout     time.Duration
	ReadTimeout time.Duration
	Expected    int
}

type HealthStatus int

const (
	StatusOK HealthStatus = iota
	StatusUnavailable
	StatusError
)

func (hs HealthStatus) MarshalJSON() ([]byte, error)

func (hs HealthStatus) String() string

func (hs *HealthStatus) UnmarshalJSON(data []byte) error

type Healthz struct {
	Status HealthStatus `json:"status"`
	Error  string       `json:"error,omitempty"`
}

type HealthzResp struct {
	Server  server.ServerInfo `json:"server"`
	Healthz Healthz           `json:"data"`
}

type JSZResp struct {
	Server server.ServerInfo `json:"server"`
	JSInfo server.JSInfo     `json:"data"`
}

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

SysClient can be used to request monitoring data from the server. This is used by the stream-check and consumer-check commands

func New(nc *nats.Conn) SysClient

func (s *SysClient) Fetch(subject string, data []byte, opts ...FetchOpt) ([]*nats.Msg, error)

func (s *SysClient) FindServers(stdin bool, expected int, timeout time.Duration, readTimeout time.Duration, getConsumer bool) ([]JSZResp, error)

func (s *SysClient) Healthz(id string, opts server.HealthzOptions) (*HealthzResp, error)

func (s *SysClient) JszPing(opts server.JszEventOptions, fopts ...FetchOpt) ([]JSZResp, error)