rpcserver

Documentation

Index

• func New(database *database.Database, cache *cache.Cache, searcher searcher.Searcher, ...) *grpc.Server
• type Server
  • func (s *Server) GetCDN(ctx context.Context, req *manager.GetCDNRequest) (*manager.CDN, error)
  • func (s *Server) GetScheduler(ctx context.Context, req *manager.GetSchedulerRequest) (*manager.Scheduler, 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) UpdateCDN(ctx context.Context, req *manager.UpdateCDNRequest) (*manager.CDN, error)
  • func (s *Server) UpdateScheduler(ctx context.Context, req *manager.UpdateSchedulerRequest) (*manager.Scheduler, error)

Functions

func New

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

Types

type Server

type Server struct {
	manager.UnimplementedManagerServer
	// contains filtered or unexported fields
}

func (*Server) GetCDN

func (s *Server) GetCDN(ctx context.Context, req *manager.GetCDNRequest) (*manager.CDN, error)

func (*Server) GetScheduler

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

func (*Server) KeepAlive

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

func (*Server) ListSchedulers

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

func (*Server) UpdateCDN

func (s *Server) UpdateCDN(ctx context.Context, req *manager.UpdateCDNRequest) (*manager.CDN, error)

func (*Server) UpdateScheduler

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