clients

Documentation

Index

• type Clients
  • func New(opts Options) *Clients
  • func (c *Clients) All(ctx context.Context) ([]schedulerv1pb.SchedulerClient, error)
  • func (c *Clients) Next(ctx context.Context) (schedulerv1pb.SchedulerClient, error)
  • func (c *Clients) Run(ctx context.Context) 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) All

func (c *Clients) All(ctx context.Context) ([]schedulerv1pb.SchedulerClient, error)

All returns all scheduler clients.

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) Run

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

type Options

type Options struct {
	Addresses []string
	Security  security.Handler
	Healthz   healthz.Healthz
}

Options contains the configuration options for the Scheduler clients.