Documentation
¶
Index ¶
- Constants
- type BaseCluster
- func (b *BaseCluster) AddHook(hook Hook, handler func())
- func (b *BaseCluster) AddInstance(instance *registry.ServiceInstance)
- func (b *BaseCluster) Cancel()
- func (b *BaseCluster) ClearInstances()
- func (b *BaseCluster) CompareAndSwapState(old, new State) bool
- func (b *BaseCluster) Context() context.Context
- func (b *BaseCluster) DeregisterInstances()
- func (b *BaseCluster) GetState() State
- func (b *BaseCluster) InitBase(ctx context.Context, cancel context.CancelFunc, reg registry.Registry, ...)
- func (b *BaseCluster) RefreshInstances()
- func (b *BaseCluster) RegisterInstances() error
- func (b *BaseCluster) RunHooks(hook Hook)
- func (b *BaseCluster) SetState(state State)
- func (b *BaseCluster) TryClose() bool
- func (b *BaseCluster) TryDestroy() bool
- func (b *BaseCluster) TryStart() bool
- type BroadcastArgs
- type DeliverArgs
- type DisconnectArgs
- type Dispatch
- type Event
- type GetIPArgs
- type Hook
- type IsOnlineArgs
- type Kind
- type Message
- type MulticastArgs
- type PublishArgs
- type PushArgs
- type State
- type SubscribeArgs
- type TriggerArgs
- type UnsubscribeArgs
Constants ¶
View Source
const ( // DefaultRegistryTimeout 默认注册/注销超时时间 DefaultRegistryTimeout = 3 * time.Second )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseCluster ¶ added in v1.0.10
type BaseCluster struct {
// contains filtered or unexported fields
}
BaseCluster 集群组件公共基类 提取 Gate/Node/Mesh 共享的状态管理、服务注册/注销、钩子函数等逻辑
func (*BaseCluster) AddHook ¶ added in v1.0.10
func (b *BaseCluster) AddHook(hook Hook, handler func())
AddHook 添加钩子监听器(线程安全)
func (*BaseCluster) AddInstance ¶ added in v1.0.10
func (b *BaseCluster) AddInstance(instance *registry.ServiceInstance)
AddInstance 添加服务实例
func (*BaseCluster) ClearInstances ¶ added in v1.0.10
func (b *BaseCluster) ClearInstances()
ClearInstances 清空服务实例列表(用于 Start 前重置,如 Gate/Mesh 单实例场景)
func (*BaseCluster) CompareAndSwapState ¶ added in v1.0.10
func (b *BaseCluster) CompareAndSwapState(old, new State) bool
CompareAndSwapState CAS 设置状态
func (*BaseCluster) Context ¶ added in v1.0.10
func (b *BaseCluster) Context() context.Context
Context 获取上下文
func (*BaseCluster) DeregisterInstances ¶ added in v1.0.10
func (b *BaseCluster) DeregisterInstances()
DeregisterInstances 解注册所有服务实例
func (*BaseCluster) GetState ¶ added in v1.0.10
func (b *BaseCluster) GetState() State
GetState 获取状态
func (*BaseCluster) InitBase ¶ added in v1.0.10
func (b *BaseCluster) InitBase(ctx context.Context, cancel context.CancelFunc, reg registry.Registry, timeout time.Duration)
InitBase 初始化基类
func (*BaseCluster) RefreshInstances ¶ added in v1.0.10
func (b *BaseCluster) RefreshInstances()
RefreshInstances 刷新所有服务实例状态
func (*BaseCluster) RegisterInstances ¶ added in v1.0.10
func (b *BaseCluster) RegisterInstances() error
RegisterInstances 注册所有服务实例
func (*BaseCluster) RunHooks ¶ added in v1.0.10
func (b *BaseCluster) RunHooks(hook Hook)
RunHooks 执行钩子函数
func (*BaseCluster) SetState ¶ added in v1.0.10
func (b *BaseCluster) SetState(state State)
SetState 设置状态
func (*BaseCluster) TryClose ¶ added in v1.0.10
func (b *BaseCluster) TryClose() bool
TryClose 尝试切换到 Hang(关闭)
func (*BaseCluster) TryDestroy ¶ added in v1.0.10
func (b *BaseCluster) TryDestroy() bool
TryDestroy 尝试从 Hang 切换到 Shut(销毁)
func (*BaseCluster) TryStart ¶ added in v1.0.10
func (b *BaseCluster) TryStart() bool
TryStart 尝试从 Shut 切换到 Work(启动)
type BroadcastArgs ¶
type DeliverArgs ¶
type DisconnectArgs ¶
type IsOnlineArgs ¶
type MulticastArgs ¶
type PublishArgs ¶
type SubscribeArgs ¶
type TriggerArgs ¶
Click to show internal directories.
Click to hide internal directories.