cluster

type ClusterListFilters struct {
	IDIn       []string // IN condition
	NameIn     []string // IN condition
	VersionGte *uint64  // Greater than or equal condition
	VersionLte *uint64  // Less than or equal condition
	VersionEq  *uint64  // Equal condition

	IncludeDeleted bool   // IncludeDeleted indicates whether to include soft-deleted records in the result.
	Limit          uint32 // Limit is the maximum number of records to return.

	StateIn    []ClusterState
	StateNotIn []ClusterState
}

type ClusterRecord struct {
	Metadata core.Metadata // Metadata is the metadata that identifies the Cluster. It is a combination of the Cluster's name and version.
	Name     string        // Name is the name of the Cluster.
	Status   ClusterStatus // Status is the status of the Cluster.
}

type ClusterState string

type ClusterStatus struct {
	State   ClusterState // State is the discrete condition of the resource.
	Message string       // Message is a human-readable description of the resource's state.
}

type CreateRequest struct {
	Name string
}

type CreateResponse struct {
	Record ClusterRecord
}

type DeleteRequest struct {
	Metadata core.Metadata
}

type GetResponse struct {
	Record ClusterRecord
}

type Ledger interface {
	// Create creates a new Cluster.
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	// GetByID retrieves a Cluster by its ID.
	GetByID(context.Context, string) (*GetResponse, error)
	// GetByName retrieves a Cluster by its name.
	GetByName(context.Context, string) (*GetResponse, error)
	// UpdateStatus updates the state and message of an existing Cluster.
	UpdateStatus(context.Context, *UpdateStateRequest) (*UpdateResponse, error)
	// List returns a list of Cluster that match the provided filters.
	List(context.Context, *ListRequest) (*ListResponse, error)
	// Delete deletes a Cluster.
	Delete(context.Context, *DeleteRequest) error
}

type ListRequest struct {
	Filters ClusterListFilters
}

type ListResponse struct {
	Records []ClusterRecord
}

type Repository interface {
	Insert(context.Context, ClusterRecord) error
	GetByID(context.Context, string) (ClusterRecord, error)
	GetByName(context.Context, string) (ClusterRecord, error)
	UpdateStatus(context.Context, core.Metadata, ClusterStatus) error
	Delete(context.Context, core.Metadata) error
	List(context.Context, ClusterListFilters) ([]ClusterRecord, error)
}

type UpdateResponse struct {
	Record ClusterRecord
}

type UpdateStateRequest struct {
	Metadata core.Metadata
	Status   ClusterStatus
}