Versions in this module Expand all Collapse all v10 v10.1.1 Apr 12, 2022 v10.1.0 Apr 12, 2022 v10.0.1 Apr 12, 2022 v10.0.0 Apr 12, 2022 Changes in this version + const APIBase + const APIVersion + var ErrInitNodeNotFound = errors.New(...) + var ErrNodeDecommissioned = errors.New("Node is decommissioned.") + var ErrNodeRemovePending = errors.New("Node remove is pending") + var ErrNotImplemented = errors.New("Not Implemented") + var ErrRemoveCausesDataLoss = errors.New("Cannot remove node without data loss") + type Cluster interface + AddEventListener func(ClusterListener) error + ClusterNotifyClusterDomainsUpdate func(types.ClusterDomainsActiveMap) error + ClusterNotifyNodeDown func(downNodeID string) (string, error) + Enumerate func() (api.Cluster, error) + GetGossipIntervals func() types.GossipIntervals + Inspect func(string) (api.Node, error) + SetSize func(size int) error + Shutdown func() error + Start func(nodeInitialized bool, gossipPort string, selfClusterDomain string) error + StartWithConfiguration func(nodeInitialized bool, gossipPort string, snapshotPrefixes []string, ...) error + Uuid func() string + func NewDefaultClusterManager() Cluster + type ClusterAlerts interface + EnumerateAlerts func(timeStart, timeEnd time.Time, resource api.ResourceType) (*api.Alerts, error) + EraseAlert func(resource api.ResourceType, alertID int64) error + func NewDefaultClusterAlerts() ClusterAlerts + type ClusterData interface + DisableUpdates func() error + EnableUpdates func() error + GetData func() (map[string]*api.Node, error) + GetGossipState func() *ClusterState + GetNodeIdFromIp func(idIp string) (string, error) + UpdateData func(nodeData map[string]interface{}) error + UpdateLabels func(nodeLabels map[string]string) error + UpdateSchedulerNodeName func(name string) error + func NewDefaultClusterData() ClusterData + type ClusterInfo struct + Id string + NodeEntries map[string]NodeEntry + PairToken string + Size int + Status api.Status + type ClusterInitState struct + ClusterInfo *ClusterInfo + Collector kvdb.UpdatesCollector + InitDb kvdb.Kvdb + Version uint64 + type ClusterListener interface + CleanupInit func(self *api.Node, clusterInfo *ClusterInfo) error + ClusterInit func(self *api.Node) error + Halt func(self *api.Node, clusterInfo *ClusterInfo) error + Init func(self *api.Node, state *ClusterInfo) (FinalizeInitCb, error) + Join func(self *api.Node, state *ClusterInitState) error + JoinComplete func(self *api.Node) error + PreJoin func(self *api.Node) error + String func() string + type ClusterListenerAlertOps interface + type ClusterListenerCallbacks interface + ClusterNotifyClusterDomainsUpdate func(types.ClusterDomainsActiveMap) error + ClusterNotifyNodeDown func(downNodeID string) (string, error) + type ClusterListenerGenericOps interface + Enumerate func(cluster *api.Cluster) error + ListenerData func() map[string]interface{} + QuorumMember func(node *api.Node) bool + UpdateCluster func(self *api.Node, clusterInfo *ClusterInfo) error + type ClusterListenerNodeOps interface + Add func(node *api.Node) error + CanNodeJoin func(node *api.Node, clusterInfo *ClusterInfo, nodeInitialized bool) error + CanNodeRemove func(node *api.Node) (string, error) + Leave func(node *api.Node) error + MarkNodeDown func(node *api.Node) error + MarkNodeForRemoval func(node *api.Node) + NodeInspect func(node *api.Node) error + Remove func(node *api.Node, forceRemove bool) error + Update func(node *api.Node) error + type ClusterListenerPairOps interface + CreatePair func(request *api.ClusterPairCreateRequest, ...) error + GetPairMode func() api.ClusterPairMode_Mode + ProcessPairRequest func(request *api.ClusterPairProcessRequest, ...) error + ValidatePair func(pair *api.ClusterPairInfo) error + type ClusterListenerStatusOps interface + ListenerPeerStatus func() map[string]api.Status + ListenerStatus func() api.Status + type ClusterPair interface + CreatePair func(*api.ClusterPairCreateRequest) (*api.ClusterPairCreateResponse, error) + DeletePair func(string) error + EnumeratePairs func() (*api.ClusterPairsEnumerateResponse, error) + GetPair func(string) (*api.ClusterPairGetResponse, error) + GetPairToken func(bool) (*api.ClusterPairTokenGetResponse, error) + ProcessPairRequest func(*api.ClusterPairProcessRequest) (*api.ClusterPairProcessResponse, error) + RefreshPair func(string) error + ValidatePair func(string) error + func NewDefaultCluterPair() ClusterPair + type ClusterRemove interface + NodeRemoveDone func(nodeID string, result error) error + Remove func(nodes []api.Node, forceRemove bool) error + func NewDefaultClusterRemove() ClusterRemove + type ClusterServerConfiguration struct + ConfigClusterDomainProvider clusterdomain.ClusterDomainProvider + ConfigDiagsProvider diags.Provider + ConfigJobProvider job.Provider + ConfigNodeDrainProvider nodedrain.Provider + ConfigObjectStoreManager objectstore.ObjectStore + ConfigSchedManager sched.SchedulePolicyProvider + ConfigSecretManager secrets.Secrets + ConfigStoragePoolProvider api.OpenStoragePoolServer + ConfigSystemTokenManager auth.TokenGenerator + type ClusterState struct + NodeStatus []types.NodeValue + type ClusterStatus interface + NodeStatus func() (api.Status, error) + PeerStatus func(listenerName string) (map[string]api.Status, error) + func NewDefaultClusterStatus() ClusterStatus + type FinalizeInitCb func(*ClusterInfo) error + type NodeEntry struct + ClusterDomain string + DataIp string + GenNumber uint64 + GossipPort string + HWType api.HardwareType + Hostname string + Id string + MemTotal uint64 + MgmtIp string + NodeLabels map[string]string + NonQuorumMember bool + SchedulerNodeName string + SecurityStatus api.StorageNode_SecurityStatus + StartTime time.Time + Status api.Status + type NullClusterAlerts struct + func (m *NullClusterAlerts) EnumerateAlerts(arg0, arg1 time.Time, arg2 api.ResourceType) (*api.Alerts, error) + func (m *NullClusterAlerts) EraseAlert(arg0 api.ResourceType, arg1 int64) error + type NullClusterData struct + func (c *NullClusterData) GetGossipIntervals() types.GossipIntervals + func (m *NullClusterData) DisableUpdates() error + func (m *NullClusterData) EnableUpdates() error + func (m *NullClusterData) GetData() (map[string]*api.Node, error) + func (m *NullClusterData) GetGossipState() *ClusterState + func (m *NullClusterData) GetNodeIdFromIp(arg0 string) (string, error) + func (m *NullClusterData) UpdateData(arg0 map[string]interface{}) error + func (m *NullClusterData) UpdateLabels(arg0 map[string]string) error + func (m *NullClusterData) UpdateSchedulerNodeName(arg0 string) error + type NullClusterListener struct + func (nc *NullClusterListener) Add(node *api.Node) error + func (nc *NullClusterListener) CanNodeJoin(node *api.Node, clusterInfo *ClusterInfo, nodeInitialized bool) error + func (nc *NullClusterListener) CanNodeRemove(node *api.Node) (string, error) + func (nc *NullClusterListener) CleanupInit(self *api.Node, clusterInfo *ClusterInfo) error + func (nc *NullClusterListener) ClusterInit(self *api.Node) error + func (nc *NullClusterListener) CreatePair(request *api.ClusterPairCreateRequest, ...) error + func (nc *NullClusterListener) Enumerate(_ *api.Cluster) error + func (nc *NullClusterListener) EnumerateAlerts(timeStart, timeEnd time.Time, resource api.ResourceType) (*api.Alerts, error) + func (nc *NullClusterListener) EraseAlert(resource api.ResourceType, alertID int64) error + func (nc *NullClusterListener) GetPairMode() api.ClusterPairMode_Mode + func (nc *NullClusterListener) Halt(self *api.Node, clusterInfo *ClusterInfo) error + func (nc *NullClusterListener) Init(self *api.Node, state *ClusterInfo) (FinalizeInitCb, error) + func (nc *NullClusterListener) Join(self *api.Node, state *ClusterInitState) error + func (nc *NullClusterListener) JoinComplete(self *api.Node) error + func (nc *NullClusterListener) Leave(node *api.Node) error + func (nc *NullClusterListener) ListenerData() map[string]interface{} + func (nc *NullClusterListener) ListenerPeerStatus() map[string]api.Status + func (nc *NullClusterListener) ListenerStatus() api.Status + func (nc *NullClusterListener) MarkNodeDown(node *api.Node) error + func (nc *NullClusterListener) MarkNodeForRemoval(node *api.Node) + func (nc *NullClusterListener) NodeInspect(node *api.Node) error + func (nc *NullClusterListener) PreJoin(self *api.Node) error + func (nc *NullClusterListener) ProcessPairRequest(request *api.ClusterPairProcessRequest, ...) error + func (nc *NullClusterListener) QuorumMember(node *api.Node) bool + func (nc *NullClusterListener) Remove(node *api.Node, forceRemove bool) error + func (nc *NullClusterListener) String() string + func (nc *NullClusterListener) Update(node *api.Node) error + func (nc *NullClusterListener) UpdateCluster(self *api.Node, clusterInfo *ClusterInfo) error + func (nc *NullClusterListener) ValidatePair(pair *api.ClusterPairInfo) error + type NullClusterManager struct + func (m *NullClusterManager) AddEventListener(arg0 ClusterListener) error + func (m *NullClusterManager) Enumerate() (api.Cluster, error) + func (m *NullClusterManager) Inspect(arg0 string) (api.Node, error) + func (m *NullClusterManager) SetSize(arg0 int) error + func (m *NullClusterManager) Shutdown() error + func (m *NullClusterManager) Start(arg1 bool, arg2 string, arg3 string) error + func (m *NullClusterManager) StartWithConfiguration(arg1 bool, arg2 string, arg3 []string, arg4 string, ...) error + func (n *NullClusterManager) ClusterNotifyClusterDomainsUpdate(types.ClusterDomainsActiveMap) error + func (n *NullClusterManager) ClusterNotifyNodeDown(culpritNodeId string) (string, error) + func (n *NullClusterManager) Uuid() string + type NullClusterPair struct + func (m *NullClusterPair) CreatePair(arg0 *api.ClusterPairCreateRequest) (*api.ClusterPairCreateResponse, error) + func (m *NullClusterPair) DeletePair(arg0 string) error + func (m *NullClusterPair) EnumeratePairs() (*api.ClusterPairsEnumerateResponse, error) + func (m *NullClusterPair) GetPair(arg0 string) (*api.ClusterPairGetResponse, error) + func (m *NullClusterPair) GetPairMode() api.ClusterPairMode_Mode + func (m *NullClusterPair) GetPairToken(arg0 bool) (*api.ClusterPairTokenGetResponse, error) + func (m *NullClusterPair) ProcessPairRequest(arg0 *api.ClusterPairProcessRequest) (*api.ClusterPairProcessResponse, error) + func (m *NullClusterPair) RefreshPair(arg0 string) error + func (m *NullClusterPair) ValidatePair(arg0 string) error + type NullClusterRemove struct + func (m *NullClusterRemove) NodeRemoveDone(arg0 string, arg1 error) error + func (m *NullClusterRemove) Remove(arg0 []api.Node, arg1 bool) error + type NullClusterStatus struct + func (m *NullClusterStatus) NodeStatus() (api.Status, error) + func (m *NullClusterStatus) PeerStatus(arg0 string) (map[string]api.Status, error) + type StoragePoolProvider interface Other modules containing this package github.com/libopenstorage/openstorage
Go to main page