redisstream

type ConsumerDef struct {
	Name             string                       `hcl:",label"`
	Stream           hcl.Expression               `hcl:"stream"`
	Group            string                       `hcl:"group"`
	ConsumerName     hcl.Expression               `hcl:"consumer_name,optional"`
	VinculumTopic    hcl.Expression               `hcl:"vinculum_topic,optional"`
	Subscriber       hcl.Expression               `hcl:"subscriber,optional"`
	Action           hcl.Expression               `hcl:"action,optional"`
	Transforms       hcl.Expression               `hcl:"transforms,optional"`
	OnDecodeError    hcl.Expression               `hcl:"on_decode_error,optional"`
	QueueSize        *int                         `hcl:"queue_size,optional"`
	Baggage          *hclutil.BaggageFilterConfig `hcl:"baggage,block"`
	BatchSize        *int64                       `hcl:"batch_size,optional"`
	BlockTimeout     hcl.Expression               `hcl:"block_timeout,optional"`
	AutoAck          *bool                        `hcl:"auto_ack,optional"`
	GroupCreate      string                       `hcl:"group_create,optional"`
	PayloadField     *string                      `hcl:"payload_field,optional"`
	TopicField       *string                      `hcl:"topic_field,optional"`
	ContentTypeField *string                      `hcl:"content_type_field,optional"`
	FieldsMode       string                       `hcl:"fields_mode,optional"`
	ReclaimPending   *bool                        `hcl:"reclaim_pending,optional"`
	ReclaimMinIdle   hcl.Expression               `hcl:"reclaim_min_idle,optional"`
	DeadLetterStream string                       `hcl:"dead_letter_stream,optional"`
	DeadLetterAfter  *int64                       `hcl:"dead_letter_after,optional"`
	DefRange         hcl.Range                    `hcl:",def_range"`
}

type ProducerDef struct {
	Name                   string         `hcl:",label"`
	Stream                 hcl.Expression `hcl:"stream,optional"`
	MaxLen                 *int64         `hcl:"maxlen,optional"`
	ApproximateMaxLen      *bool          `hcl:"approximate_maxlen,optional"`
	DefaultStreamTransform string         `hcl:"default_stream_transform,optional"`
	PayloadField           *string        `hcl:"payload_field,optional"`
	TopicField             *string        `hcl:"topic_field,optional"`
	ContentTypeField       *string        `hcl:"content_type_field,optional"`
	FieldsMode             string         `hcl:"fields_mode,optional"`
	DefRange               hcl.Range      `hcl:",def_range"`
}

type RedisStreamClient struct {
	cfg.BaseClient
	bus.BaseSubscriber
	// contains filtered or unexported fields
}

type RedisStreamDefinition struct {
	Connection hcl.Expression `hcl:"connection"`
	WireFormat hcl.Expression `hcl:"wire_format,optional"`
	Metrics    hcl.Expression `hcl:"metrics,optional"`
	Tracing    hcl.Expression `hcl:"tracing,optional"`
	Producers  []ProducerDef  `hcl:"producer,block"`
	Consumers  []ConsumerDef  `hcl:"consumer,block"`
	DefRange   hcl.Range      `hcl:",def_range"`
}