operator

Documentation

Index

• type Operator
  • func New(opts ...Option) (*Operator, error)
  • func (o *Operator) Cancel(opid uuid.UUID) error
  • func (o *Operator) Create(ctx context.Context, ...) (uuid.UUID, error)
  • func (o *Operator) Get(ctx context.Context, opid uuid.UUID) (*types.Operation, error)
  • func (o *Operator) List(ctx context.Context, opts ...listoption.ListOption) ([]*types.Operation, error)
• type Option
  • func WithDispatcher(dispatcher types.Dispatcher) Option
  • func WithLogger(logger logger.Logger) Option
  • func WithStore(store types.Store) Option
• type Options

Types

type Operator

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

func New

func New(opts ...Option) (*Operator, error)

func (*Operator) Cancel

func (o *Operator) Cancel(opid uuid.UUID) error

func (*Operator) Create

func (o *Operator) Create(ctx context.Context, opFunc func(ctx context.Context, opid uuid.UUID) (interface{}, error)) (uuid.UUID, error)

func (*Operator) Get

func (o *Operator) Get(ctx context.Context, opid uuid.UUID) (*types.Operation, error)

func (*Operator) List

func (o *Operator) List(ctx context.Context, opts ...listoption.ListOption) ([]*types.Operation, error)

type Option

type Option func(*Options)

func WithDispatcher

func WithDispatcher(dispatcher types.Dispatcher) Option

func WithLogger

func WithLogger(logger logger.Logger) Option

func WithStore

func WithStore(store types.Store) Option

type Options

type Options struct {
	Logger types.Logger

	Store      types.Store
	Dispatcher types.Dispatcher
}