Struct channelManager

replica/channel_manager.go:56–63

channelManager implements ChannelManager.

	}

	channelManager struct {
		ctx              context.Context         // context passed to all ShardChannel
		fct              rpc.ClientStreamFactory // factory to get rpc  writeTask client
		stateMgr         broker.StateManager
		logger           logger.Logger
		cancel           context.CancelFunc // cancelFun to cancel context
		databaseChannels databaseChannels
	}
)

// NewChannelManager returns a ChannelManager with dirPath and WriteClientFactory.