Interface ChannelManager

replica/channel_manager.go:40–46

go:generate mockgen -source=./channel_manager.go -destination=./channel_manager_mock.go -package=replica ChannelManager manages the construction, retrieving, closing for all channels.

// ChannelManager manages the construction, retrieving, closing for all channels.
type ChannelManager interface {
	// Write writes a MetricList, the manager handler the database, sharding things.
	Write(ctx context.Context, database string, brokerBatchRows *metric.BrokerBatchRows) error

	// Close closes all the shardChannel.
	Close()
}

// channelManager implements ChannelManager.
type (