cluster_conf

Documentation

Index

• type RDBClusterStorager
  • func NewRDBClusterStorager(dbCtxFactory lib.DBContextFactory, ...) *RDBClusterStorager
  • func (rm *RDBClusterStorager) BindSubCluster(ctx context.Context, cluster *icluster_conf.Cluster, ...) error
  • func (rm *RDBClusterStorager) ClusterCreate(ctx context.Context, product *ibasic.Product, ...) (int64, error)
  • func (rm *RDBClusterStorager) ClusterDelete(ctx context.Context, product *ibasic.Product, cluster *icluster_conf.Cluster) error
  • func (rm *RDBClusterStorager) ClusterUpdate(ctx context.Context, product *ibasic.Product, old *icluster_conf.Cluster, ...) error
  • func (rm *RDBClusterStorager) FetchCluster(ctx context.Context, filter *icluster_conf.ClusterFilter) (*icluster_conf.Cluster, error)
  • func (rm *RDBClusterStorager) FetchClusterList(ctx context.Context, filter *icluster_conf.ClusterFilter) ([]*icluster_conf.Cluster, error)
• type RDBPoolStorager
  • func NewRDBPoolStorager(dbCtxFactory lib.DBContextFactory, productStorager ibasic.ProductStorager) *RDBPoolStorager
  • func (rpps *RDBPoolStorager) CreatePool(ctx context.Context, product *ibasic.Product, data *icluster_conf.PoolParam) (*icluster_conf.Pool, error)
  • func (rpps *RDBPoolStorager) DeletePool(ctx context.Context, pool *icluster_conf.Pool) error
  • func (rpps *RDBPoolStorager) FetchPool(ctx context.Context, name string) (*icluster_conf.Pool, error)
  • func (rpps *RDBPoolStorager) FetchPools(ctx context.Context, filter *icluster_conf.PoolFilter) ([]*icluster_conf.Pool, error)
  • func (rpps *RDBPoolStorager) UpdatePool(ctx context.Context, oldData *icluster_conf.Pool, ...) error
• type RDBSubClusterStorager
  • func NewRDBSubClusterStorager(dbCtxFactory lib.DBContextFactory, poolStorage icluster_conf.PoolStorager, ...) *RDBSubClusterStorager
  • func (rpps *RDBSubClusterStorager) CreateSubCluster(ctx context.Context, param *icluster_conf.SubClusterParam) error
  • func (rpps *RDBSubClusterStorager) DeleteSubCluster(ctx context.Context, oldOne *icluster_conf.SubCluster) error
  • func (rpps *RDBSubClusterStorager) FetchSubClusterList(ctx context.Context, filter *icluster_conf.SubClusterFilter) ([]*icluster_conf.SubCluster, error)
  • func (rpps *RDBSubClusterStorager) UpdateSubCluster(ctx context.Context, oldOne *icluster_conf.SubCluster, ...) error

Types

type RDBClusterStorager

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

func NewRDBClusterStorager

func NewRDBClusterStorager(dbCtxFactory lib.DBContextFactory,
	subClusterStorager icluster_conf.SubClusterStorager) *RDBClusterStorager

func (*RDBClusterStorager) BindSubCluster

func (rm *RDBClusterStorager) BindSubCluster(ctx context.Context, cluster *icluster_conf.Cluster,
	appendSubClusters, unbindSubClusters []*icluster_conf.SubCluster) error

func (*RDBClusterStorager) ClusterCreate

func (rm *RDBClusterStorager) ClusterCreate(ctx context.Context, product *ibasic.Product,
	param *icluster_conf.ClusterParam, subClusters []*icluster_conf.SubCluster) (int64, error)

func (*RDBClusterStorager) ClusterDelete

func (rm *RDBClusterStorager) ClusterDelete(ctx context.Context, product *ibasic.Product, cluster *icluster_conf.Cluster) error

func (*RDBClusterStorager) ClusterUpdate

func (rm *RDBClusterStorager) ClusterUpdate(ctx context.Context, product *ibasic.Product, old *icluster_conf.Cluster,
	param *icluster_conf.ClusterParam) error

func (*RDBClusterStorager) FetchCluster

func (rm *RDBClusterStorager) FetchCluster(ctx context.Context, filter *icluster_conf.ClusterFilter) (*icluster_conf.Cluster, error)

func (*RDBClusterStorager) FetchClusterList

func (rm *RDBClusterStorager) FetchClusterList(ctx context.Context, filter *icluster_conf.ClusterFilter) ([]*icluster_conf.Cluster, error)

type RDBPoolStorager

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

func NewRDBPoolStorager

func NewRDBPoolStorager(dbCtxFactory lib.DBContextFactory,
	productStorager ibasic.ProductStorager) *RDBPoolStorager

func (*RDBPoolStorager) CreatePool

func (rpps *RDBPoolStorager) CreatePool(ctx context.Context, product *ibasic.Product,
	data *icluster_conf.PoolParam) (*icluster_conf.Pool, error)

func (*RDBPoolStorager) DeletePool

func (rpps *RDBPoolStorager) DeletePool(ctx context.Context, pool *icluster_conf.Pool) error

func (*RDBPoolStorager) FetchPool

func (rpps *RDBPoolStorager) FetchPool(ctx context.Context, name string) (*icluster_conf.Pool, error)

func (*RDBPoolStorager) FetchPools

func (rpps *RDBPoolStorager) FetchPools(ctx context.Context, filter *icluster_conf.PoolFilter) ([]*icluster_conf.Pool, error)

func (*RDBPoolStorager) UpdatePool

func (rpps *RDBPoolStorager) UpdatePool(ctx context.Context, oldData *icluster_conf.Pool,
	diff *icluster_conf.PoolParam) error

type RDBSubClusterStorager

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

func NewRDBSubClusterStorager

func NewRDBSubClusterStorager(dbCtxFactory lib.DBContextFactory, poolStorage icluster_conf.PoolStorager,
	productStorager ibasic.ProductStorager) *RDBSubClusterStorager

func (*RDBSubClusterStorager) CreateSubCluster

func (rpps *RDBSubClusterStorager) CreateSubCluster(ctx context.Context, param *icluster_conf.SubClusterParam) error

func (*RDBSubClusterStorager) DeleteSubCluster

func (rpps *RDBSubClusterStorager) DeleteSubCluster(ctx context.Context, oldOne *icluster_conf.SubCluster) error

func (*RDBSubClusterStorager) FetchSubClusterList

func (rpps *RDBSubClusterStorager) FetchSubClusterList(ctx context.Context,
	filter *icluster_conf.SubClusterFilter) ([]*icluster_conf.SubCluster, error)

func (*RDBSubClusterStorager) UpdateSubCluster

func (rpps *RDBSubClusterStorager) UpdateSubCluster(ctx context.Context, oldOne *icluster_conf.SubCluster, param *icluster_conf.SubClusterParam) error