client

Documentation

Overview

Package client implements client.

Index

• type Client
  • func New(cfg Config) (Client, error)
• type Config
• type Op
• type OpOption
  • func WithLogLevel(logLevel string) OpOption
  • func WithWhitelistedSubnets(whitelistedSubnets string) OpOption

Types

type Client

type Client interface {
	Ping(ctx context.Context) (*rpcpb.PingResponse, error)
	Start(ctx context.Context, execPath string, opts ...OpOption) (*rpcpb.StartResponse, error)
	Health(ctx context.Context) (*rpcpb.HealthResponse, error)
	URIs(ctx context.Context) ([]string, error)
	Status(ctx context.Context) (*rpcpb.StatusResponse, error)
	StreamStatus(ctx context.Context, pushInterval time.Duration) (<-chan *rpcpb.ClusterInfo, error)
	RemoveNode(ctx context.Context, name string) (*rpcpb.RemoveNodeResponse, error)
	RestartNode(ctx context.Context, name string, execPath string, opts ...OpOption) (*rpcpb.RestartNodeResponse, error)
	Stop(ctx context.Context) (*rpcpb.StopResponse, error)
	Close() error
}

func New

func New(cfg Config) (Client, error)

type Config

type Config struct {
	LogLevel    string
	Endpoint    string
	DialTimeout time.Duration
}

type Op

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

type OpOption

type OpOption func(*Op)

func WithLogLevel

func WithLogLevel(logLevel string) OpOption

func WithWhitelistedSubnets

func WithWhitelistedSubnets(whitelistedSubnets string) OpOption