client

Documentation

Index

• type Client
  • func Connect() (c Client, err error)
  • func ConnectTo(url string) (c Client, err error)
  • func (c Client) GetRepoInfo() (info session.RepoInfo, err error)
  • func (c Client) GetVersion() (res string, err error)
  • func (c Client) KV(key string) (res session.KVState, err error)
  • func (c Client) KVCAS(key string, expected, desired any) (res session.KVCompareAndSwapResult, err error)
  • func (c Client) KVCreate(key string, value any) (res uint64, err error)
  • func (c Client) KVList() (res []string, err error)
  • func (c Client) KVPurge(key string) (res struct{}, err error)
  • func (c Client) KVPut(key string, value any) (res uint64, err error)
  • func (c Client) KVSet(key string, value any, revision uint64) (res uint64, err error)
  • func (c Client) Lambdas() (res map[string]session.Lambda, err error)
  • func (c Client) Peers() (res []xpost.Peer, err error)
  • func (c Client) PeersAlive() (res []xpost.Peer, err error)
  • func (c Client) Ping() (res string, err error)
  • func (c Client) Publish(topic string, p any) (ack jetstream.PubAck, err error)
  • func (c Client) QueryIP(ip string) (info session.IPInfoResult, err error)
  • func (c Client) Reload(invalidate bool) (err error)
  • func (c Client) Result(stream string, seq int) (res json.RawMessage, err error)
  • func (c Client) ServiceHealth(name string) (h session.ServiceHealth, err error)
  • func (c Client) ServiceHealthMap() (h map[string]session.ServiceHealth, err error)
  • func (c Client) ServiceMetrics(name string) (m session.ServiceMetrics, err error)
  • func (c Client) ServiceMetricsMap() (m map[string]session.ServiceMetrics, err error)
  • func (c Client) ServiceRestart(name string, invalidate bool) (res session.ServiceCommandResult, err error)
  • func (c Client) ServiceRestartAll(invalidate bool) (res session.ServiceCommandResult, err error)
  • func (c Client) ServiceStop(name string) (res session.ServiceCommandResult, err error)
  • func (c Client) ServiceStopAll() (res session.ServiceCommandResult, err error)
  • func (c Client) Services() (res map[string]snowflake.ID, err error)
  • func (c Client) SessionMetrics() (m session.SessionMetrics, err error)
  • func (c Client) Shutdown() (err error)
  • func (c Client) SignURL(p urlsigner.Options) (res string, err error)
  • func (c Client) SystemMetrics() (m session.SystemMetrics, err error)
  • func (c Client) Tail(to xlog.TailOptions, out io.Writer) error
  • func (c Client) TailContext(ctx context.Context, to xlog.TailOptions, out io.Writer) error
  • func (c Client) UpdateRepo(p session.UpdateParams) (res session.PullResult, err error)
  • func (c Client) Valid() bool

Types

type Client

type Client struct {
	pmtp.Client
	URL string
}

func Connect

func Connect() (c Client, err error)

func ConnectTo

func ConnectTo(url string) (c Client, err error)

func (Client) GetRepoInfo

func (c Client) GetRepoInfo() (info session.RepoInfo, err error)

func (Client) GetVersion

func (c Client) GetVersion() (res string, err error)

func (Client) KV

func (c Client) KV(key string) (res session.KVState, err error)

func (Client) KVCAS

func (c Client) KVCAS(key string, expected, desired any) (res session.KVCompareAndSwapResult, err error)

func (Client) KVCreate

func (c Client) KVCreate(key string, value any) (res uint64, err error)

func (Client) KVList

func (c Client) KVList() (res []string, err error)

func (Client) KVPurge

func (c Client) KVPurge(key string) (res struct{}, err error)

func (Client) KVPut

func (c Client) KVPut(key string, value any) (res uint64, err error)

func (Client) KVSet

func (c Client) KVSet(key string, value any, revision uint64) (res uint64, err error)

func (Client) Lambdas

func (c Client) Lambdas() (res map[string]session.Lambda, err error)

func (Client) Peers

func (c Client) Peers() (res []xpost.Peer, err error)

func (Client) PeersAlive

func (c Client) PeersAlive() (res []xpost.Peer, err error)

func (Client) Ping

func (c Client) Ping() (res string, err error)

func (Client) Publish

func (c Client) Publish(topic string, p any) (ack jetstream.PubAck, err error)

func (Client) QueryIP

func (c Client) QueryIP(ip string) (info session.IPInfoResult, err error)

func (Client) Reload

func (c Client) Reload(invalidate bool) (err error)

func (Client) Result

func (c Client) Result(stream string, seq int) (res json.RawMessage, err error)

func (Client) ServiceHealth

func (c Client) ServiceHealth(name string) (h session.ServiceHealth, err error)

func (Client) ServiceHealthMap

func (c Client) ServiceHealthMap() (h map[string]session.ServiceHealth, err error)

func (Client) ServiceMetrics

func (c Client) ServiceMetrics(name string) (m session.ServiceMetrics, err error)

func (Client) ServiceMetricsMap

func (c Client) ServiceMetricsMap() (m map[string]session.ServiceMetrics, err error)

func (Client) ServiceRestart

func (c Client) ServiceRestart(name string, invalidate bool) (res session.ServiceCommandResult, err error)

func (Client) ServiceRestartAll

func (c Client) ServiceRestartAll(invalidate bool) (res session.ServiceCommandResult, err error)

func (Client) ServiceStop

func (c Client) ServiceStop(name string) (res session.ServiceCommandResult, err error)

func (Client) ServiceStopAll

func (c Client) ServiceStopAll() (res session.ServiceCommandResult, err error)

func (Client) Services

func (c Client) Services() (res map[string]snowflake.ID, err error)

func (Client) SessionMetrics

func (c Client) SessionMetrics() (m session.SessionMetrics, err error)

func (Client) Shutdown

func (c Client) Shutdown() (err error)

func (Client) SignURL

func (c Client) SignURL(p urlsigner.Options) (res string, err error)

func (Client) SystemMetrics

func (c Client) SystemMetrics() (m session.SystemMetrics, err error)

func (Client) Tail

func (c Client) Tail(to xlog.TailOptions, out io.Writer) error

func (Client) TailContext

func (c Client) TailContext(ctx context.Context, to xlog.TailOptions, out io.Writer) error

func (Client) UpdateRepo

func (c Client) UpdateRepo(p session.UpdateParams) (res session.PullResult, err error)

func (Client) Valid

func (c Client) Valid() bool