Method Stop

replica/channel_database.go:192–203

Stop stops current database write shardChannel.

()

// Stop stops current database write shardChannel.
func (dc *databaseChannel) Stop() {
	dc.shardChannels.mu.Lock()
	defer func() {
		dc.cancel()
		dc.shardChannels.mu.Unlock()
	}()

	channels := dc.shardChannels.value.Load().(shard2Channel)
	for _, channel := range channels {
		channel.Stop()
	}
}

// getChannelByShardID gets the replica shardChannel by shard id
func (dc *databaseChannel) getChannelByShardID(shardID models.ShardID) (ShardChannel, bool) {