opscoor

Documentation

Index

• Variables
• type DefaultOperation
  • func (o *DefaultOperation) Active() bool
  • func (o *DefaultOperation) Finished() bool
  • func (o *DefaultOperation) ID() string
  • func (o *DefaultOperation) Started() bool
  • func (o *DefaultOperation) Type() interfaces.OperationType
• type SingleNodeOpsCoor
  • func NewSingleNodeOpsCoor() *SingleNodeOpsCoor
  • func (s *SingleNodeOpsCoor) Count(id string) int
  • func (s *SingleNodeOpsCoor) Prepare(opt interfaces.OperationType, id string, f interfaces.Callback) (interfaces.Operation, bool, error)

Variables

var (
	ErrNotImplemented = errors.New("not implemented")
)

defining different errors for this service

Types

type DefaultOperation

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

DefaultOperation this is the default operation abstract class

func (*DefaultOperation) Active

func (o *DefaultOperation) Active() bool

Active return the id of this operation

func (*DefaultOperation) Finished

func (o *DefaultOperation) Finished() bool

Finished return the id of this operation

func (*DefaultOperation) ID

func (o *DefaultOperation) ID() string

ID return the id of this operation

func (*DefaultOperation) Started

func (o *DefaultOperation) Started() bool

Started return the id of this operation

func (*DefaultOperation) Type

func (o *DefaultOperation) Type() interfaces.OperationType

Type return the id of this operation

type SingleNodeOpsCoor

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

SingleNodeOpsCoor this coordinator is used in a single node. It coordinates different operation on the same id the following operation are defined

func NewSingleNodeOpsCoor

func NewSingleNodeOpsCoor() *SingleNodeOpsCoor

NewSingleNodeOpsCoor return a OpsCoor for a single node system

func (*SingleNodeOpsCoor) Count

func (s *SingleNodeOpsCoor) Count(id string) int

Count operations of an id

func (*SingleNodeOpsCoor) Prepare

func (s *SingleNodeOpsCoor) Prepare(opt interfaces.OperationType, id string, f interfaces.Callback) (interfaces.Operation, bool, error)

Prepare the operation on the id, this is a factory