memory

Documentation

Index

• type Application
  • func NewApplication() *Application
  • func (s *Application) FindAll() ([]*internal.Application, error)
  • func (s *Application) FindOneByServiceID(id internal.ApplicationServiceID) (*internal.Application, error)
  • func (s *Application) Get(name internal.ApplicationName) (*internal.Application, error)
  • func (s *Application) Remove(name internal.ApplicationName) error
  • func (s *Application) Upsert(app *internal.Application) (bool, error)
• type Config
• type Instance
  • func NewInstance() *Instance
  • func (s *Instance) FindAll(m func(i *internal.Instance) bool) ([]*internal.Instance, error)
  • func (s *Instance) FindOne(m func(i *internal.Instance) bool) (*internal.Instance, error)
  • func (s *Instance) Get(id internal.InstanceID) (*internal.Instance, error)
  • func (s *Instance) Insert(i *internal.Instance) error
  • func (s *Instance) Remove(id internal.InstanceID) error
  • func (s *Instance) UpdateState(iID internal.InstanceID, state internal.InstanceState) error
• type InstanceOperation
  • func NewInstanceOperation() *InstanceOperation
  • func (s *InstanceOperation) Get(iID internal.InstanceID, opID internal.OperationID) (*internal.InstanceOperation, error)
  • func (s *InstanceOperation) GetAll(iID internal.InstanceID) ([]*internal.InstanceOperation, error)
  • func (s *InstanceOperation) GetLast(iID internal.InstanceID) (*internal.InstanceOperation, error)
  • func (s *InstanceOperation) Insert(io *internal.InstanceOperation) error
  • func (s *InstanceOperation) Remove(iID internal.InstanceID, opID internal.OperationID) error
  • func (s *InstanceOperation) UpdateState(iID internal.InstanceID, opID internal.OperationID, ...) error
  • func (s *InstanceOperation) UpdateStateDesc(iID internal.InstanceID, opID internal.OperationID, ...) error
  • func (s *InstanceOperation) WithTimeProvider(nowProvider func() time.Time)

Types

type Application

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

Application entity

func NewApplication

func NewApplication() *Application

NewApplication creates new storage for Applications

func (*Application) FindAll

func (s *Application) FindAll() ([]*internal.Application, error)

FindAll returns from memory all Application

func (*Application) FindOneByServiceID

func (s *Application) FindOneByServiceID(id internal.ApplicationServiceID) (*internal.Application, error)

FindOneByServiceID returns Application which contains Service with given ID

func (*Application) Get

func (s *Application) Get(name internal.ApplicationName) (*internal.Application, error)

Get returns from memory Application with given name

func (*Application) Remove

func (s *Application) Remove(name internal.ApplicationName) error

Remove removes from memory Application with given name

func (*Application) Upsert

func (s *Application) Upsert(app *internal.Application) (bool, error)

Upsert persists Application in memory.

If Application already exists in storage than full replace is performed.

True is returned if Application already existed in storage and was replaced.

type Config

type Config struct {
	MaxKeys int64 `json:"max-keys"`
}

Config provide config for storage

type Instance

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

Instance implements in-memory storage for Instance entities.

func NewInstance

func NewInstance() *Instance

NewInstance creates new Instances storage

func (*Instance) FindAll

func (s *Instance) FindAll(m func(i *internal.Instance) bool) ([]*internal.Instance, error)

FindOne returns from storage first object which passes the match.

func (*Instance) FindOne

func (s *Instance) FindOne(m func(i *internal.Instance) bool) (*internal.Instance, error)

FindOne returns from storage first object which passes the match.

func (*Instance) Get

func (s *Instance) Get(id internal.InstanceID) (*internal.Instance, error)

Get returns object from storage.

func (*Instance) Insert

func (s *Instance) Insert(i *internal.Instance) error

Insert inserts object to storage.

func (*Instance) Remove

func (s *Instance) Remove(id internal.InstanceID) error

Remove removing object from storage.

func (*Instance) UpdateState

func (s *Instance) UpdateState(iID internal.InstanceID, state internal.InstanceState) error

UpdateState modifies state on object in storage.

type InstanceOperation

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

InstanceOperation implements in-memory storage InstanceOperation.

func NewInstanceOperation

func NewInstanceOperation() *InstanceOperation

NewInstanceOperation returns new instance of InstanceOperation storage.

func (*InstanceOperation) Get

func (s *InstanceOperation) Get(iID internal.InstanceID, opID internal.OperationID) (*internal.InstanceOperation, error)

Get returns object from storage.

func (*InstanceOperation) GetAll

func (s *InstanceOperation) GetAll(iID internal.InstanceID) ([]*internal.InstanceOperation, error)

GetAll returns all objects from storage.

func (*InstanceOperation) GetLast

func (s *InstanceOperation) GetLast(iID internal.InstanceID) (*internal.InstanceOperation, error)

GetLast returns last inserted object from storage.

func (*InstanceOperation) Insert

func (s *InstanceOperation) Insert(io *internal.InstanceOperation) error

Insert inserts object into storage.

func (*InstanceOperation) Remove

func (s *InstanceOperation) Remove(iID internal.InstanceID, opID internal.OperationID) error

Remove removes object from storage.

func (*InstanceOperation) UpdateState

func (s *InstanceOperation) UpdateState(iID internal.InstanceID, opID internal.OperationID, state internal.OperationState) error

UpdateState modifies state on object in storage.

func (*InstanceOperation) UpdateStateDesc

func (s *InstanceOperation) UpdateStateDesc(iID internal.InstanceID, opID internal.OperationID, state internal.OperationState, desc *string) error

UpdateStateDesc updates both state and description for single operation. If desc is nil than description will be removed.

func (*InstanceOperation) WithTimeProvider

func (s *InstanceOperation) WithTimeProvider(nowProvider func() time.Time)

WithTimeProvider allows for passing custom time provider. Used mostly in testing.