manager_clusters

Documentation

Index

• Constants
• type ClustersManager
  • func NewClustersManager(ctx context.Context, d ClustersRecorder, user, userToken string) *ClustersManager
  • func (r *ClustersManager) BindNewResources(slaveGuid, slaveLevel, masterGuid string, slaveTypes int) error
  • func (r *ClustersManager) DeleteCluster(clusterGuid string) error
  • func (r *ClustersManager) ExistCluster(clusterGuid string) bool
  • func (r *ClustersManager) GetCluster(guid string) *clusters.Cluster
  • func (r *ClustersManager) GetRelationshipGraph(clusterGuid string) *clusters.Cluster
  • func (r *ClustersManager) GetStatisticClusterInfo(clusterGuid string) *clusters.Cluster
  • func (r *ClustersManager) ListCluster() map[string]*clusters.Cluster
  • func (r *ClustersManager) NewCluster(s *strategies.Strategy) error
• type ClustersRecorder

Constants

const (
	SlaveTypeDevices                = "devices"
	SlaveTypeServices               = "services"
	ClustersSavePathPrefixFormat    = "/spongeregister/superbahnManager/clusters/%v/"
	ClustersResSavePathPrefixFormat = "/spongeregister/superbahnManager/clustersRes/%v/"
)

Types

type ClustersManager

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

func NewClustersManager

func NewClustersManager(ctx context.Context, d ClustersRecorder, user, userToken string) *ClustersManager

func (*ClustersManager) BindNewResources

func (r *ClustersManager) BindNewResources(slaveGuid, slaveLevel, masterGuid string, slaveTypes int) error

func (*ClustersManager) DeleteCluster

func (r *ClustersManager) DeleteCluster(clusterGuid string) error

func (*ClustersManager) ExistCluster

func (r *ClustersManager) ExistCluster(clusterGuid string) bool

func (*ClustersManager) GetCluster

func (r *ClustersManager) GetCluster(guid string) *clusters.Cluster

func (*ClustersManager) GetRelationshipGraph

func (r *ClustersManager) GetRelationshipGraph(clusterGuid string) *clusters.Cluster

func (*ClustersManager) GetStatisticClusterInfo

func (r *ClustersManager) GetStatisticClusterInfo(clusterGuid string) *clusters.Cluster

func (*ClustersManager) ListCluster

func (r *ClustersManager) ListCluster() map[string]*clusters.Cluster

func (*ClustersManager) NewCluster

func (r *ClustersManager) NewCluster(s *strategies.Strategy) error

type ClustersRecorder

type ClustersRecorder interface {
	Put(string, string) error
	Get(string) ([]byte, error)
	GetWithPrefix(string) (map[string][]byte, error)
	Del(string) error
}