mothership_rpc

Documentation

Index

• type Server
  • func NewServer(db *base.DB, temporalClient client.Client, opts ...base.GRPCServerOption) (*Server, error)
  • func (s *Server) CreateBatch(ctx context.Context, req *mothershippb.CreateBatchRequest) (*mothershippb.Batch, error)
  • func (s *Server) GetBatch(_ context.Context, req *mothershippb.GetBatchRequest) (*mothershippb.Batch, error)
  • func (s *Server) GetEntry(ctx context.Context, req *mothershippb.GetEntryRequest) (*mothershippb.Entry, error)
  • func (s *Server) GetOperation(ctx context.Context, req *longrunning.GetOperationRequest) (*longrunning.Operation, error)
  • func (s *Server) ListBatches(_ context.Context, req *mothershippb.ListBatchesRequest) (*mothershippb.ListBatchesResponse, error)
  • func (s *Server) ListEntries(_ context.Context, req *mothershippb.ListEntriesRequest) (*mothershippb.ListEntriesResponse, error)
  • func (s *Server) SealBatch(ctx context.Context, req *mothershippb.SealBatchRequest) (*longrunning.Operation, error)
  • func (s *Server) Start() error
  • func (s *Server) SubmitEntry(ctx context.Context, req *mothershippb.SubmitEntryRequest) (*longrunning.Operation, error)
  • func (s *Server) WorkerPing(ctx context.Context, req *emptypb.Empty) (*emptypb.Empty, error)

Types

type Server

type Server struct {
	base.GRPCServer

	mothershippb.UnimplementedSrpmArchiverServer
	longrunning.UnimplementedOperationsServer
	// contains filtered or unexported fields
}

func NewServer

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

func (*Server) CreateBatch

func (s *Server) CreateBatch(ctx context.Context, req *mothershippb.CreateBatchRequest) (*mothershippb.Batch, error)

func (*Server) GetBatch

func (s *Server) GetBatch(_ context.Context, req *mothershippb.GetBatchRequest) (*mothershippb.Batch, error)

func (*Server) GetEntry

func (s *Server) GetEntry(ctx context.Context, req *mothershippb.GetEntryRequest) (*mothershippb.Entry, error)

func (*Server) GetOperation

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

func (*Server) ListBatches

func (s *Server) ListBatches(_ context.Context, req *mothershippb.ListBatchesRequest) (*mothershippb.ListBatchesResponse, error)

func (*Server) ListEntries

func (s *Server) ListEntries(_ context.Context, req *mothershippb.ListEntriesRequest) (*mothershippb.ListEntriesResponse, error)

func (*Server) SealBatch

func (s *Server) SealBatch(ctx context.Context, req *mothershippb.SealBatchRequest) (*longrunning.Operation, error)

func (*Server) Start

func (s *Server) Start() error

func (*Server) SubmitEntry

func (s *Server) SubmitEntry(ctx context.Context, req *mothershippb.SubmitEntryRequest) (*longrunning.Operation, error)

SubmitEntry handles the RPC request for submitting an entry. This is usually called by the worker. The worker must be authenticated. The checksum will "lease" the entry for the worker, so that other workers will not submit the same entry. This "lease" is enforced using Temporal

func (*Server) WorkerPing

func (s *Server) WorkerPing(ctx context.Context, req *emptypb.Empty) (*emptypb.Empty, error)