Versions in this module Expand all Collapse all v0 v0.0.1 Nov 4, 2024 Changes in this version + type AddCapabilityRequest struct + CapabilityID string + Metadata core.Metadata + type AddDisruptionRequest struct + Disruption Disruption + Metadata core.Metadata + type CreateRequest struct + CapabilityIDs []string + LocalVolumes []LocalVolume + Name string + SystemReservedResources Resources + TotalResources Resources + UpdateDomain string + type CreateResponse struct + Record NodeRecord + type DeleteRequest struct + Metadata core.Metadata + type Disruption struct + ID string + ShouldEvict bool + StartTime time.Time + Status DisruptionStatus + type DisruptionState string + const DisruptionStateApproved + const DisruptionStateCompleted + const DisruptionStateScheduled + const DisruptionStateUnknown + type DisruptionStatus struct + Message string + State DisruptionState + type GetResponse struct + Record NodeRecord + type Ledger interface + AddCapability func(context.Context, *AddCapabilityRequest) (*UpdateResponse, error) + AddDisruption func(context.Context, *AddDisruptionRequest) (*UpdateResponse, error) + Create func(context.Context, *CreateRequest) (*CreateResponse, error) + Delete func(context.Context, *DeleteRequest) error + GetByID func(context.Context, string) (*GetResponse, error) + GetByName func(context.Context, string) (*GetResponse, error) + List func(context.Context, *ListRequest) (*ListResponse, error) + RemoveCapability func(context.Context, *RemoveCapabilityRequest) (*UpdateResponse, error) + RemoveDisruption func(context.Context, *RemoveDisruptionRequest) (*UpdateResponse, error) + UpdateDisruptionStatus func(context.Context, *UpdateDisruptionStatusRequest) (*UpdateResponse, error) + UpdateStatus func(context.Context, *UpdateStatusRequest) (*UpdateResponse, error) + func NewLedger(repo Repository) Ledger + type ListRequest struct + Filters NodeListFilters + type ListResponse struct + Records []NodeRecord + type LocalVolume struct + MountPath string + StorageCapacity uint32 + StorageClass string + type NodeListFilters struct + ClusterIDIn []string + IDIn []string + IncludeDeleted bool + Limit uint32 + NameIn []string + PayloadNameIn []string + PayloadNameNotIn []string + RemainingCoresGte *uint32 + RemainingCoresLte *uint32 + RemainingMemoryGte *uint32 + RemainingMemoryLte *uint32 + StateIn []NodeState + StateNotIn []NodeState + UpdateDomainIn []string + VersionEq *uint64 + VersionGte *uint64 + VersionLte *uint64 + type NodeRecord struct + CapabilityIDs []string + ClusterID string + Disruptions []Disruption + LocalVolumes []LocalVolume + Metadata core.Metadata + Name string + RemainingResources Resources + Status NodeStatus + SystemReservedResources Resources + TotalResources Resources + UpdateDomain string + type NodeState string + const NodeStateAllocated + const NodeStateAllocating + const NodeStateEvicted + const NodeStateSanitizing + const NodeStateUnallocated + const NodeStateUnknown + type NodeStatus struct + Message string + State NodeState + type RemoveCapabilityRequest struct + CapabilityID string + Metadata core.Metadata + type RemoveDisruptionRequest struct + DisruptionID string + Metadata core.Metadata + type Repository interface + Delete func(context.Context, core.Metadata) error + DeleteCapability func(ctx context.Context, metadata core.Metadata, capabilityID string) error + DeleteDisruption func(ctx context.Context, metadata core.Metadata, disruptionID string) error + GetByID func(context.Context, string) (NodeRecord, error) + GetByName func(context.Context, string) (NodeRecord, error) + Insert func(context.Context, NodeRecord) error + InsertCapability func(ctx context.Context, metadata core.Metadata, capabilityID string) error + InsertDisruption func(context.Context, core.Metadata, Disruption) error + List func(context.Context, NodeListFilters) ([]NodeRecord, error) + UpdateDisruptionStatus func(ctx context.Context, metadata core.Metadata, disruptionID string, ...) error + UpdateStatus func(context.Context, core.Metadata, NodeStatus, string) error + type Resources struct + Cores uint32 + Memory uint32 + type UpdateDisruptionStatusRequest struct + DisruptionID string + Metadata core.Metadata + Status DisruptionStatus + type UpdateResponse struct + Record NodeRecord + type UpdateStatusRequest struct + ClusterID string + Metadata core.Metadata + Status NodeStatus
Go to main page