discovery

Documentation

Index

• type Config
• type Discovery
  • func NewDiscoveryServer(portnum int, logger logger.Logger, config *Config) (*Discovery, error)
  • func (d *Discovery) GetServiceInfo(ctx context.Context, info *peerpb.BasicPeerInfo) (*pb.ClientResponse, error)
  • func (d *Discovery) Register(ctx context.Context, id *peerpb.BasicPeerInfo) (*pb.ServerResponse, error)
  • func (d *Discovery) Run(ctx context.Context)
  • func (d *Discovery) Serve(ctx context.Context) error
  • func (m *Discovery) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (d *Discovery) Stop()

Types

type Config

type Config struct {
	NodeCount       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(portnum int, logger logger.Logger, config *Config) (*Discovery, error)

func (*Discovery) GetServiceInfo

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

func (*Discovery) Register

func (d *Discovery) Register(ctx context.Context, id *peerpb.BasicPeerInfo) (*pb.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(ctx context.Context) error

func (*Discovery) ServeHTTP

func (m *Discovery) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*Discovery) Stop

func (d *Discovery) Stop()