Documentation ¶
Index ¶
- type Bundle
- func (s *Bundle) FindAll() ([]*internal.Bundle, error)
- func (s *Bundle) Get(name internal.BundleName, ver semver.Version) (*internal.Bundle, error)
- func (s *Bundle) GetByID(id internal.BundleID) (*internal.Bundle, error)
- func (s *Bundle) Remove(name internal.BundleName, ver semver.Version) error
- func (s *Bundle) RemoveAll() error
- func (s *Bundle) RemoveByID(id internal.BundleID) error
- func (s *Bundle) Upsert(b *internal.Bundle) (bool, error)
- type Chart
- type Client
- type Config
- type Instance
- type InstanceBindData
- type 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) 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) *InstanceOperation
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Bundle ¶
type Bundle struct {
// contains filtered or unexported fields
}
Bundle implements etcd storage for Bundle entities.
func (*Bundle) RemoveByID ¶
RemoveByID is removing object by primary ID from storage.
type Chart ¶
type Chart struct {
// contains filtered or unexported fields
}
Chart provides storage operations on Chart entity
type Config ¶
type Config struct { Endpoints []string `json:"endpoints"` Username string `json:"username"` Password string `json:"password"` ForceClient *clientv3.Client }
Config holds configuration for etcd access in storage.
type Instance ¶
type Instance struct {
// contains filtered or unexported fields
}
Instance implements etcd based storage for Instance entities.
func NewInstance ¶
NewInstance creates new Instances storage
type InstanceBindData ¶
type InstanceBindData struct {
// contains filtered or unexported fields
}
InstanceBindData implements etcd based storage for BindData.
func NewInstanceBindData ¶
func NewInstanceBindData(cli clientv3.KV) (*InstanceBindData, error)
NewInstanceBindData returns new instance of BindData storage.
func (*InstanceBindData) Get ¶
func (s *InstanceBindData) Get(iID internal.InstanceID) (*internal.InstanceBindData, error)
Get returns object from storage.
func (*InstanceBindData) Insert ¶
func (s *InstanceBindData) Insert(ibd *internal.InstanceBindData) error
Insert inserts object into storage.
func (*InstanceBindData) Remove ¶
func (s *InstanceBindData) Remove(iID internal.InstanceID) error
Remove removes object from storage.
type InstanceOperation ¶
type InstanceOperation struct {
// contains filtered or unexported fields
}
InstanceOperation implements etcd based storage InstanceOperation.
func NewInstanceOperation ¶
func NewInstanceOperation(cli clientv3.KV) (*InstanceOperation, error)
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) 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 modifies state and description on object in storage. If desc is nil than description will be removed.
func (*InstanceOperation) WithTimeProvider ¶
func (s *InstanceOperation) WithTimeProvider(nowProvider func() time.Time) *InstanceOperation
WithTimeProvider allows for passing custom time provider. Used mostly in testing.