clients

Documentation

Index

• type Clients
  • func New(opts Options) *Clients
  • func (c *Clients) Addresses() []string
  • func (c *Clients) Disable()
  • func (c *Clients) Next(ctx context.Context) (schedulerv1pb.SchedulerClient, error)
  • func (c *Clients) Reload(ctx context.Context, addresses []string) error
• type Options

Types

type Clients

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

Clients builds Scheduler clients and provides those clients in a round-robin fashion.

func New

func New(opts Options) *Clients

func (*Clients) Addresses

func (c *Clients) Addresses() []string

func (*Clients) Disable

func (c *Clients) Disable()

func (*Clients) Next

func (c *Clients) Next(ctx context.Context) (schedulerv1pb.SchedulerClient, error)

Next returns the next client in a round-robin manner.

func (*Clients) Reload

func (c *Clients) Reload(ctx context.Context, addresses []string) error

type Options

type Options struct {
	Security security.Handler
}

Options contains the configuration options for the Scheduler clients.