Documentation ¶
Index ¶
- func NewZkHelixAdmin(zkSvr string, options ...zkclient.Option) helix.HelixAdmin
- type Admin
- func (adm *Admin) AddCluster(cluster string) error
- func (adm *Admin) AddClusterToGrandCluster(cluster, grandCluster string) (err error)
- func (adm *Admin) AddConstaint()
- func (adm *Admin) AddInstance(cluster string, config *model.InstanceConfig) error
- func (adm *Admin) AddInstanceTag(cluster, instance, tag string) error
- func (adm *Admin) AddNode(cluster string, node string) error
- func (adm *Admin) AddResource(cluster string, resource string, option helix.AddResourceOption) error
- func (adm *Admin) AddStateModelDef(cluster string, stateModel string, definition *model.StateModelDef) error
- func (adm *Admin) AllowParticipantAutoJoin(cluster string, yes bool) error
- func (adm *Admin) Clusters() ([]string, error)
- func (adm *Admin) Connect() error
- func (adm *Admin) Constraints()
- func (adm *Admin) ControllerHistory(cluster string) ([]string, error)
- func (adm *Admin) ControllerLeader(cluster string) string
- func (adm *Admin) Disconnect()
- func (adm *Admin) DropCluster(cluster string) error
- func (adm *Admin) DropConfig(scope helix.HelixConfigScope, keys []string, ident ...string) error
- func (adm *Admin) DropInstance(cluster string, ic *model.InstanceConfig) error
- func (adm *Admin) DropNode(cluster string, node string) error
- func (adm *Admin) DropResource(cluster string, resource string) error
- func (adm *Admin) EnableCluster(cluster string, yes bool) error
- func (adm *Admin) EnableInstance(cluster, instanceName string, yes bool) error
- func (adm *Admin) EnablePartitions(cluster, resource string, partitions []string, yes bool) error
- func (adm *Admin) EnableResource(cluster string, resource string, enabled bool) error
- func (adm *Admin) GetConfig(cluster string, scope helix.HelixConfigScope, keys []string, ident ...string) (map[string]interface{}, error)
- func (conn Admin) GetRecord(path string) (*model.Record, error)
- func (adm *Admin) InstanceConfig(cluster, instance string) (*model.InstanceConfig, error)
- func (adm *Admin) Instances(cluster string) ([]string, error)
- func (adm *Admin) InstancesWithTag(cluster, tag string) ([]string, error)
- func (conn Admin) IsClusterSetup(cluster string) (bool, error)
- func (conn Admin) IsInstanceSetup(cluster, node string) (bool, error)
- func (adm *Admin) LiveInstances(cluster string) ([]string, error)
- func (adm *Admin) Rebalance(cluster string, resource string, replica int) error
- func (adm *Admin) RemoveConstaint()
- func (adm *Admin) RemoveInstanceTag(cluster, instance, tag string) error
- func (conn Admin) RemoveMapFieldKey(path string, key string) error
- func (adm *Admin) ResourceExternalView(cluster string, resource string) (*model.ExternalView, error)
- func (adm *Admin) ResourceIdealState(cluster, resource string) (*model.IdealState, error)
- func (adm *Admin) Resources(cluster string) ([]string, error)
- func (adm *Admin) ResourcesWithTag(cluster, tag string) ([]string, error)
- func (adm *Admin) ScaleResource(cluster string, resource string, partitions int) error
- func (adm *Admin) SetConfig(cluster string, scope helix.HelixConfigScope, properties map[string]string, ...) error
- func (adm *Admin) SetInstallPath(path string)
- func (adm *Admin) SetResourceIdealState(cluster, resource string, is *model.IdealState) error
- func (adm *Admin) StateModelDef(cluster, stateModel string) (*model.StateModelDef, error)
- func (adm *Admin) StateModelDefs(cluster string) ([]string, error)
- func (conn Admin) UpdateMapField(path string, key string, property string, value string) error
- func (conn Admin) UpdateSimpleField(path string, key string, value string) error
- type CallbackHandler
- func (cb *CallbackHandler) HandleChildChange(parentPath string, lastChilds []string) error
- func (cb *CallbackHandler) HandleDataChange(dataPath string, data []byte) error
- func (cb *CallbackHandler) HandleDataDeleted(dataPath string) error
- func (cb *CallbackHandler) Init()
- func (cb *CallbackHandler) Reset()
- func (cb *CallbackHandler) String() string
- type Manager
- func NewZkDistributedController(clusterID, host, port, zkSvr string, options ...ManagerOption) (mgr *Manager, err error)
- func NewZkParticipant(clusterID, host, port, zkSvr string, options ...ManagerOption) (mgr *Manager, err error)
- func NewZkSpectator(clusterID, host, port, zkSvr string, options ...ManagerOption) (mgr *Manager, err error)
- func NewZkStandaloneController(clusterID, host, port, zkSvr string, options ...ManagerOption) (mgr *Manager, err error)
- func (m *Manager) AddControllerListener(listener helix.ControllerChangeListener) error
- func (m *Manager) AddControllerMessageListener(listener helix.MessageListener) error
- func (m *Manager) AddCurrentStateChangeListener(instance string, sessionID string, listener helix.CurrentStateChangeListener) error
- func (m *Manager) AddExternalViewChangeListener(listener helix.ExternalViewChangeListener) error
- func (m *Manager) AddIdealStateChangeListener(listener helix.IdealStateChangeListener) error
- func (m *Manager) AddInstanceConfigChangeListener(listener helix.InstanceConfigChangeListener) error
- func (m *Manager) AddLiveInstanceChangeListener(listener helix.LiveInstanceChangeListener) error
- func (m *Manager) AddMessageListener(instance string, listener helix.MessageListener) error
- func (m *Manager) AddPostConnectCallback(cb helix.PostConnectCallback)
- func (m *Manager) AddPreConnectCallback(cb helix.PreConnectCallback)
- func (m *Manager) Cluster() string
- func (m *Manager) ClusterManagementTool() helix.HelixAdmin
- func (m *Manager) Connect() error
- func (m *Manager) Disconnect()
- func (m *Manager) HandleNewSession() (err error)
- func (m *Manager) HandleStateChanged(state zk.State) (err error)
- func (m *Manager) Instance() string
- func (m *Manager) InstanceType() helix.InstanceType
- func (m *Manager) IsConnected() bool
- func (m *Manager) IsLeader() bool
- func (m *Manager) MessagingService() helix.ClusterMessagingService
- func (m *Manager) PropertyStore()
- func (m *Manager) RemoveListener(path string, listener interface{}) error
- func (m *Manager) SessionID() string
- func (m *Manager) StateMachineEngine() helix.StateMachineEngine
- func (m *Manager) Valid() bool
- type ManagerOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewZkHelixAdmin ¶
NewZkHelixAdmin creates a HelixAdmin implementation with zk as storage.
Types ¶
type Admin ¶
func (*Admin) AddCluster ¶
func (*Admin) AddClusterToGrandCluster ¶
func (*Admin) AddConstaint ¶
func (adm *Admin) AddConstaint()
func (*Admin) AddInstance ¶
func (adm *Admin) AddInstance(cluster string, config *model.InstanceConfig) error
func (*Admin) AddInstanceTag ¶
func (*Admin) AddNode ¶
AddNode is the internal implementation corresponding to command ./helix-admin.sh --zkSvr <ZookeeperServerAddress> --addNode <clusterName instanceId> node is in the form of host_port
func (*Admin) AddResource ¶
func (*Admin) AddStateModelDef ¶
func (*Admin) AllowParticipantAutoJoin ¶
func (*Admin) Constraints ¶
func (adm *Admin) Constraints()
func (*Admin) ControllerHistory ¶
func (*Admin) ControllerLeader ¶
func (*Admin) Disconnect ¶
func (adm *Admin) Disconnect()
func (*Admin) DropCluster ¶
func (*Admin) DropConfig ¶
func (*Admin) DropInstance ¶
func (adm *Admin) DropInstance(cluster string, ic *model.InstanceConfig) error
func (*Admin) DropNode ¶
DropNode removes a node from a cluster. The corresponding znodes in zookeeper will be removed.
func (*Admin) EnableInstance ¶
TODO
func (*Admin) EnablePartitions ¶
func (*Admin) EnableResource ¶
func (*Admin) InstanceConfig ¶
func (adm *Admin) InstanceConfig(cluster, instance string) (*model.InstanceConfig, error)
func (*Admin) InstancesWithTag ¶
func (Admin) IsClusterSetup ¶
func (Admin) IsInstanceSetup ¶
func (*Admin) RemoveConstaint ¶
func (adm *Admin) RemoveConstaint()
func (*Admin) RemoveInstanceTag ¶
func (Admin) RemoveMapFieldKey ¶
func (*Admin) ResourceExternalView ¶
func (*Admin) ResourceIdealState ¶
func (adm *Admin) ResourceIdealState(cluster, resource string) (*model.IdealState, error)
func (*Admin) ResourcesWithTag ¶
func (*Admin) ScaleResource ¶
func (*Admin) SetInstallPath ¶
func (*Admin) SetResourceIdealState ¶
func (adm *Admin) SetResourceIdealState(cluster, resource string, is *model.IdealState) error
func (*Admin) StateModelDef ¶
func (adm *Admin) StateModelDef(cluster, stateModel string) (*model.StateModelDef, error)
func (Admin) UpdateMapField ¶
update a map field for the znode. path is the znode path. key is the top-level key in the MapFields, mapProperty is the inner key, and value is the. For example:
mapFields":{
"eat1-app993.stg.linkedin.com_11932,BizProfile,p31_1,SLAVE":{ "CURRENT_STATE":"ONLINE" ,"INFO":"" }
if we want to set the CURRENT_STATE to ONLINE, we call UpdateMapField("/RELAY/INSTANCES/{instance}/CURRENT_STATE/{sessionID}/{db}", "eat1-app993.stg.linkedin.com_11932,BizProfile,p31_1,SLAVE", "CURRENT_STATE", "ONLINE")
type CallbackHandler ¶
type CallbackHandler struct { *Manager // contains filtered or unexported fields }
func (*CallbackHandler) HandleChildChange ¶
func (cb *CallbackHandler) HandleChildChange(parentPath string, lastChilds []string) error
func (*CallbackHandler) HandleDataChange ¶
func (cb *CallbackHandler) HandleDataChange(dataPath string, data []byte) error
func (*CallbackHandler) HandleDataDeleted ¶
func (cb *CallbackHandler) HandleDataDeleted(dataPath string) error
func (*CallbackHandler) Init ¶
func (cb *CallbackHandler) Init()
func (*CallbackHandler) Reset ¶
func (cb *CallbackHandler) Reset()
func (*CallbackHandler) String ¶
func (cb *CallbackHandler) String() string
type Manager ¶
func NewZkDistributedController ¶
func NewZkDistributedController(clusterID, host, port, zkSvr string, options ...ManagerOption) (mgr *Manager, err error)
NewZkDistributedController creates a Distributed Controller implementation with zk as storage.
func NewZkParticipant ¶
func NewZkParticipant(clusterID, host, port, zkSvr string, options ...ManagerOption) (mgr *Manager, err error)
NewZkParticipant creates a Participant implementation with zk as storage.
func NewZkSpectator ¶
func NewZkSpectator(clusterID, host, port, zkSvr string, options ...ManagerOption) (mgr *Manager, err error)
NewZkSpectator creates a Spectator implementation with zk as storage.
func NewZkStandaloneController ¶
func NewZkStandaloneController(clusterID, host, port, zkSvr string, options ...ManagerOption) (mgr *Manager, err error)
NewZkStandaloneController creates a Standalone Controller implementation with zk as storage.
func (*Manager) AddControllerListener ¶
func (*Manager) AddControllerMessageListener ¶
func (*Manager) AddCurrentStateChangeListener ¶
func (*Manager) AddExternalViewChangeListener ¶
func (*Manager) AddIdealStateChangeListener ¶
func (*Manager) AddInstanceConfigChangeListener ¶
func (*Manager) AddLiveInstanceChangeListener ¶
func (*Manager) AddMessageListener ¶
func (*Manager) AddPostConnectCallback ¶
func (m *Manager) AddPostConnectCallback(cb helix.PostConnectCallback)
func (*Manager) AddPreConnectCallback ¶
func (m *Manager) AddPreConnectCallback(cb helix.PreConnectCallback)
func (*Manager) ClusterManagementTool ¶
func (m *Manager) ClusterManagementTool() helix.HelixAdmin
func (*Manager) Disconnect ¶
func (m *Manager) Disconnect()
func (*Manager) HandleNewSession ¶
func (*Manager) HandleStateChanged ¶
func (*Manager) InstanceType ¶
func (m *Manager) InstanceType() helix.InstanceType
func (*Manager) IsConnected ¶
func (*Manager) MessagingService ¶
func (m *Manager) MessagingService() helix.ClusterMessagingService
func (*Manager) PropertyStore ¶
func (m *Manager) PropertyStore()
func (*Manager) RemoveListener ¶
func (*Manager) StateMachineEngine ¶
func (m *Manager) StateMachineEngine() helix.StateMachineEngine
type ManagerOption ¶
type ManagerOption func(*Manager)
func WithParticipantID ¶
func WithParticipantID(id string) ManagerOption
func WithPprofPort ¶
func WithPprofPort(port int) ManagerOption
func WithZkSessionTimeout ¶
func WithZkSessionTimeout(d time.Duration) ManagerOption
func WithoutPprof ¶
func WithoutPprof() ManagerOption