client

Documentation

Index

• type Client
• type RpcClient
  • func NewRpcClient(ctx context.Context, addr string) (*RpcClient, error)
  • func (c *RpcClient) Add(ctx context.Context) (chan<- *oproto.AddRequest, <-chan *oproto.AddResponse, error)
  • func (c *RpcClient) Close()
  • func (c *RpcClient) Get(ctx context.Context, request *oproto.GetRequest) (<-chan *oproto.GetResponse, error)
  • func (c *RpcClient) GetConfig(ctx context.Context) (*oproto.ClusterConfig, error)
  • func (c *RpcClient) List(ctx context.Context, request *oproto.ListRequest) (<-chan *oproto.ListResponse, error)

Types

type Client

type Client interface {
	List(ctx context.Context, request *oproto.ListRequest) (<-chan *oproto.ListResponse, error)
	Get(ctx context.Context, request *oproto.GetRequest) (<-chan *oproto.GetResponse, error)
	Add(ctx context.Context) (chan<- *oproto.AddRequest, <-chan *oproto.AddResponse, error)
	GetConfig(ctx context.Context) (*oproto.ClusterConfig, error)
}

type RpcClient

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

func NewRpcClient

func NewRpcClient(ctx context.Context, addr string) (*RpcClient, error)

func (*RpcClient) Add

func (c *RpcClient) Add(ctx context.Context) (chan<- *oproto.AddRequest, <-chan *oproto.AddResponse, error)

func (*RpcClient) Close

func (c *RpcClient) Close()

func (*RpcClient) Get

func (c *RpcClient) Get(ctx context.Context, request *oproto.GetRequest) (<-chan *oproto.GetResponse, error)

func (*RpcClient) GetConfig

func (c *RpcClient) GetConfig(ctx context.Context) (*oproto.ClusterConfig, error)

func (*RpcClient) List

func (c *RpcClient) List(ctx context.Context, request *oproto.ListRequest) (<-chan *oproto.ListResponse, error)