client

Documentation

Index

• type Client
  • func New(target string) (Client, error)
  • func NewWithAddrs(netAddrs []dfnet.NetAddr) (Client, error)

Types

type Client

type Client interface {
	// Update Seed peer configuration.
	UpdateSeedPeer(*manager.UpdateSeedPeerRequest) (*manager.SeedPeer, error)

	// Get Scheduler and Scheduler cluster configuration.
	GetScheduler(*manager.GetSchedulerRequest) (*manager.Scheduler, error)

	// Update scheduler configuration.
	UpdateScheduler(*manager.UpdateSchedulerRequest) (*manager.Scheduler, error)

	// List acitve schedulers configuration.
	ListSchedulers(*manager.ListSchedulersRequest) (*manager.ListSchedulersResponse, error)

	// KeepAlive with manager.
	KeepAlive(time.Duration, *manager.KeepAliveRequest)

	// Close client connect.
	Close() error
}

func New

func New(target string) (Client, error)

func NewWithAddrs

func NewWithAddrs(netAddrs []dfnet.NetAddr) (Client, error)