svc

Documentation

Index

• Constants
• type OperationsServer
  • func NewOperationsServer(store store.Store) *OperationsServer
  • func (o *OperationsServer) CancelOperation(ctx context.Context, req *lrpb.CancelOperationRequest) (*emptypb.Empty, error)
  • func (o *OperationsServer) DeleteOperation(ctx context.Context, req *lrpb.DeleteOperationRequest) (*emptypb.Empty, error)
  • func (o *OperationsServer) GetOperation(ctx context.Context, req *lrpb.GetOperationRequest) (operation *lrpb.Operation, err error)
  • func (o *OperationsServer) ListOperations(ctx context.Context, req *lrpb.ListOperationsRequest) (*lrpb.ListOperationsResponse, error)
  • func (o *OperationsServer) WaitOperation(ctx context.Context, req *lrpb.WaitOperationRequest) (*lrpb.Operation, error)
• type Scheduler
• type SchedulingServer
  • func NewSchedulingServer(scheduler Scheduler, operations lrpb.OperationsServer, store store.Store) *SchedulingServer
  • func (s *SchedulingServer) StartTestSession(ctx context.Context, req *svcpb.StartTestSessionRequest) (operation *lrpb.Operation, err error)

Constants

const Version = "v0.1.0-alpha"

Version contains the current version of the service. This version complies with Semantic Versioning 2.0.0; see https://semver.org/.

Types

type OperationsServer

type OperationsServer struct {
	// contains filtered or unexported fields
}

OperationsServer implements the google.longrunning.Operations interface to provide access to a data Store.

func NewOperationsServer

func NewOperationsServer(store store.Store) *OperationsServer

NewOperationsServer constructs a new instance of OperationsServer.

func (*OperationsServer) CancelOperation

func (o *OperationsServer) CancelOperation(ctx context.Context, req *lrpb.CancelOperationRequest) (*emptypb.Empty, error)

CancelOperation cancels an operation. This function is not implemented.

func (*OperationsServer) DeleteOperation

func (o *OperationsServer) DeleteOperation(ctx context.Context, req *lrpb.DeleteOperationRequest) (*emptypb.Empty, error)

DeleteOperation deletes an operation. This function is not implemented.

func (*OperationsServer) GetOperation

func (o *OperationsServer) GetOperation(ctx context.Context, req *lrpb.GetOperationRequest) (operation *lrpb.Operation, err error)

GetOperation gets an operation. This function returns nil if the operation name is invalid or does not correspond to an existing session in the Store.

func (*OperationsServer) ListOperations

func (o *OperationsServer) ListOperations(ctx context.Context, req *lrpb.ListOperationsRequest) (*lrpb.ListOperationsResponse, error)

ListOperations returns the list of operations. This function is not implemented.

func (*OperationsServer) WaitOperation

func (o *OperationsServer) WaitOperation(ctx context.Context, req *lrpb.WaitOperationRequest) (*lrpb.Operation, error)

WaitOperation waits for an operation to finish. This function is not implemented.

type Scheduler

type Scheduler interface {
	// Schedule enqueues a session, returning any immediate error.
	// Infrastructure and test runtime errors will not be
	// returned.
	Schedule(s *types.Session) error
}

Scheduler is a single method interface for queueing sessions.

type SchedulingServer

type SchedulingServer struct {
	// contains filtered or unexported fields
}

SchedulingServer implements the scheduling service.

func NewSchedulingServer

func NewSchedulingServer(scheduler Scheduler, operations lrpb.OperationsServer, store store.Store) *SchedulingServer

NewSchedulingServer constructs a scheduling server from a scheduler, an operations server, and a store.

func (*SchedulingServer) StartTestSession

func (s *SchedulingServer) StartTestSession(ctx context.Context, req *svcpb.StartTestSessionRequest) (operation *lrpb.Operation, err error)

StartTestSession implements the scheduling service interface for starting a test session.