Documentation ¶
Index ¶
- Constants
- type BaseOperationRepo
- func (r *BaseOperationRepo) DeleteOperation(operation *types.Operation) error
- func (r *BaseOperationRepo) GetOperationByID(operationID string) (*types.Operation, error)
- func (r *BaseOperationRepo) GetOperations() (map[string]*types.Operation, error)
- func (r *BaseOperationRepo) PutOperation(operation *types.Operation) error
- type OperationRepo
Constants ¶
View Source
const ( OperationsKey = "operations" DeletedOperationsKey = "deleted_operations" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseOperationRepo ¶
type BaseOperationRepo struct {
// contains filtered or unexported fields
}
func NewOperationRepo ¶
func NewOperationRepo(s state.State, topic string) (*BaseOperationRepo, error)
func (*BaseOperationRepo) DeleteOperation ¶
func (r *BaseOperationRepo) DeleteOperation(operation *types.Operation) error
DeleteOperation deletes operation from an operation pool
func (*BaseOperationRepo) GetOperationByID ¶
func (r *BaseOperationRepo) GetOperationByID(operationID string) (*types.Operation, error)
func (*BaseOperationRepo) GetOperations ¶
func (r *BaseOperationRepo) GetOperations() (map[string]*types.Operation, error)
GetOperations returns all operations from an operation pool
func (*BaseOperationRepo) PutOperation ¶
func (r *BaseOperationRepo) PutOperation(operation *types.Operation) error
Click to show internal directories.
Click to hide internal directories.