client

Documentation

Index

• type Client
  • func NewClient(target string, opts ...grpc.DialOption) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) GetThread(ctx context.Context, name string) (*pb.GetThreadReply, error)
  • func (c *Client) ListThreads(ctx context.Context) (*pb.ListThreadsReply, error)

Types

type Client

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

Client provides the client api.

func NewClient

func NewClient(target string, opts ...grpc.DialOption) (*Client, error)

NewClient starts the client.

func (*Client) Close

func (c *Client) Close() error

Close closes the client's grpc connection and cancels any active requests.

func (*Client) GetThread

func (c *Client) GetThread(ctx context.Context, name string) (*pb.GetThreadReply, error)

GetThread returns a thread by name.

func (*Client) ListThreads

func (c *Client) ListThreads(ctx context.Context) (*pb.ListThreadsReply, error)

ListThreads returns a list of threads. Threads can be created using the threads or threads network client.