mothershipadmin_rpc

Documentation

Index

• type Server
  • func NewServer(db *base.DB, temporalClient client.Client, githubTeam string, ...) (*Server, error)
  • func (s *Server) CreateWorker(_ context.Context, req *mshipadminpb.CreateWorkerRequest) (*mshipadminpb.Worker, error)
  • func (s *Server) DeleteWorker(_ context.Context, req *mshipadminpb.DeleteWorkerRequest) (*emptypb.Empty, error)
  • func (s *Server) GetOperation(ctx context.Context, req *longrunning.GetOperationRequest) (*longrunning.Operation, error)
  • func (s *Server) GetWorker(_ context.Context, req *mshipadminpb.GetWorkerRequest) (*mshipadminpb.Worker, error)
  • func (s *Server) ListWorkers(_ context.Context, req *mshipadminpb.ListWorkersRequest) (*mshipadminpb.ListWorkersResponse, error)
  • func (s *Server) RescueEntryImport(ctx context.Context, req *mshipadminpb.RescueEntryImportRequest) (*emptypb.Empty, error)
  • func (s *Server) RetractEntry(ctx context.Context, req *mshipadminpb.RetractEntryRequest) (*longrunning.Operation, error)
  • func (s *Server) Start() error

Types

type Server

type Server struct {
	base.GRPCServer

	mshipadminpb.UnimplementedMshipAdminServer
	longrunning.UnimplementedOperationsServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(db *base.DB, temporalClient client.Client, githubTeam string, opts ...base.GRPCServerOption) (*Server, error)

func (*Server) CreateWorker

func (s *Server) CreateWorker(_ context.Context, req *mshipadminpb.CreateWorkerRequest) (*mshipadminpb.Worker, error)

func (*Server) DeleteWorker

func (s *Server) DeleteWorker(_ context.Context, req *mshipadminpb.DeleteWorkerRequest) (*emptypb.Empty, error)

func (*Server) GetOperation

func (s *Server) GetOperation(ctx context.Context, req *longrunning.GetOperationRequest) (*longrunning.Operation, error)

func (*Server) GetWorker

func (s *Server) GetWorker(_ context.Context, req *mshipadminpb.GetWorkerRequest) (*mshipadminpb.Worker, error)

func (*Server) ListWorkers

func (s *Server) ListWorkers(_ context.Context, req *mshipadminpb.ListWorkersRequest) (*mshipadminpb.ListWorkersResponse, error)

func (*Server) RescueEntryImport

func (s *Server) RescueEntryImport(ctx context.Context, req *mshipadminpb.RescueEntryImportRequest) (*emptypb.Empty, error)

func (*Server) RetractEntry

func (s *Server) RetractEntry(ctx context.Context, req *mshipadminpb.RetractEntryRequest) (*longrunning.Operation, error)

func (*Server) Start

func (s *Server) Start() error