records

type AWSKinesis struct {
	PartitionKey   string `protobuf:"bytes,1,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	SequenceNumber string `protobuf:"bytes,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	EncryptionType string `protobuf:"bytes,3,opt,name=encryption_type,json=encryptionType,proto3" json:"encryption_type,omitempty"`
	ShardId        string `protobuf:"bytes,4,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Value          []byte `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type AWSSQS struct {
	Id              string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Timestamp       int64             `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	RecipientHandle string            `protobuf:"bytes,3,opt,name=recipient_handle,json=recipientHandle,proto3" json:"recipient_handle,omitempty"`
	Attributes      map[string]string `` /* 161-byte string literal not displayed */
	Value           []byte            `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type ActiveMQ struct {
	Destination    string `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	ContentType    string `protobuf:"bytes,2,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	SubscriptionId string `protobuf:"bytes,3,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	Timestamp      int64  `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value          []byte `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type AzureEventHub struct {
	Id               string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	SystemProperties map[string]string `` /* 197-byte string literal not displayed */
	Timestamp        int64             `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value            []byte            `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type AzureServiceBus struct {
	ContentType      string                 `protobuf:"bytes,1,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	CorrelationId    string                 `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Value            []byte                 `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	DeliveryCount    uint32                 `protobuf:"varint,4,opt,name=delivery_count,json=deliveryCount,proto3" json:"delivery_count,omitempty"`
	SessionId        string                 `protobuf:"bytes,5,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	GroupSequence    uint32                 `protobuf:"varint,6,opt,name=group_sequence,json=groupSequence,proto3" json:"group_sequence,omitempty"`
	Id               string                 `protobuf:"bytes,7,opt,name=id,proto3" json:"id,omitempty"`
	Label            string                 `protobuf:"bytes,8,opt,name=label,proto3" json:"label,omitempty"`
	ReplyTo          string                 `protobuf:"bytes,9,opt,name=reply_to,json=replyTo,proto3" json:"reply_to,omitempty"`
	ReplyToGroupId   string                 `protobuf:"bytes,10,opt,name=reply_to_group_id,json=replyToGroupId,proto3" json:"reply_to_group_id,omitempty"`
	To               string                 `protobuf:"bytes,11,opt,name=to,proto3" json:"to,omitempty"`
	Ttl              int64                  `protobuf:"varint,12,opt,name=ttl,proto3" json:"ttl,omitempty"`
	LockToken        string                 `protobuf:"bytes,13,opt,name=lock_token,json=lockToken,proto3" json:"lock_token,omitempty"`
	SystemProperties *AzureSystemProperties `protobuf:"bytes,14,opt,name=system_properties,json=systemProperties,proto3" json:"system_properties,omitempty"`
	UserProperties   map[string]string      `` /* 192-byte string literal not displayed */
	Format           uint32                 `protobuf:"varint,16,opt,name=format,proto3" json:"format,omitempty"`
	// contains filtered or unexported fields
}

type AzureSystemProperties struct {
	LockedUntil            int64             `protobuf:"varint,1,opt,name=locked_until,json=lockedUntil,proto3" json:"locked_until,omitempty"`
	SequenceNumber         int64             `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	PartitionId            int32             `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	PartitionKey           string            `protobuf:"bytes,4,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	EnqueuedTime           int64             `protobuf:"varint,5,opt,name=enqueued_time,json=enqueuedTime,proto3" json:"enqueued_time,omitempty"`
	DeadLetterSource       string            `protobuf:"bytes,6,opt,name=dead_letter_source,json=deadLetterSource,proto3" json:"dead_letter_source,omitempty"`
	ScheduledEnqueueTime   int64             `protobuf:"varint,7,opt,name=scheduled_enqueue_time,json=scheduledEnqueueTime,proto3" json:"scheduled_enqueue_time,omitempty"`
	EnqueuedSequenceNumber int64             `` /* 130-byte string literal not displayed */
	ViaPartitionKey        string            `protobuf:"bytes,9,opt,name=via_partition_key,json=viaPartitionKey,proto3" json:"via_partition_key,omitempty"`
	Annotations            map[string]string `` /* 164-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ErrorRecord struct {
	OccurredAtUnixTsUtc int64             `protobuf:"varint,1,opt,name=occurred_at_unix_ts_utc,json=occurredAtUnixTsUtc,proto3" json:"occurred_at_unix_ts_utc,omitempty"`
	Error               string            `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Metadata            map[string][]byte `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

type GCPPubSub struct {
	Id              string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Value           []byte            `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Attributes      map[string]string `` /* 161-byte string literal not displayed */
	PublishTime     int64             `protobuf:"varint,4,opt,name=publish_time,json=publishTime,proto3" json:"publish_time,omitempty"`
	DeliveryAttempt int32             `protobuf:"varint,5,opt,name=delivery_attempt,json=deliveryAttempt,proto3" json:"delivery_attempt,omitempty"`
	OrderingKey     string            `protobuf:"bytes,6,opt,name=ordering_key,json=orderingKey,proto3" json:"ordering_key,omitempty"`
	// contains filtered or unexported fields
}

type IsReadRecord_Record = isReadRecord_Record

type Kafka struct {
	Topic     string         `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Key       []byte         `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte         `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp int64          `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Offset    int64          `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	Partition int32          `protobuf:"varint,6,opt,name=partition,proto3" json:"partition,omitempty"`
	Headers   []*KafkaHeader `protobuf:"bytes,7,rep,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

type KafkaHeader struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type KubeMQ struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ClientId  string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Channel   string `protobuf:"bytes,3,opt,name=channel,proto3" json:"channel,omitempty"`
	Value     []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp int64  `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Sequence  int64  `protobuf:"varint,6,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

type MQTT struct {
	Id        uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Topic     string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Value     []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Duplicate bool   `protobuf:"varint,4,opt,name=duplicate,proto3" json:"duplicate,omitempty"`
	Retained  bool   `protobuf:"varint,5,opt,name=retained,proto3" json:"retained,omitempty"`
	Qos       uint32 `protobuf:"varint,6,opt,name=qos,proto3" json:"qos,omitempty"`
	Timestamp int64  `protobuf:"varint,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type Memphis struct {
	Value     []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type Mongo struct {
	Value     []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type NSQ struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Topic       string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Channel     string `protobuf:"bytes,3,opt,name=channel,proto3" json:"channel,omitempty"`
	Attempts    int32  `protobuf:"varint,4,opt,name=attempts,proto3" json:"attempts,omitempty"`
	NsqdAddress string `protobuf:"bytes,5,opt,name=nsqd_address,json=nsqdAddress,proto3" json:"nsqd_address,omitempty"`
	Value       []byte `protobuf:"bytes,6,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp   int64  `protobuf:"varint,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type Nats struct {
	Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	Value   []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type NatsJetstream struct {
	Stream       string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	Value        []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	ConsumerName string `protobuf:"bytes,3,opt,name=consumer_name,json=consumerName,proto3" json:"consumer_name,omitempty"`
	Sequence     int64  `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

type NatsStreaming struct {
	Metadata  map[string]string `` /* 157-byte string literal not displayed */
	Value     []byte            `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp int64             `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type Postgres struct {
	Metadata  map[string]string `` /* 157-byte string literal not displayed */
	Timestamp int64             `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     []byte            `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Pulsar struct {
	Id              string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Key             string            `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Topic           string            `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Properties      map[string]string `` /* 161-byte string literal not displayed */
	RedeliveryCount uint32            `protobuf:"varint,5,opt,name=redelivery_count,json=redeliveryCount,proto3" json:"redelivery_count,omitempty"`
	EventTime       string            `protobuf:"bytes,6,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	IsReplicated    bool              `protobuf:"varint,7,opt,name=is_replicated,json=isReplicated,proto3" json:"is_replicated,omitempty"`
	OrderingKey     string            `protobuf:"bytes,8,opt,name=ordering_key,json=orderingKey,proto3" json:"ordering_key,omitempty"`
	ProducerName    string            `protobuf:"bytes,9,opt,name=producer_name,json=producerName,proto3" json:"producer_name,omitempty"`
	PublishTime     string            `protobuf:"bytes,10,opt,name=publish_time,json=publishTime,proto3" json:"publish_time,omitempty"`
	Timestamp       int64             `protobuf:"varint,11,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value           []byte            `protobuf:"bytes,12,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Rabbit struct {
	Body            []byte          `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	Timestamp       int64           `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Type            string          `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Exchange        string          `protobuf:"bytes,4,opt,name=exchange,proto3" json:"exchange,omitempty"`
	RoutingKey      string          `protobuf:"bytes,5,opt,name=routing_key,json=routingKey,proto3" json:"routing_key,omitempty"`
	ContentType     string          `protobuf:"bytes,6,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	ContentEncoding string          `protobuf:"bytes,7,opt,name=content_encoding,json=contentEncoding,proto3" json:"content_encoding,omitempty"`
	Priority        int32           `protobuf:"varint,8,opt,name=priority,proto3" json:"priority,omitempty"`
	Expiration      string          `protobuf:"bytes,9,opt,name=expiration,proto3" json:"expiration,omitempty"`
	MessageId       string          `protobuf:"bytes,10,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	UserId          string          `protobuf:"bytes,11,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	AppId           string          `protobuf:"bytes,12,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	ReplyTo         string          `protobuf:"bytes,13,opt,name=reply_to,json=replyTo,proto3" json:"reply_to,omitempty"`
	CorrelationId   string          `protobuf:"bytes,14,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Headers         []*RabbitHeader `protobuf:"bytes,15,rep,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

type RabbitHeader struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type RabbitStreams struct {
	DeliveryTag         string               `protobuf:"bytes,1,opt,name=delivery_tag,json=deliveryTag,proto3" json:"delivery_tag,omitempty"`
	Format              uint32               `protobuf:"varint,2,opt,name=format,proto3" json:"format,omitempty"`
	Header              *RabbitStreamsHeader `protobuf:"bytes,3,opt,name=header,proto3" json:"header,omitempty"`
	DeliveryAnnotations map[string]string    `` /* 206-byte string literal not displayed */
	SendSettled         bool                 `protobuf:"varint,5,opt,name=send_settled,json=sendSettled,proto3" json:"send_settled,omitempty"`
	StreamName          string               `protobuf:"bytes,6,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	Timestamp           int64                `protobuf:"varint,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value               []byte               `protobuf:"bytes,8,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type RabbitStreamsHeader struct {
	Durable       bool   `protobuf:"varint,1,opt,name=durable,proto3" json:"durable,omitempty"`
	Priority      uint32 `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	Ttl           int64  `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	FirstAcquirer bool   `protobuf:"varint,4,opt,name=first_acquirer,json=firstAcquirer,proto3" json:"first_acquirer,omitempty"`
	DeliveryCount uint32 `protobuf:"varint,5,opt,name=delivery_count,json=deliveryCount,proto3" json:"delivery_count,omitempty"`
	// contains filtered or unexported fields
}

type ReadRecord struct {

	// Unique id automatically created by plumber
	MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// Plumber counts the number of messages it reads; this number represents
	// the message number (useful for CLI).
	Num int64 `protobuf:"varint,3,opt,name=num,proto3" json:"num,omitempty"`
	// Metadata may contain properties that cannot be found in the Raw message.
	// For example: read lag in Kafka.
	//
	// Metadata may also contain data such as "count" which is an incremental
	// number that plumber assigns to each message it receives. This is used
	// with read via CLI functionality to allow the user to quickly discern
	// whether this is message #1 or #500, etc.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// UTC unix timestamp of when plumber received the message; a backend record
	// entry might have its own timestamp as well. This should be seconds.
	ReceivedAtUnixTsUtc int64 `protobuf:"varint,6,opt,name=received_at_unix_ts_utc,json=receivedAtUnixTsUtc,proto3" json:"received_at_unix_ts_utc,omitempty"`
	// Set _outside_ the backend; will contain the final value, regardless of
	// whether decoding options were specified for a read.
	// _This_ is what both CLI and desktop should display for the payload.
	Payload []byte `protobuf:"bytes,99,opt,name=payload,proto3" json:"payload,omitempty"`
	// Types that are assignable to Record:
	//
	//	*ReadRecord_Kafka
	//	*ReadRecord_Rabbit
	//	*ReadRecord_Activemq
	//	*ReadRecord_AwsSqs
	//	*ReadRecord_AzureEventHub
	//	*ReadRecord_AzureServiceBus
	//	*ReadRecord_GcpPubsub
	//	*ReadRecord_Kubemq
	//	*ReadRecord_Mongo
	//	*ReadRecord_Mqtt
	//	*ReadRecord_Nats
	//	*ReadRecord_NatsStreaming
	//	*ReadRecord_Nsq
	//	*ReadRecord_Postgres
	//	*ReadRecord_Pulsar
	//	*ReadRecord_RabbitStreams
	//	*ReadRecord_RedisPubsub
	//	*ReadRecord_RedisStreams
	//	*ReadRecord_NatsJetstream
	//	*ReadRecord_AwsKinesis
	//	*ReadRecord_Memphis
	Record isReadRecord_Record `protobuf_oneof:"Record"`
	// Original backend message (encoded with gob, ie. *skafka.Message, etc.).
	// In most cases, you should use the oneof record instead of the raw message.
	XRaw []byte `protobuf:"bytes,1000,opt,name=_raw,json=Raw,proto3" json:"_raw,omitempty"`
	// Identifies which plumber instance received the event (set outside the backend)
	XPlumberId string `protobuf:"bytes,1001,opt,name=_plumber_id,json=PlumberId,proto3" json:"_plumber_id,omitempty"`
	// contains filtered or unexported fields
}

type ReadRecord_Activemq struct {
	Activemq *ActiveMQ `protobuf:"bytes,102,opt,name=activemq,proto3,oneof"`
}

type ReadRecord_AwsKinesis struct {
	AwsKinesis *AWSKinesis `protobuf:"bytes,119,opt,name=aws_kinesis,json=awsKinesis,proto3,oneof"`
}

type ReadRecord_AwsSqs struct {
	AwsSqs *AWSSQS `protobuf:"bytes,103,opt,name=aws_sqs,json=awsSqs,proto3,oneof"`
}

type ReadRecord_AzureEventHub struct {
	AzureEventHub *AzureEventHub `protobuf:"bytes,104,opt,name=azure_event_hub,json=azureEventHub,proto3,oneof"`
}

type ReadRecord_AzureServiceBus struct {
	AzureServiceBus *AzureServiceBus `protobuf:"bytes,105,opt,name=azure_service_bus,json=azureServiceBus,proto3,oneof"`
}

type ReadRecord_GcpPubsub struct {
	GcpPubsub *GCPPubSub `protobuf:"bytes,106,opt,name=gcp_pubsub,json=gcpPubsub,proto3,oneof"`
}

type ReadRecord_Kafka struct {
	Kafka *Kafka `protobuf:"bytes,100,opt,name=kafka,proto3,oneof"`
}

type ReadRecord_Kubemq struct {
	Kubemq *KubeMQ `protobuf:"bytes,107,opt,name=kubemq,proto3,oneof"`
}

type ReadRecord_Memphis struct {
	Memphis *Memphis `protobuf:"bytes,120,opt,name=memphis,proto3,oneof"`
}

type ReadRecord_Mongo struct {
	Mongo *Mongo `protobuf:"bytes,108,opt,name=mongo,proto3,oneof"`
}

type ReadRecord_Mqtt struct {
	Mqtt *MQTT `protobuf:"bytes,109,opt,name=mqtt,proto3,oneof"`
}

type ReadRecord_Nats struct {
	Nats *Nats `protobuf:"bytes,110,opt,name=nats,proto3,oneof"`
}

type ReadRecord_NatsJetstream struct {
	NatsJetstream *NatsJetstream `protobuf:"bytes,118,opt,name=nats_jetstream,json=natsJetstream,proto3,oneof"`
}

type ReadRecord_NatsStreaming struct {
	NatsStreaming *NatsStreaming `protobuf:"bytes,111,opt,name=nats_streaming,json=natsStreaming,proto3,oneof"`
}

type ReadRecord_Nsq struct {
	Nsq *NSQ `protobuf:"bytes,112,opt,name=nsq,proto3,oneof"`
}

type ReadRecord_Postgres struct {
	Postgres *Postgres `protobuf:"bytes,113,opt,name=postgres,proto3,oneof"`
}

type ReadRecord_Pulsar struct {
	Pulsar *Pulsar `protobuf:"bytes,114,opt,name=pulsar,proto3,oneof"`
}

type ReadRecord_Rabbit struct {
	Rabbit *Rabbit `protobuf:"bytes,101,opt,name=rabbit,proto3,oneof"`
}

type ReadRecord_RabbitStreams struct {
	RabbitStreams *RabbitStreams `protobuf:"bytes,115,opt,name=rabbit_streams,json=rabbitStreams,proto3,oneof"`
}

type ReadRecord_RedisPubsub struct {
	RedisPubsub *RedisPubsub `protobuf:"bytes,116,opt,name=redis_pubsub,json=redisPubsub,proto3,oneof"`
}

type ReadRecord_RedisStreams struct {
	RedisStreams *RedisStreams `protobuf:"bytes,117,opt,name=redis_streams,json=redisStreams,proto3,oneof"`
}

type RedisPubsub struct {
	Metadata  map[string]string `` /* 157-byte string literal not displayed */
	Value     []byte            `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp int64             `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type RedisStreams struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Key       string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value     string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Stream    string `protobuf:"bytes,4,opt,name=stream,proto3" json:"stream,omitempty"`
	Timestamp int64  `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type WriteRecord struct {

	// If encoding options are provided, this value will be updated by plumber
	// to contain the encoded payload _before_ passing it to the backend.
	// @gotags: kong:"help='Input string',name=input,xor=input,default"
	Input string `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty" kong:"help='Input string',name=input,xor=input,default"`
	// @gotags: kong:"help='Optional metadata a backend may use (key1=value,key2=value,etc)',name=input-metadata"
	InputMetadata map[string]string `` /* 286-byte string literal not displayed */
	// contains filtered or unexported fields
}