operations

Documentation

Index

• type Operation
• type Service
  • func New(ctx context.Context, logger logger, sqldb *sql.DB) *Service
  • func (s *Service) CancelOperation(ctx context.Context, in *longrunning.CancelOperationRequest) (*empty.Empty, error)
  • func (s *Service) CreateOperation(ctx context.Context, metadata *any.Any, operationFunc Operation) (*longrunning.Operation, error)
  • func (s *Service) DeleteOperation(ctx context.Context, in *longrunning.DeleteOperationRequest) (*empty.Empty, error)
  • func (s *Service) GetOperation(ctx context.Context, in *longrunning.GetOperationRequest) (*longrunning.Operation, error)
  • func (s *Service) ListOperations(ctx context.Context, in *longrunning.ListOperationsRequest) (*longrunning.ListOperationsResponse, error)
  • func (s *Service) WaitOperation(ctx context.Context, in *longrunning.WaitOperationRequest) (*longrunning.Operation, error)

Types

type Operation

type Operation func(context.Context, *longrunning.Operation, chan<- *longrunning.Operation) error

Operation is a single long running operation.

type Service

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

Service manages longrunning api operations.

func New

func New(ctx context.Context, logger logger, sqldb *sql.DB) *Service

New returns new service.

func (*Service) CancelOperation

func (s *Service) CancelOperation(ctx context.Context, in *longrunning.CancelOperationRequest) (*empty.Empty, error)

CancelOperation cancels a running operation.

func (*Service) CreateOperation

func (s *Service) CreateOperation(ctx context.Context, metadata *any.Any, operationFunc Operation) (*longrunning.Operation, error)

CreateOperation creates an operation, and runs it.

func (*Service) DeleteOperation

func (s *Service) DeleteOperation(ctx context.Context, in *longrunning.DeleteOperationRequest) (*empty.Empty, error)

DeleteOperation deletes an operation.

func (*Service) GetOperation

func (s *Service) GetOperation(ctx context.Context, in *longrunning.GetOperationRequest) (*longrunning.Operation, error)

GetOperation returns a single operation.

func (*Service) ListOperations

func (s *Service) ListOperations(ctx context.Context, in *longrunning.ListOperationsRequest) (*longrunning.ListOperationsResponse, error)

ListOperations returns list of operations.

func (*Service) WaitOperation

func (s *Service) WaitOperation(ctx context.Context, in *longrunning.WaitOperationRequest) (*longrunning.Operation, error)

WaitOperation waits until operations is done, and then returns an operation.