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 *manager.GetObjectStorageRequest) (*manager.ObjectStorage, error)
  • 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) ListBuckets(ctx context.Context, req *manager.ListBucketsRequest) (*manager.ListBucketsResponse, 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(
	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.
	manager.UnimplementedManagerServer
	// contains filtered or unexported fields
}

Server is grpc server.

func (*Server) GetObjectStorage

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

Get object storage configuration.

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) ListBuckets

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

List buckets configuration.

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.