server

Documentation

Index

• Constants
• type OptionFunc
  • func WithGrpcPort(p int) OptionFunc
  • func WithLogger(l *zap.Logger) OptionFunc
  • func WithMonitoringPort(p int) OptionFunc
• type Server
  • func NewServer(ctrl *controller.Controller, s *scheduler.Scheduler, opts ...OptionFunc) (*Server, error)
  • func (s *Server) Get(ctx context.Context, in *pb.GetMessage) (*pb.GetResponse, error)
  • func (s *Server) StartBlocking() error

Constants

const (
	DefaultGRPCPort       = 5000
	DefaultMonitoringPort = 9696
)

Types

type OptionFunc

type OptionFunc func(s *Server)

func WithGrpcPort

func WithGrpcPort(p int) OptionFunc

func WithLogger

func WithLogger(l *zap.Logger) OptionFunc

func WithMonitoringPort

func WithMonitoringPort(p int) OptionFunc

type Server

type Server struct {
	pb.UnimplementedConfKVServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctrl *controller.Controller, s *scheduler.Scheduler, opts ...OptionFunc) (*Server, error)

func (*Server) Get

func (s *Server) Get(ctx context.Context, in *pb.GetMessage) (*pb.GetResponse, error)

func (*Server) StartBlocking

func (s *Server) StartBlocking() error