cluster

package

v0.5.0 Latest Latest Go to latest Published: Nov 6, 2025 License: PostgreSQL Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func Provide(i *do.Injector)

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

func NewClusterStore(client *clientv3.Client, root string) *ClusterStore

func (s *ClusterStore) Create(item *StoredCluster) storage.PutOp[*StoredCluster]

func (s *ClusterStore) Get() storage.GetOp[*StoredCluster]

func (s *ClusterStore) Key() string

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

func NewService(store *Store) *Service

func (s *Service) Get(ctx context.Context) (*StoredCluster, error)

type Store struct {
	Cluster *ClusterStore
	// contains filtered or unexported fields
}

func NewStore(client *clientv3.Client, root string) *Store

func (s *Store) Txn(ops ...storage.TxnOperation) storage.Txn

type StoredCluster struct {
	storage.StoredValue
	ID string `json:"id"`
}