manager

Documentation

Index

• type ManagerClient
  • func NewManagerClient(etcdCli *clientv3.Client) ManagerClient

Types

type ManagerClient

type ManagerClient interface {
	// WatchNodeChanged returns a channel that receive the signal that a streaming node change.
	WatchNodeChanged(ctx context.Context) (<-chan struct{}, error)

	// CollectAllStatus collects status of all streamingnode, such as load balance attributes.
	CollectAllStatus(ctx context.Context) (map[int64]*types.StreamingNodeStatus, error)

	// Assign a wal instance for the channel on streaming node of given server id.
	Assign(ctx context.Context, pchannel types.PChannelInfoAssigned) error

	// Remove the wal instance for the channel on streaming node of given server id.
	Remove(ctx context.Context, pchannel types.PChannelInfoAssigned) error

	// Close closes the manager client.
	// It close the underlying connection, stop the node watcher and release all resources.
	Close()
}

ManagerClient is the client to manage wal instances in all streamingnode. ManagerClient wraps the Session Service Discovery. Provides the ability to assign and remove wal instances for the channel on streaming node.

func NewManagerClient

func NewManagerClient(etcdCli *clientv3.Client) ManagerClient

NewManagerClient creates a new manager client.