server

Documentation

Index

• Variables
• type Config
• type DummyServer
  • func NewDummyServer(port int, httpPort int) (DummyServer, error)
• type MixConfig
• type NativeStakingConfig
• type NativeStakingServer
  • func NewNativeStakingServer(cfg *NativeStakingConfig) (*NativeStakingServer, error)
  • func (s *NativeStakingServer) Committee() *committee.NativeCommittee
  • func (s *NativeStakingServer) GetBuckets(ctx context.Context, request *api.GetBucketsRequest) (*api.BucketResponse, error)
  • func (s *NativeStakingServer) GetBucketsByCandidate(ctx context.Context, request *api.GetBucketsByCandidateRequest) (*api.BucketResponse, error)
  • func (s *NativeStakingServer) GetCandidateByName(ctx context.Context, request *api.GetCandidateByNameRequest) (*api.Candidate, error)
  • func (s *NativeStakingServer) GetCandidates(ctx context.Context, request *api.GetCandidatesRequest) (*api.CandidateResponse, error)
  • func (s *NativeStakingServer) GetMeta(ctx context.Context, empty *empty.Empty) (*api.ChainMeta, error)
  • func (s *NativeStakingServer) GetRawData(ctx context.Context, request *api.GetRawDataRequest) (*api.RawDataResponse, error)
  • func (s *NativeStakingServer) IsHealth(ctx context.Context, empty *empty.Empty) (*api.HealthCheckResponse, error)
  • func (s *NativeStakingServer) Start(ctx context.Context) error
  • func (s *NativeStakingServer) Stop(ctx context.Context) error
• type Server
  • func NewServer(cfg *Config, vs *votesync.VoteSync) (Server, error)
• type ServerMix
  • func NewServerMix(mCfg MixConfig) (*ServerMix, error)
  • func (sm *ServerMix) Start(ctx context.Context) error
  • func (sm *ServerMix) Stop(ctx context.Context) error

Variables

var ErrNotSupported = errors.New("Not supported")

Types

type Config

type Config struct {
	DB                   db.Config        `yaml:"db"`
	Port                 int              `yaml:"port"`
	HttpPort             int              `yaml:"httpPort"`
	Committee            committee.Config `yaml:"committee"`
	SelfStakingThreshold string           `yaml:"selfStakingThreshold"`
	ScoreThreshold       string           `yaml:"scoreThreshold"`
}

Config defines the config for server

type DummyServer

type DummyServer interface {
	api.APIServiceServer
	Start(context.Context) error
	Stop(context.Context) error
}

DummyServer defines the interface of the ranking dummy server implementation

func NewDummyServer

func NewDummyServer(port int, httpPort int) (DummyServer, error)

NewDummyServer returns an implementation of ranking dummy server

type MixConfig

type MixConfig struct {
	ElectionConfig      Config              `yaml:"electionConfig"`
	NativeConfig        NativeStakingConfig `yaml:"nativeConfig"`
	VoteSync            votesync.Config     `yaml:"voteSync"`
	EnableVoteSync      bool                `yaml:"enableVoteSync"`
	DummyServerPort     int                 `yaml:"dummyServerPort"`
	DummyServerHttpPort int                 `yaml:"dummyServerHttpPort"`
}

type NativeStakingConfig

type NativeStakingConfig struct {
	DB        db.Config                       `yaml:"db"`
	Port      int                             `yaml:"port"`
	Committee committee.NativeCommitteeConfig `yaml:"committee"`
}

NativeStakingConfig defines the config for native staking server

type NativeStakingServer

type NativeStakingServer struct {
	api.APIServiceServer
	// contains filtered or unexported fields
}

NativeStakingServer implements api.APIServiceServer.

func NewNativeStakingServer

func NewNativeStakingServer(cfg *NativeStakingConfig) (*NativeStakingServer, error)

NewNativeStakingServer returns an implementation of ranking server

func (*NativeStakingServer) Committee

func (s *NativeStakingServer) Committee() *committee.NativeCommittee

func (*NativeStakingServer) GetBuckets

func (s *NativeStakingServer) GetBuckets(ctx context.Context, request *api.GetBucketsRequest) (*api.BucketResponse, error)

GetBuckets returns a list of buckets

func (*NativeStakingServer) GetBucketsByCandidate

func (s *NativeStakingServer) GetBucketsByCandidate(ctx context.Context, request *api.GetBucketsByCandidateRequest) (*api.BucketResponse, error)

GetBucketsByCandidate returns the buckets

func (*NativeStakingServer) GetCandidateByName

func (s *NativeStakingServer) GetCandidateByName(ctx context.Context, request *api.GetCandidateByNameRequest) (*api.Candidate, error)

GetCandidateByName returns the candidate details

func (*NativeStakingServer) GetCandidates

func (s *NativeStakingServer) GetCandidates(ctx context.Context, request *api.GetCandidatesRequest) (*api.CandidateResponse, error)

GetCandidates returns a list of candidates sorted by weighted votes

func (*NativeStakingServer) GetMeta

func (s *NativeStakingServer) GetMeta(ctx context.Context, empty *empty.Empty) (*api.ChainMeta, error)

GetMeta returns the meta of the chain

func (*NativeStakingServer) GetRawData

func (s *NativeStakingServer) GetRawData(ctx context.Context, request *api.GetRawDataRequest) (*api.RawDataResponse, error)

func (*NativeStakingServer) IsHealth

func (s *NativeStakingServer) IsHealth(ctx context.Context, empty *empty.Empty) (*api.HealthCheckResponse, error)

func (*NativeStakingServer) Start

func (s *NativeStakingServer) Start(ctx context.Context) error

func (*NativeStakingServer) Stop

func (s *NativeStakingServer) Stop(ctx context.Context) error

type Server

type Server interface {
	api.APIServiceServer
	Start(context.Context) error
	Stop(context.Context) error
}

Server defines the interface of the ranking server implementation

func NewServer

func NewServer(cfg *Config, vs *votesync.VoteSync) (Server, error)

NewServer returns an implementation of ranking server

type ServerMix

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

func NewServerMix

func NewServerMix(mCfg MixConfig) (*ServerMix, error)

func (*ServerMix) Start

func (sm *ServerMix) Start(ctx context.Context) error

func (*ServerMix) Stop

func (sm *ServerMix) Stop(ctx context.Context) error