Versions in this module Expand all Collapse all v0 v0.0.1 Nov 4, 2024 Changes in this version + func Initialize(simpleDB simplesql.Database) error + type ClusterRow struct + DeletedAt int64 + ID string + Message string + Name string + State string + Version uint64 + type ClusterTable struct + func NewClusterTable(db simplesql.Database) *ClusterTable + func (s *ClusterTable) Delete(ctx context.Context, execer sqlx.ExecerContext, id string, version uint64) error + func (s *ClusterTable) Get(ctx context.Context, keys ClusterTableKeys) (ClusterRow, error) + func (s *ClusterTable) Insert(ctx context.Context, execer sqlx.ExecerContext, row ClusterRow) error + func (s *ClusterTable) List(ctx context.Context, filters ClusterTableSelectFilters) ([]ClusterRow, error) + func (s *ClusterTable) Update(ctx context.Context, execer sqlx.ExecerContext, id string, version uint64, ...) error + type ClusterTableKeys struct + ID *string + Name *string + type ClusterTableSelectFilters struct + IDIn []string + IncludeDeleted bool + Limit uint32 + NameIn []string + StateIn []string + StateNotIn []string + VersionEq *uint64 + VersionGte *uint64 + VersionLte *uint64 + type ClusterTableUpdateFields struct + DeletedAt *int64 + Message *string + State *string + type ComputeCapabilityKeys struct + ID *string + Name *string + type ComputeCapabilityRow struct + DeletedAt int64 + ID string + Message string + Name string + Score uint32 + State string + Type string + Version uint64 + type ComputeCapabilityTable struct + func NewComputeCapabilityTable(db simplesql.Database) *ComputeCapabilityTable + func (s *ComputeCapabilityTable) Delete(ctx context.Context, execer sqlx.ExecerContext, id string, version uint64) error + func (s *ComputeCapabilityTable) Get(ctx context.Context, keys ComputeCapabilityKeys) (ComputeCapabilityRow, error) + func (s *ComputeCapabilityTable) Insert(ctx context.Context, execer sqlx.ExecerContext, row ComputeCapabilityRow) error + func (s *ComputeCapabilityTable) List(ctx context.Context, filters ComputeCapabilityTableSelectFilters) ([]ComputeCapabilityRow, error) + func (s *ComputeCapabilityTable) Update(ctx context.Context, execer sqlx.ExecerContext, id string, version uint64, ...) error + type ComputeCapabilityTableSelectFilters struct + IDIn []string + IncludeDeleted bool + Limit uint32 + NameIn []string + StateIn []string + StateNotIn []string + TypeIn []string + VersionEq *uint64 + VersionGte *uint64 + VersionLte *uint64 + type ComputeCapabilityTableUpdateFields struct + DeletedAt *int64 + Message *string + State *string + type DeploymentMatchingCapabilityTable struct + func NewDeploymentMatchingCapabilityTable(db simplesql.Database) *DeploymentMatchingCapabilityTable + func (s *DeploymentMatchingCapabilityTable) Insert(ctx context.Context, execer sqlx.ExecerContext, ...) error + func (s *DeploymentMatchingCapabilityTable) List(ctx context.Context, ...) ([]DeploymentPlanMatchingCapabilityRow, error) + type DeploymentPlanApplicationPersistentVolumeRow struct + Capacity uint32 + DeploymentPlanID string + MountPath string + PayloadName string + StorageClass string + type DeploymentPlanApplicationPersistentVolumeTable struct + func NewDeploymentPlanApplicationPersistentVolumeTable(db simplesql.Database) *DeploymentPlanApplicationPersistentVolumeTable + func (s *DeploymentPlanApplicationPersistentVolumeTable) Insert(ctx context.Context, execer sqlx.ExecerContext, ...) error + func (s *DeploymentPlanApplicationPersistentVolumeTable) List(ctx context.Context, ...) ([]DeploymentPlanApplicationPersistentVolumeRow, error) + type DeploymentPlanApplicationPersistentVolumeTableSelectFilters struct + DeploymentPlanIDIn []string + PayloadNameIn []string + type DeploymentPlanApplicationPortRow struct + DeploymentPlanID string + PayloadName string + Port uint32 + Protocol string + type DeploymentPlanApplicationPortTable struct + func NewDeploymentPlanApplicationPortTable(db simplesql.Database) *DeploymentPlanApplicationPortTable + func (s *DeploymentPlanApplicationPortTable) Insert(ctx context.Context, execer sqlx.ExecerContext, ...) error + func (s *DeploymentPlanApplicationPortTable) List(ctx context.Context, filters DeploymentPlanApplicationPortTableSelectFilters) ([]DeploymentPlanApplicationPortRow, error) + type DeploymentPlanApplicationPortTableSelectFilters struct + DeploymentPlanIDIn []string + PayloadNameIn []string + type DeploymentPlanApplicationRow struct + Cores uint32 + DeploymentPlanID string + Memory uint32 + PayloadName string + type DeploymentPlanApplicationTable struct + func NewDeploymentPlanApplicationTable(db simplesql.Database) *DeploymentPlanApplicationTable + func (s *DeploymentPlanApplicationTable) Insert(ctx context.Context, execer sqlx.ExecerContext, ...) error + func (s *DeploymentPlanApplicationTable) List(ctx context.Context, filters DeploymentPlanApplicationTableSelectFilters) ([]DeploymentPlanApplicationRow, error) + type DeploymentPlanApplicationTableSelectFilters struct + DeploymentPlanIDIn []string + PayloadNameIn []string + type DeploymentPlanDeploymentPayloadCoordinatesRow struct + Coordinates string + DeploymentID string + DeploymentPlanID string + PayloadName string + type DeploymentPlanDeploymentPayloadCoordinatesTable struct + func NewDeploymentPlanDeploymentPayloadCoordinatesTable(db simplesql.Database) *DeploymentPlanDeploymentPayloadCoordinatesTable + func (s *DeploymentPlanDeploymentPayloadCoordinatesTable) Insert(ctx context.Context, execer sqlx.ExecerContext, ...) error + func (s *DeploymentPlanDeploymentPayloadCoordinatesTable) List(ctx context.Context, ...) ([]DeploymentPlanDeploymentPayloadCoordinatesRow, error) + type DeploymentPlanDeploymentPayloadCoordinatesTableSelectFilters struct + DeploymentIDIn []string + DeploymentPlanIDIn []string + type DeploymentPlanDeploymentRow struct + DeploymentPlanID string + ID string + InstanceCount uint32 + Message string + State string + type DeploymentPlanDeploymentTable struct + func NewDeploymentPlanDeploymentTable(db simplesql.Database) *DeploymentPlanDeploymentTable + func (s *DeploymentPlanDeploymentTable) Insert(ctx context.Context, execer sqlx.ExecerContext, ...) error + func (s *DeploymentPlanDeploymentTable) List(ctx context.Context, filters DeploymentPlanDeploymentTableSelectFilters) ([]DeploymentPlanDeploymentRow, error) + func (s *DeploymentPlanDeploymentTable) Update(ctx context.Context, execer sqlx.ExecerContext, deploymentID string, ...) error + type DeploymentPlanDeploymentTableSelectFilters struct + DeploymentPlanIDIn []string + IDIn []string + StateIn []string + StateNotIn []string + type DeploymentPlanDeploymentTableUpdateFields struct + Message *string + State *string + type DeploymentPlanKeys struct + ID *string + Name *string + type DeploymentPlanMatchingCapabilityRow struct + CapabilityNames string + CapabilityType string + Comparator string + DeploymentPlanID string + type DeploymentPlanMatchingCapabilityTableSelectFilters struct + DeploymentPlanIDIn []string + type DeploymentPlanRow struct + DeletedAt int64 + ID string + Message string + Name string + Namespace string + ServiceName string + State string + Version uint64 + type DeploymentPlanTable struct + func NewDeploymentPlanTable(db simplesql.Database) *DeploymentPlanTable + func (s *DeploymentPlanTable) Delete(ctx context.Context, execer sqlx.ExecerContext, id string, version uint64) error + func (s *DeploymentPlanTable) Get(ctx context.Context, keys DeploymentPlanKeys) (DeploymentPlanRow, error) + func (s *DeploymentPlanTable) Insert(ctx context.Context, execer sqlx.ExecerContext, row DeploymentPlanRow) error + func (s *DeploymentPlanTable) List(ctx context.Context, filters DeploymentPlanTableSelectFilters) ([]DeploymentPlanRow, error) + func (s *DeploymentPlanTable) Update(ctx context.Context, execer sqlx.ExecerContext, id string, version uint64, ...) error + type DeploymentPlanTableSelectFilters struct + IDIn []string + IncludeDeleted bool + Limit uint32 + NameIn []string + NamespaceIn []string + ServiceNameIn []string + StateIn []string + StateNotIn []string + VersionEq *uint64 + VersionGte *uint64 + VersionLte *uint64 + type DeploymentPlanTableUpdateFields struct + DeletedAt *int64 + Message *string + State *string + type MetaInstanceKeys struct + ID *string + Name *string + type MetaInstanceOperationRow struct + ID string + IntentID string + Message string + MetaInstanceID string + State string + Type string + type MetaInstanceOperationTable struct + func NewMetaInstanceOperationTable(db simplesql.Database) *MetaInstanceOperationTable + func (s *MetaInstanceOperationTable) Delete(ctx context.Context, execer sqlx.ExecerContext, operationID string, ...) error + func (s *MetaInstanceOperationTable) Insert(ctx context.Context, execer sqlx.ExecerContext, row MetaInstanceOperationRow) error + func (s *MetaInstanceOperationTable) List(ctx context.Context, filters MetaInstanceOperationTableSelectFilters) ([]MetaInstanceOperationRow, error) + func (s *MetaInstanceOperationTable) Update(ctx context.Context, execer sqlx.ExecerContext, operationID string, ...) error + type MetaInstanceOperationTableSelectFilters struct + IDIn []string + MetaInstanceIDIn []string + StateIn []string + StateNotIn []string + type MetaInstanceOperationTableUpdateFields struct + Message *string + State *string + type MetaInstanceRow struct + DeletedAt int64 + DeploymentID string + DeploymentPlanID string + ID string + Message string + Name string + State string + Version uint64 + type MetaInstanceRuntimeInstanceRow struct + ID string + IsActive bool + Message string + MetaInstanceID string + NodeID string + State string + type MetaInstanceRuntimeInstanceTable struct + func NewMetaInstanceRuntimeInstanceTable(db simplesql.Database) *MetaInstanceRuntimeInstanceTable + func (s *MetaInstanceRuntimeInstanceTable) Delete(ctx context.Context, execer sqlx.ExecerContext, runtimeInstanceID string, ...) error + func (s *MetaInstanceRuntimeInstanceTable) Insert(ctx context.Context, execer sqlx.ExecerContext, ...) error + func (s *MetaInstanceRuntimeInstanceTable) List(ctx context.Context, filters MetaInstanceRuntimeInstanceTableSelectFilters) ([]MetaInstanceRuntimeInstanceRow, error) + func (s *MetaInstanceRuntimeInstanceTable) Update(ctx context.Context, execer sqlx.ExecerContext, runtimeInstanceID string, ...) error + type MetaInstanceRuntimeInstanceTableSelectFilters struct + IDIn []string + IsActive *bool + MetaInstanceIDIn []string + NodeIDIn []string + StateIn []string + StateNotIn []string + type MetaInstanceRuntimeInstanceTableUpdateFields struct + IsActive *bool + Message *string + State *string + type MetaInstanceTable struct + func NewMetaInstanceTable(db simplesql.Database) *MetaInstanceTable + func (s *MetaInstanceTable) Delete(ctx context.Context, execer sqlx.ExecerContext, id string, version uint64) error + func (s *MetaInstanceTable) Get(ctx context.Context, keys MetaInstanceKeys) (MetaInstanceRow, error) + func (s *MetaInstanceTable) Insert(ctx context.Context, execer sqlx.ExecerContext, row MetaInstanceRow) error + func (s *MetaInstanceTable) List(ctx context.Context, filters MetaInstanceTableSelectFilters) ([]MetaInstanceRow, error) + func (s *MetaInstanceTable) Update(ctx context.Context, execer sqlx.ExecerContext, id string, version uint64, ...) error + type MetaInstanceTableSelectFilters struct + DeploymentIDIn []string + DeploymentPlanIDIn []string + IDIn []string + IncludeDeleted bool + Limit uint32 + NameIn []string + StateIn []string + StateNotIn []string + VersionEq *uint64 + VersionGte *uint64 + VersionLte *uint64 + type MetaInstanceTableUpdateFields struct + DeletedAt *int64 + DeploymentID *string + Message *string + State *string + type NodeCapabilityRow struct + CapabilityID string + NodeID string + type NodeCapabilityTable struct + func NewNodeCapabilityTable(db simplesql.Database) *NodeCapabilityTable + func (s *NodeCapabilityTable) Delete(ctx context.Context, execer sqlx.ExecerContext, nodeID string, ...) error + func (s *NodeCapabilityTable) Insert(ctx context.Context, execer sqlx.ExecerContext, row NodeCapabilityRow) error + func (s *NodeCapabilityTable) List(ctx context.Context, filters NodeCapabilityTableSelectFilters) ([]NodeCapabilityRow, error) + type NodeCapabilityTableSelectFilters struct + CapabilityIDIn []string + NodeIDIn []string + type NodeDisruptionRow struct + EvictNode bool + ID string + Message string + NodeID string + StartTime uint64 + State string + type NodeDisruptionTable struct + func NewNodeDisruptionTable(db simplesql.Database) *NodeDisruptionTable + func (s *NodeDisruptionTable) Delete(ctx context.Context, execer sqlx.ExecerContext, nodeID string, id string) error + func (s *NodeDisruptionTable) Insert(ctx context.Context, execer sqlx.ExecerContext, row NodeDisruptionRow) error + func (s *NodeDisruptionTable) List(ctx context.Context, filters NodeDisruptionTableSelectFilters) ([]NodeDisruptionRow, error) + func (s *NodeDisruptionTable) Update(ctx context.Context, execer sqlx.ExecerContext, nodeID string, id string, ...) error + type NodeDisruptionTableSelectFilters struct + DisruptionIDIn []string + NodeIDIn []string + StartTimeGte *uint64 + StartTimeLte *uint64 + StateIn []string + StateNotIn []string + type NodeDisruptionTableUpdateFields struct + Message *string + State *string + type NodeKeys struct + ID *string + Name *string + type NodeLocalVolumeRow struct + MountPath string + NodeID string + StorageCapacity uint32 + StorageClass string + type NodeLocalVolumeTable struct + func NewNodeLocalVolumeTable(db simplesql.Database) *NodeLocalVolumeTable + func (s *NodeLocalVolumeTable) Delete(ctx context.Context, execer sqlx.ExecerContext, nodeID string) error + func (s *NodeLocalVolumeTable) Insert(ctx context.Context, execer sqlx.ExecerContext, row NodeLocalVolumeRow) error + func (s *NodeLocalVolumeTable) List(ctx context.Context, filters NodeLocalVolumeTableSelectFilters) ([]NodeLocalVolumeRow, error) + type NodeLocalVolumeTableSelectFilters struct + NodeIDIn []string + StorageClassIn []string + type NodePayloadRow struct + NodeID string + PayloadName string + type NodePayloadTable struct + func NewNodePayloadTable(db simplesql.Database) *NodePayloadTable + func (s *NodePayloadTable) Delete(ctx context.Context, execer sqlx.ExecerContext, nodeID string, ...) error + func (s *NodePayloadTable) Insert(ctx context.Context, execer sqlx.ExecerContext, row NodePayloadRow) error + func (s *NodePayloadTable) List(ctx context.Context, filters NodePayloadTableSelectFilters) ([]NodePayloadRow, error) + type NodePayloadTableSelectFilters struct + NodeIDIn []string + PayloadNameIn []string + PayloadNameNotIn []string + type NodeRow struct + ClusterID string + DeletedAt int64 + ID string + Message string + Name string + RemainingCores uint32 + RemainingMemory uint32 + State string + SystemReservedCores uint32 + SystemReservedMemory uint32 + TotalCores uint32 + TotalMemory uint32 + UpdateDomain string + Version uint64 + type NodeSelectFilters struct + ClusterIDIn []string + ClusterIDNotIn []string + IDIn []string + IncludeDeleted bool + Limit uint32 + NameIn []string + PayloadNameIn []string + PayloadNameNotIn []string + RemainingCoresGte *uint32 + RemainingCoresLte *uint32 + RemainingMemoryGte *uint32 + RemainingMemoryLte *uint32 + StateIn []string + StateNotIn []string + UpdateDomainIn []string + VersionEq *uint64 + VersionGte *uint64 + VersionLte *uint64 + type NodeTable struct + func NewNodeTable(db simplesql.Database) *NodeTable + func (s *NodeTable) Delete(ctx context.Context, execer sqlx.ExecerContext, id string, version uint64) error + func (s *NodeTable) Get(ctx context.Context, keys NodeKeys) (NodeRow, error) + func (s *NodeTable) Insert(ctx context.Context, execer sqlx.ExecerContext, row NodeRow) error + func (s *NodeTable) List(ctx context.Context, filters NodeSelectFilters) ([]NodeRow, error) + func (s *NodeTable) Update(ctx context.Context, execer sqlx.ExecerContext, id string, version uint64, ...) error + type NodeUpdateFields struct + ClusterID *string + DeletedAt *int64 + Message *string + RemainingCores *uint32 + RemainingMemory *uint32 + State *string