topic

Documentation

Index

• Constants
• Variables
• func ExpandConsumers(consumers []interface{}) []topictypes.Consumer
• func FlattenConsumersDescription(consumers []topictypes.Consumer) []map[string]interface{}
• func MergeConsumerSettings(consumers []interface{}, readRules []topictypes.Consumer) (opts []topicoptions.AlterOption)

Constants

const (
	YDBTopicCodecGZIP = "gzip"
	YDBTopicCodecRAW  = "raw"
	YDBTopicCodecZSTD = "zstd"
)

Variables

var (
	YDBTopicAllowedCodecs = []string{
		YDBTopicCodecRAW,
		YDBTopicCodecGZIP,
		YDBTopicCodecZSTD,
	}

	YDBTopicDefaultCodecs = []topictypes.Codec{
		topictypes.CodecRaw,
		topictypes.CodecGzip,
		topictypes.CodecZstd,
	}

	YDBTopicCodecNameToCodec = map[string]topictypes.Codec{
		YDBTopicCodecRAW:  topictypes.CodecRaw,
		YDBTopicCodecGZIP: topictypes.CodecGzip,
		YDBTopicCodecZSTD: topictypes.CodecZstd,
	}

	YDBTopicCodecToCodecName = map[topictypes.Codec]string{
		topictypes.CodecRaw:  YDBTopicCodecRAW,
		topictypes.CodecGzip: YDBTopicCodecGZIP,
		topictypes.CodecZstd: YDBTopicCodecZSTD,
	}
)

Functions

func ExpandConsumers

func ExpandConsumers(consumers []interface{}) []topictypes.Consumer

func FlattenConsumersDescription

func FlattenConsumersDescription(consumers []topictypes.Consumer) []map[string]interface{}

func MergeConsumerSettings

func MergeConsumerSettings(
	consumers []interface{},
	readRules []topictypes.Consumer,
) (opts []topicoptions.AlterOption)