server

Documentation

Index

• Variables
• type Config
• type DummyServer
  • func NewDummyServer(port int, vs *votesync.VoteSync) (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"`
	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, vs *votesync.VoteSync) (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"`
}

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