client

Documentation

Index

• type Client
  • func New(opts Options) (*Client, error)
  • func (c *Client) Ready() bool
  • func (c *Client) Recv(ctx context.Context) (*v1pb.PlacementOrder, error)
  • func (c *Client) Run(ctx context.Context) error
  • func (c *Client) Send(ctx context.Context, host *v1pb.Host) error
• type Options

Types

type Client

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

func New

func New(opts Options) (*Client, error)

New creates a new placement client for the given dial opts.

func (*Client) Ready

func (c *Client) Ready() bool

func (*Client) Recv

func (c *Client) Recv(ctx context.Context) (*v1pb.PlacementOrder, error)

func (*Client) Run

func (c *Client) Run(ctx context.Context) error

func (*Client) Send

func (c *Client) Send(ctx context.Context, host *v1pb.Host) error

type Options

type Options struct {
	Addresses []string
	Security  security.Handler
	Lock      *lock.Lock
	Table     table.Interface
	Healthz   healthz.Healthz
}