rpcserver

Documentation

Index

• func New(cfg *config.Config, database *database.Database, cache *cache.Cache, ...) *grpc.Server
• type Server
  • func (s *Server) GetObjectStorage(ctx context.Context, req *managerv1.GetObjectStorageRequest) (*managerv1.ObjectStorage, error)
  • func (s *Server) GetScheduler(ctx context.Context, req *managerv1.GetSchedulerRequest) (*managerv1.Scheduler, error)
  • func (s *Server) GetSeedPeer(ctx context.Context, req *managerv1.GetSeedPeerRequest) (*managerv1.SeedPeer, error)
  • func (s *Server) KeepAlive(stream managerv1.Manager_KeepAliveServer) error
  • func (s *Server) ListBuckets(ctx context.Context, req *managerv1.ListBucketsRequest) (*managerv1.ListBucketsResponse, error)
  • func (s *Server) ListSchedulers(ctx context.Context, req *managerv1.ListSchedulersRequest) (*managerv1.ListSchedulersResponse, error)
  • func (s *Server) UpdateScheduler(ctx context.Context, req *managerv1.UpdateSchedulerRequest) (*managerv1.Scheduler, error)
  • func (s *Server) UpdateSeedPeer(ctx context.Context, req *managerv1.UpdateSeedPeerRequest) (*managerv1.SeedPeer, error)

Functions

func New

func New(
	cfg *config.Config, database *database.Database, cache *cache.Cache, searcher searcher.Searcher,
	objectStorage objectstorage.ObjectStorage, objectStorageConfig *config.ObjectStorageConfig, opts ...grpc.ServerOption,
) *grpc.Server

New returns a new manager server from the given options.

Types

type Server

type Server struct {

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

Server is grpc server.

func (*Server) GetObjectStorage

func (s *Server) GetObjectStorage(ctx context.Context, req *managerv1.GetObjectStorageRequest) (*managerv1.ObjectStorage, error)

Get object storage configuration.

func (*Server) GetScheduler

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

Get Scheduler and Scheduler cluster configuration.

func (*Server) GetSeedPeer

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

Get SeedPeer and SeedPeer cluster configuration.

func (*Server) KeepAlive

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

KeepAlive with manager.

func (*Server) ListBuckets

func (s *Server) ListBuckets(ctx context.Context, req *managerv1.ListBucketsRequest) (*managerv1.ListBucketsResponse, error)

List buckets configuration.

func (*Server) ListSchedulers

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

List acitve schedulers configuration.

func (*Server) UpdateScheduler

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

Update scheduler configuration.

func (*Server) UpdateSeedPeer

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

Update SeedPeer configuration.