rpcserver

Documentation

Index

• func New(database *database.Database, cache *cache.Cache, searcher searcher.Searcher, ...) *grpc.Server
• type Server
  • func (s *Server) GetScheduler(ctx context.Context, req *manager.GetSchedulerRequest) (*manager.Scheduler, error)
  • func (s *Server) GetSeedPeer(ctx context.Context, req *manager.GetSeedPeerRequest) (*manager.SeedPeer, error)
  • func (s *Server) KeepAlive(stream manager.Manager_KeepAliveServer) error
  • func (s *Server) ListSchedulers(ctx context.Context, req *manager.ListSchedulersRequest) (*manager.ListSchedulersResponse, error)
  • func (s *Server) UpdateScheduler(ctx context.Context, req *manager.UpdateSchedulerRequest) (*manager.Scheduler, error)
  • func (s *Server) UpdateSeedPeer(ctx context.Context, req *manager.UpdateSeedPeerRequest) (*manager.SeedPeer, error)

Functions

func New

func New(database *database.Database, cache *cache.Cache, searcher searcher.Searcher, opts ...grpc.ServerOption) *grpc.Server

New returns a new manager server from the given options.

Types

type Server

type Server struct {

	// Manager grpc interface.
	manager.UnimplementedManagerServer
	// contains filtered or unexported fields
}

Server is grpc server.

func (*Server) GetScheduler

func (s *Server) GetScheduler(ctx context.Context, req *manager.GetSchedulerRequest) (*manager.Scheduler, error)

Get Scheduler and Scheduler cluster configuration.

func (*Server) GetSeedPeer

func (s *Server) GetSeedPeer(ctx context.Context, req *manager.GetSeedPeerRequest) (*manager.SeedPeer, error)

Get SeedPeer and SeedPeer cluster configuration.

func (*Server) KeepAlive

func (s *Server) KeepAlive(stream manager.Manager_KeepAliveServer) error

KeepAlive with manager.

func (*Server) ListSchedulers

func (s *Server) ListSchedulers(ctx context.Context, req *manager.ListSchedulersRequest) (*manager.ListSchedulersResponse, error)

List acitve schedulers configuration.

func (*Server) UpdateScheduler

func (s *Server) UpdateScheduler(ctx context.Context, req *manager.UpdateSchedulerRequest) (*manager.Scheduler, error)

Update scheduler configuration.

func (*Server) UpdateSeedPeer

func (s *Server) UpdateSeedPeer(ctx context.Context, req *manager.UpdateSeedPeerRequest) (*manager.SeedPeer, error)

Update SeedPeer configuration.