discovery

Documentation

Index

• type Config
• type Discovery
  • func NewDiscoveryServer(logger logger.Logger, config Config, ipMapping map[string]string) *Discovery
  • func (d *Discovery) GetServiceInfo(ctx context.Context, info *peerpb.BasicPeerInfo) (*masterpb.ClientResponse, error)
  • func (d *Discovery) Register(ctx context.Context, id *peerpb.BasicPeerInfo) (*masterpb.ServerResponse, error)
  • func (d *Discovery) Run(ctx context.Context)
  • func (d *Discovery) Serve(lis net.Listener) error
  • func (d *Discovery) Stop()
  • func (d *Discovery) TriggerClients()
  • func (d *Discovery) WaitReady(ctx context.Context) error

Types

type Config

type Config struct {
	PeerCount       int32                     `json:"node_count"`
	ClientCount     int32                     `json:"client_count"`
	Algorithm       peerpb.Algorithm          `json:"algorithm"`
	MaxFailures     int32                     `json:"max_failures"`
	MaxFastFailures int32                     `json:"max_fast_failures"`
	LeaderRegion    string                    `json:"leader_region"`
	KeyFile         string                    `json:"key_file"`
	ServerConfig    masterpb.BaseServerConfig `json:"server"`
	ClientConfig    masterpb.BaseClientConfig `json:"client"`
}

type Discovery

type Discovery struct {
	Config
	// contains filtered or unexported fields
}

func NewDiscoveryServer

func NewDiscoveryServer(logger logger.Logger, config Config, ipMapping map[string]string) *Discovery

func (*Discovery) GetServiceInfo

func (d *Discovery) GetServiceInfo(ctx context.Context, info *peerpb.BasicPeerInfo) (*masterpb.ClientResponse, error)

func (*Discovery) Register

func (d *Discovery) Register(ctx context.Context, id *peerpb.BasicPeerInfo) (*masterpb.ServerResponse, error)

Register is the grpc handler for registering a service

func (*Discovery) Run

func (d *Discovery) Run(ctx context.Context)

func (*Discovery) Serve

func (d *Discovery) Serve(lis net.Listener) error

func (*Discovery) Stop

func (d *Discovery) Stop()

func (*Discovery) TriggerClients

func (d *Discovery) TriggerClients()

func (*Discovery) WaitReady

func (d *Discovery) WaitReady(ctx context.Context) error