args

package
v0.0.185 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 13, 2024 License: Apache-2.0 Imports: 4 Imported by: 23

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SASLType_name = map[int32]string{
		0: "NONE",
		1: "PLAIN",
		2: "SCRAM",
	}
	SASLType_value = map[string]int32{
		"NONE":  0,
		"PLAIN": 1,
		"SCRAM": 2,
	}
)

Enum value maps for SASLType.

View Source 
var (
	MQTTQoSLevel_name = map[int32]string{
		0: "MQTT_QOS_LEVEL_AT_MOST_ONCE",
		1: "MQTT_QOS_LEVEL_AT_LEAST_ONCE",
		2: "MQTT_QOS_LEVEL_EXACTLY_ONCE",
	}
	MQTTQoSLevel_value = map[string]int32{
		"MQTT_QOS_LEVEL_AT_MOST_ONCE":  0,
		"MQTT_QOS_LEVEL_AT_LEAST_ONCE": 1,
		"MQTT_QOS_LEVEL_EXACTLY_ONCE":  2,
	}
)

Enum value maps for MQTTQoSLevel.

View Source 
var (
	SubscriptionType_name = map[int32]string{
		0: "SHARED",
		1: "EXCLUSIVE",
		2: "FAILOVER",
		3: "KEYSHARED",
	}
	SubscriptionType_value = map[string]int32{
		"SHARED":    0,
		"EXCLUSIVE": 1,
		"FAILOVER":  2,
		"KEYSHARED": 3,
	}
)

Enum value maps for SubscriptionType.

View Source 
var (
	SubscriptionInitialPosition_name = map[int32]string{
		0: "PULSAR_LATEST",
		1: "PULSAR_EARLIEST",
	}
	SubscriptionInitialPosition_value = map[string]int32{
		"PULSAR_LATEST":   0,
		"PULSAR_EARLIEST": 1,
	}
)

Enum value maps for SubscriptionInitialPosition.

View Source 
var (
	OffsetStart_name = map[int32]string{
		0: "LATEST",
		1: "OLDEST",
	}
	OffsetStart_value = map[string]int32{
		"LATEST": 0,
		"OLDEST": 1,
	}
)

Enum value maps for OffsetStart.

View Source 
var File_ps_args_activemq_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_aws_kinesis_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_aws_sns_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_aws_sqs_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_azure_event_hub_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_azure_service_bus_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_gcp_pubsub_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_kafka_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_kubemq_queue_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_memphis_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_mongo_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_mqtt_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_nats_jetstream_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_nats_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_nats_streaming_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_nsq_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_postgres_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_pulsar_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_rabbit_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_rabbit_streams_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_redis_pubsub_proto protoreflect.FileDescriptor
View Source 
var File_ps_args_redis_streams_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AWSKinesisConn added in v0.0.121 

type AWSKinesisConn struct {

	// @gotags: kong:"env=AWS_DEFAULT_REGION,hidden"
	AwsRegion string `protobuf:"bytes,1,opt,name=aws_region,json=awsRegion,proto3" json:"aws_region,omitempty" kong:"env=AWS_DEFAULT_REGION,hidden"`
	// @gotags: kong:"env=AWS_ACCESS_KEY_ID,hidden"
	AwsAccessKeyId string `` /* 143-byte string literal not displayed */
	// @gotags: kong:"env=AWS_SECRET_ACCESS_KEY,hidden"
	AwsSecretAccessKey string `` /* 159-byte string literal not displayed */
	// @gotags: kong:"env=AWS_PROFILE,hidden"
	AwsProfile string `protobuf:"bytes,4,opt,name=aws_profile,json=awsProfile,proto3" json:"aws_profile,omitempty" kong:"env=AWS_PROFILE,hidden"`
	// contains filtered or unexported fields
}

func (*AWSKinesisConn) Descriptor deprecated added in v0.0.121 

func (*AWSKinesisConn) Descriptor() ([]byte, []int)

Deprecated: Use AWSKinesisConn.ProtoReflect.Descriptor instead.

func (*AWSKinesisConn) GetAwsAccessKeyId added in v0.0.121 

func (x *AWSKinesisConn) GetAwsAccessKeyId() string

func (*AWSKinesisConn) GetAwsProfile added in v0.0.123 

func (x *AWSKinesisConn) GetAwsProfile() string

func (*AWSKinesisConn) GetAwsRegion added in v0.0.121 

func (x *AWSKinesisConn) GetAwsRegion() string

func (*AWSKinesisConn) GetAwsSecretAccessKey added in v0.0.121 

func (x *AWSKinesisConn) GetAwsSecretAccessKey() string

func (*AWSKinesisConn) ProtoMessage added in v0.0.121 

func (*AWSKinesisConn) ProtoMessage()

func (*AWSKinesisConn) ProtoReflect added in v0.0.181 

func (x *AWSKinesisConn) ProtoReflect() protoreflect.Message

func (*AWSKinesisConn) Reset added in v0.0.121 

func (x *AWSKinesisConn) Reset()

func (*AWSKinesisConn) String added in v0.0.121 

func (x *AWSKinesisConn) String() string

type AWSKinesisReadArgs added in v0.0.121 

type AWSKinesisReadArgs struct {

	// @gotags: kong:"help='Stream Name',required"
	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty" kong:"help='Stream Name',required"`
	// @gotags: kong:"help='Shard ID. If empty, will read from all shards'"
	Shard string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty" kong:"help='Shard ID. If empty, will read from all shards'"`
	// @gotags: kong:"help='Maximum number of records to read from kinesis',default=1"
	MaxRecords int64 `` /* 163-byte string literal not displayed */
	// @gotags: kong:"help='Deliver starting at this timestamp',xor=kinesis_delivery_option"
	ReadFromTimestamp int64 `` /* 192-byte string literal not displayed */
	// @gotags: kong:"help='Deliver messages starting at sequence number',xor=kinesis_delivery_option"
	ReadSequenceNumber string `` /* 204-byte string literal not displayed */
	// @gotags: kong:"help='Deliver messages starting after this sequence number',xor=kinesis_delivery_option"
	ReadAfterSequenceNumber string `` /* 229-byte string literal not displayed */
	// @gotags: kong:"help='Deliver messages starting at the last untrimmed record in the shard in the system, which is the oldest data record in the shard.',xor=kinesis_delivery_option"
	ReadTrimHorizon bool `` /* 280-byte string literal not displayed */
	// @gotags: kong:"help='Deliver messages after the most recent record',xor=kinesis_delivery_option"
	ReadLatest bool `` /* 180-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AWSKinesisReadArgs) Descriptor deprecated added in v0.0.121 

func (*AWSKinesisReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use AWSKinesisReadArgs.ProtoReflect.Descriptor instead.

func (*AWSKinesisReadArgs) GetMaxRecords added in v0.0.121 

func (x *AWSKinesisReadArgs) GetMaxRecords() int64

func (*AWSKinesisReadArgs) GetReadAfterSequenceNumber added in v0.0.121 

func (x *AWSKinesisReadArgs) GetReadAfterSequenceNumber() string

func (*AWSKinesisReadArgs) GetReadFromTimestamp added in v0.0.121 

func (x *AWSKinesisReadArgs) GetReadFromTimestamp() int64

func (*AWSKinesisReadArgs) GetReadLatest added in v0.0.121 

func (x *AWSKinesisReadArgs) GetReadLatest() bool

func (*AWSKinesisReadArgs) GetReadSequenceNumber added in v0.0.121 

func (x *AWSKinesisReadArgs) GetReadSequenceNumber() string

func (*AWSKinesisReadArgs) GetReadTrimHorizon added in v0.0.121 

func (x *AWSKinesisReadArgs) GetReadTrimHorizon() bool

func (*AWSKinesisReadArgs) GetShard added in v0.0.121 

func (x *AWSKinesisReadArgs) GetShard() string

func (*AWSKinesisReadArgs) GetStream added in v0.0.121 

func (x *AWSKinesisReadArgs) GetStream() string

func (*AWSKinesisReadArgs) ProtoMessage added in v0.0.121 

func (*AWSKinesisReadArgs) ProtoMessage()

func (*AWSKinesisReadArgs) ProtoReflect added in v0.0.181 

func (x *AWSKinesisReadArgs) ProtoReflect() protoreflect.Message

func (*AWSKinesisReadArgs) Reset added in v0.0.121 

func (x *AWSKinesisReadArgs) Reset()

func (*AWSKinesisReadArgs) String added in v0.0.121 

func (x *AWSKinesisReadArgs) String() string

type AWSKinesisWriteArgs added in v0.0.121 

type AWSKinesisWriteArgs struct {

	// @gotags: kong:"help='Stream Name',required"
	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty" kong:"help='Stream Name',required"`
	// @gotags: kong:"help='Partition Key',required"
	PartitionKey string `` /* 134-byte string literal not displayed */
	// @gotags: kong:"help='Sequence number for ordering'"
	SequenceNumber string `` /* 146-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AWSKinesisWriteArgs) Descriptor deprecated added in v0.0.121 

func (*AWSKinesisWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use AWSKinesisWriteArgs.ProtoReflect.Descriptor instead.

func (*AWSKinesisWriteArgs) GetPartitionKey added in v0.0.121 

func (x *AWSKinesisWriteArgs) GetPartitionKey() string

func (*AWSKinesisWriteArgs) GetSequenceNumber added in v0.0.121 

func (x *AWSKinesisWriteArgs) GetSequenceNumber() string

func (*AWSKinesisWriteArgs) GetStream added in v0.0.121 

func (x *AWSKinesisWriteArgs) GetStream() string

func (*AWSKinesisWriteArgs) ProtoMessage added in v0.0.121 

func (*AWSKinesisWriteArgs) ProtoMessage()

func (*AWSKinesisWriteArgs) ProtoReflect added in v0.0.181 

func (x *AWSKinesisWriteArgs) ProtoReflect() protoreflect.Message

func (*AWSKinesisWriteArgs) Reset added in v0.0.121 

func (x *AWSKinesisWriteArgs) Reset()

func (*AWSKinesisWriteArgs) String added in v0.0.121 

func (x *AWSKinesisWriteArgs) String() string

type AWSSNSConn added in v0.0.46 

type AWSSNSConn struct {

	// @gotags: kong:"env=AWS_DEFAULT_REGION,hidden"
	AwsRegion string `protobuf:"bytes,1,opt,name=aws_region,json=awsRegion,proto3" json:"aws_region,omitempty" kong:"env=AWS_DEFAULT_REGION,hidden"`
	// @gotags: kong:"env=AWS_ACCESS_KEY_ID,hidden"
	AwsAccessKeyId string `` /* 143-byte string literal not displayed */
	// @gotags: kong:"env=AWS_SECRET_ACCESS_KEY,hidden"
	AwsSecretAccessKey string `` /* 159-byte string literal not displayed */
	// @gotags: kong:"env=AWS_PROFILE,hidden"
	AwsProfile string `protobuf:"bytes,4,opt,name=aws_profile,json=awsProfile,proto3" json:"aws_profile,omitempty" kong:"env=AWS_PROFILE,hidden"`
	// contains filtered or unexported fields
}

func (*AWSSNSConn) Descriptor deprecated added in v0.0.46 

func (*AWSSNSConn) Descriptor() ([]byte, []int)

Deprecated: Use AWSSNSConn.ProtoReflect.Descriptor instead.

func (*AWSSNSConn) GetAwsAccessKeyId added in v0.0.46 

func (x *AWSSNSConn) GetAwsAccessKeyId() string

func (*AWSSNSConn) GetAwsProfile added in v0.0.123 

func (x *AWSSNSConn) GetAwsProfile() string

func (*AWSSNSConn) GetAwsRegion added in v0.0.46 

func (x *AWSSNSConn) GetAwsRegion() string

func (*AWSSNSConn) GetAwsSecretAccessKey added in v0.0.46 

func (x *AWSSNSConn) GetAwsSecretAccessKey() string

func (*AWSSNSConn) ProtoMessage added in v0.0.46 

func (*AWSSNSConn) ProtoMessage()

func (*AWSSNSConn) ProtoReflect added in v0.0.181 

func (x *AWSSNSConn) ProtoReflect() protoreflect.Message

func (*AWSSNSConn) Reset added in v0.0.46 

func (x *AWSSNSConn) Reset()

func (*AWSSNSConn) String added in v0.0.46 

func (x *AWSSNSConn) String() string

type AWSSNSWriteArgs added in v0.0.47 

type AWSSNSWriteArgs struct {

	// @gotags: kong:"help='Topic ARN',required"
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic ARN',required"`
	// contains filtered or unexported fields
}

func (*AWSSNSWriteArgs) Descriptor deprecated added in v0.0.47 

func (*AWSSNSWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use AWSSNSWriteArgs.ProtoReflect.Descriptor instead.

func (*AWSSNSWriteArgs) GetTopic added in v0.0.47 

func (x *AWSSNSWriteArgs) GetTopic() string

func (*AWSSNSWriteArgs) ProtoMessage added in v0.0.47 

func (*AWSSNSWriteArgs) ProtoMessage()

func (*AWSSNSWriteArgs) ProtoReflect added in v0.0.181 

func (x *AWSSNSWriteArgs) ProtoReflect() protoreflect.Message

func (*AWSSNSWriteArgs) Reset added in v0.0.47 

func (x *AWSSNSWriteArgs) Reset()

func (*AWSSNSWriteArgs) String added in v0.0.47 

func (x *AWSSNSWriteArgs) String() string

type AWSSQSConn added in v0.0.46 

type AWSSQSConn struct {

	// @gotags: kong:"env=AWS_DEFAULT_REGION,hidden"
	AwsRegion string `protobuf:"bytes,1,opt,name=aws_region,json=awsRegion,proto3" json:"aws_region,omitempty" kong:"env=AWS_DEFAULT_REGION,hidden"`
	// @gotags: kong:"env=AWS_ACCESS_KEY_ID,hidden"
	AwsAccessKeyId string `` /* 143-byte string literal not displayed */
	// @gotags: kong:"env=AWS_SECRET_ACCESS_KEY,hidden"
	AwsSecretAccessKey string `` /* 159-byte string literal not displayed */
	// @gotags: kong:"env=AWS_PROFILE,hidden"
	AwsProfile string `protobuf:"bytes,4,opt,name=aws_profile,json=awsProfile,proto3" json:"aws_profile,omitempty" kong:"env=AWS_PROFILE,hidden"`
	// contains filtered or unexported fields
}

func (*AWSSQSConn) Descriptor deprecated added in v0.0.46 

func (*AWSSQSConn) Descriptor() ([]byte, []int)

Deprecated: Use AWSSQSConn.ProtoReflect.Descriptor instead.

func (*AWSSQSConn) GetAwsAccessKeyId added in v0.0.46 

func (x *AWSSQSConn) GetAwsAccessKeyId() string

func (*AWSSQSConn) GetAwsProfile added in v0.0.123 

func (x *AWSSQSConn) GetAwsProfile() string

func (*AWSSQSConn) GetAwsRegion added in v0.0.46 

func (x *AWSSQSConn) GetAwsRegion() string

func (*AWSSQSConn) GetAwsSecretAccessKey added in v0.0.46 

func (x *AWSSQSConn) GetAwsSecretAccessKey() string

func (*AWSSQSConn) ProtoMessage added in v0.0.46 

func (*AWSSQSConn) ProtoMessage()

func (*AWSSQSConn) ProtoReflect added in v0.0.181 

func (x *AWSSQSConn) ProtoReflect() protoreflect.Message

func (*AWSSQSConn) Reset added in v0.0.46 

func (x *AWSSQSConn) Reset()

func (*AWSSQSConn) String added in v0.0.46 

func (x *AWSSQSConn) String() string

type AWSSQSReadArgs added in v0.0.47 

type AWSSQSReadArgs struct {

	// @gotags: kong:"help='Queue name'"
	QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty" kong:"help='Queue name'"`
	// @gotags: kong:"help='Remote AWS account ID',optional"
	RemoteAccountId string `` /* 153-byte string literal not displayed */
	// @gotags: kong:"help='Max number of messages to read',default=1"
	MaxNumMessages int64 `` /* 161-byte string literal not displayed */
	// @gotags: kong:"help='An id to identify this read request by',default='plumber/relay'"
	ReceiveRequestAttemptId string `` /* 211-byte string literal not displayed */
	// @gotags: kong:"help='Auto-delete read/received message(s)'"
	AutoDelete bool `` /* 143-byte string literal not displayed */
	// @gotags: kong:"help='Number of seconds to wait for messages (not used when using --continuous)',default=5"
	WaitTimeSeconds int64 `` /* 207-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AWSSQSReadArgs) Descriptor deprecated added in v0.0.47 

func (*AWSSQSReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use AWSSQSReadArgs.ProtoReflect.Descriptor instead.

func (*AWSSQSReadArgs) GetAutoDelete added in v0.0.47 

func (x *AWSSQSReadArgs) GetAutoDelete() bool

func (*AWSSQSReadArgs) GetMaxNumMessages added in v0.0.47 

func (x *AWSSQSReadArgs) GetMaxNumMessages() int64

func (*AWSSQSReadArgs) GetQueueName added in v0.0.47 

func (x *AWSSQSReadArgs) GetQueueName() string

func (*AWSSQSReadArgs) GetReceiveRequestAttemptId added in v0.0.47 

func (x *AWSSQSReadArgs) GetReceiveRequestAttemptId() string

func (*AWSSQSReadArgs) GetRemoteAccountId added in v0.0.47 

func (x *AWSSQSReadArgs) GetRemoteAccountId() string

func (*AWSSQSReadArgs) GetWaitTimeSeconds added in v0.0.47 

func (x *AWSSQSReadArgs) GetWaitTimeSeconds() int64

func (*AWSSQSReadArgs) ProtoMessage added in v0.0.47 

func (*AWSSQSReadArgs) ProtoMessage()

func (*AWSSQSReadArgs) ProtoReflect added in v0.0.181 

func (x *AWSSQSReadArgs) ProtoReflect() protoreflect.Message

func (*AWSSQSReadArgs) Reset added in v0.0.47 

func (x *AWSSQSReadArgs) Reset()

func (*AWSSQSReadArgs) String added in v0.0.47 

func (x *AWSSQSReadArgs) String() string

type AWSSQSRelayArgs added in v0.0.47 

type AWSSQSRelayArgs struct {

	// @gotags: kong:"help='Queue name',env=PLUMBER_RELAY_SQS_QUEUE_NAME"
	QueueName string `` /* 146-byte string literal not displayed */
	// @gotags: kong:"help='Remote AWS account ID',env=PLUMBER_RELAY_SQS_REMOTE_ACCOUNT_ID,optional"
	RemoteAccountId string `` /* 193-byte string literal not displayed */
	// @gotags: kong:"help='Max number of messages to read',env=PLUMBER_RELAY_SQS_MAX_NUM_MESSAGES,default=1"
	MaxNumMessages int64 `` /* 200-byte string literal not displayed */
	// @gotags: kong:"help='An id to identify this read request by',env=PLUMBER_RELAY_SQS_RECEIVE_REQUEST_ATTEMPT_ID,default='plumber/relay'"
	ReceiveRequestAttemptId string `` /* 260-byte string literal not displayed */
	// @gotags: kong:"help='Auto-delete read/received message(s)',env=PLUMBER_RELAY_SQS_AUTO_DELETE"
	AutoDelete bool `` /* 177-byte string literal not displayed */
	// @gotags: kong:"help='Number of seconds to wait for messages (not used when using --continuous)',env=PLUMBER_RELAY_SQS_WAIT_TIME_SECONDS,default=5"
	WaitTimeSeconds int64 `` /* 247-byte string literal not displayed */
	// contains filtered or unexported fields
}

SQS has a dedicated RelayArgs struct as relay has different defaults than read

func (*AWSSQSRelayArgs) Descriptor deprecated added in v0.0.47 

func (*AWSSQSRelayArgs) Descriptor() ([]byte, []int)

Deprecated: Use AWSSQSRelayArgs.ProtoReflect.Descriptor instead.

func (*AWSSQSRelayArgs) GetAutoDelete added in v0.0.47 

func (x *AWSSQSRelayArgs) GetAutoDelete() bool

func (*AWSSQSRelayArgs) GetMaxNumMessages added in v0.0.47 

func (x *AWSSQSRelayArgs) GetMaxNumMessages() int64

func (*AWSSQSRelayArgs) GetQueueName added in v0.0.47 

func (x *AWSSQSRelayArgs) GetQueueName() string

func (*AWSSQSRelayArgs) GetReceiveRequestAttemptId added in v0.0.47 

func (x *AWSSQSRelayArgs) GetReceiveRequestAttemptId() string

func (*AWSSQSRelayArgs) GetRemoteAccountId added in v0.0.47 

func (x *AWSSQSRelayArgs) GetRemoteAccountId() string

func (*AWSSQSRelayArgs) GetWaitTimeSeconds added in v0.0.47 

func (x *AWSSQSRelayArgs) GetWaitTimeSeconds() int64

func (*AWSSQSRelayArgs) ProtoMessage added in v0.0.47 

func (*AWSSQSRelayArgs) ProtoMessage()

func (*AWSSQSRelayArgs) ProtoReflect added in v0.0.181 

func (x *AWSSQSRelayArgs) ProtoReflect() protoreflect.Message

func (*AWSSQSRelayArgs) Reset added in v0.0.47 

func (x *AWSSQSRelayArgs) Reset()

func (*AWSSQSRelayArgs) String added in v0.0.47 

func (x *AWSSQSRelayArgs) String() string

type AWSSQSWriteArgs added in v0.0.47 

type AWSSQSWriteArgs struct {

	// @gotags: kong:"help='Queue name'"
	QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty" kong:"help='Queue name'"`
	// @gotags: kong:"help='Remote AWS account ID',optional"
	RemoteAccountId string `` /* 153-byte string literal not displayed */
	// @gotags: kong:"help='How many seconds to delay message delivery by',default=0"
	DelaySeconds int64 `` /* 168-byte string literal not displayed */
	// @gotags: kong:"help='Add optional attributes to outgoing message (assign: k=v delimit: ;)'"
	Attributes map[string]string `` /* 244-byte string literal not displayed */
	// @gotags: kong:"help='Message Group ID. For FIFO queues only'"
	MessageGroupId string `` /* 158-byte string literal not displayed */
	// @gotags: kong:"help='Required when publishing to a FIFO queue that does not have content based deduplication enabled'"
	MessageDeduplicationId string `` /* 239-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AWSSQSWriteArgs) Descriptor deprecated added in v0.0.47 

func (*AWSSQSWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use AWSSQSWriteArgs.ProtoReflect.Descriptor instead.

func (*AWSSQSWriteArgs) GetAttributes added in v0.0.47 

func (x *AWSSQSWriteArgs) GetAttributes() map[string]string

func (*AWSSQSWriteArgs) GetDelaySeconds added in v0.0.47 

func (x *AWSSQSWriteArgs) GetDelaySeconds() int64

func (*AWSSQSWriteArgs) GetMessageDeduplicationId added in v0.0.47 

func (x *AWSSQSWriteArgs) GetMessageDeduplicationId() string

func (*AWSSQSWriteArgs) GetMessageGroupId added in v0.0.47 

func (x *AWSSQSWriteArgs) GetMessageGroupId() string

func (*AWSSQSWriteArgs) GetQueueName added in v0.0.47 

func (x *AWSSQSWriteArgs) GetQueueName() string

func (*AWSSQSWriteArgs) GetRemoteAccountId added in v0.0.47 

func (x *AWSSQSWriteArgs) GetRemoteAccountId() string

func (*AWSSQSWriteArgs) ProtoMessage added in v0.0.47 

func (*AWSSQSWriteArgs) ProtoMessage()

func (*AWSSQSWriteArgs) ProtoReflect added in v0.0.181 

func (x *AWSSQSWriteArgs) ProtoReflect() protoreflect.Message

func (*AWSSQSWriteArgs) Reset added in v0.0.47 

func (x *AWSSQSWriteArgs) Reset()

func (*AWSSQSWriteArgs) String added in v0.0.47 

func (x *AWSSQSWriteArgs) String() string

type ActiveMQConn added in v0.0.46 

type ActiveMQConn struct {

	// @gotags: kong:"help='Destination host address',required,default=localhost:61613"
	Address string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ActiveMQConn) Descriptor deprecated added in v0.0.46 

func (*ActiveMQConn) Descriptor() ([]byte, []int)

Deprecated: Use ActiveMQConn.ProtoReflect.Descriptor instead.

func (*ActiveMQConn) GetAddress added in v0.0.46 

func (x *ActiveMQConn) GetAddress() string

func (*ActiveMQConn) ProtoMessage added in v0.0.46 

func (*ActiveMQConn) ProtoMessage()

func (*ActiveMQConn) ProtoReflect added in v0.0.181 

func (x *ActiveMQConn) ProtoReflect() protoreflect.Message

func (*ActiveMQConn) Reset added in v0.0.46 

func (x *ActiveMQConn) Reset()

func (*ActiveMQConn) String added in v0.0.46 

func (x *ActiveMQConn) String() string

type ActiveMQReadArgs added in v0.0.47 

type ActiveMQReadArgs struct {

	// @gotags: kong:"help='Topic to read message(s) from',xor=activemq_read"
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic to read message(s) from',xor=activemq_read"`
	// @gotags: kong:'help='Queue to read message(s) from',xor=activemq_read"
	Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

func (*ActiveMQReadArgs) Descriptor deprecated added in v0.0.47 

func (*ActiveMQReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use ActiveMQReadArgs.ProtoReflect.Descriptor instead.

func (*ActiveMQReadArgs) GetQueue added in v0.0.47 

func (x *ActiveMQReadArgs) GetQueue() string

func (*ActiveMQReadArgs) GetTopic added in v0.0.47 

func (x *ActiveMQReadArgs) GetTopic() string

func (*ActiveMQReadArgs) ProtoMessage added in v0.0.47 

func (*ActiveMQReadArgs) ProtoMessage()

func (*ActiveMQReadArgs) ProtoReflect added in v0.0.181 

func (x *ActiveMQReadArgs) ProtoReflect() protoreflect.Message

func (*ActiveMQReadArgs) Reset added in v0.0.47 

func (x *ActiveMQReadArgs) Reset()

func (*ActiveMQReadArgs) String added in v0.0.47 

func (x *ActiveMQReadArgs) String() string

type ActiveMQWriteArgs added in v0.0.47 

type ActiveMQWriteArgs struct {

	// @gotags: kong:"help='Topic to write message(s) to',xor=activemq_write"
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic to write message(s) to',xor=activemq_write"`
	// @gotags: kong:'help='Queue to write message(s) to',xor=activemq_write"
	Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

func (*ActiveMQWriteArgs) Descriptor deprecated added in v0.0.47 

func (*ActiveMQWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use ActiveMQWriteArgs.ProtoReflect.Descriptor instead.

func (*ActiveMQWriteArgs) GetQueue added in v0.0.47 

func (x *ActiveMQWriteArgs) GetQueue() string

func (*ActiveMQWriteArgs) GetTopic added in v0.0.47 

func (x *ActiveMQWriteArgs) GetTopic() string

func (*ActiveMQWriteArgs) ProtoMessage added in v0.0.47 

func (*ActiveMQWriteArgs) ProtoMessage()

func (*ActiveMQWriteArgs) ProtoReflect added in v0.0.181 

func (x *ActiveMQWriteArgs) ProtoReflect() protoreflect.Message

func (*ActiveMQWriteArgs) Reset added in v0.0.47 

func (x *ActiveMQWriteArgs) Reset()

func (*ActiveMQWriteArgs) String added in v0.0.47 

func (x *ActiveMQWriteArgs) String() string

type AzureEventHubConn added in v0.0.46 

type AzureEventHubConn struct {

	// @gotags: kong:"help='Connection string',env='EVENTHUB_CONNECTION_STRING',required"
	ConnectionString string `` /* 183-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AzureEventHubConn) Descriptor deprecated added in v0.0.46 

func (*AzureEventHubConn) Descriptor() ([]byte, []int)

Deprecated: Use AzureEventHubConn.ProtoReflect.Descriptor instead.

func (*AzureEventHubConn) GetConnectionString added in v0.0.46 

func (x *AzureEventHubConn) GetConnectionString() string

func (*AzureEventHubConn) ProtoMessage added in v0.0.46 

func (*AzureEventHubConn) ProtoMessage()

func (*AzureEventHubConn) ProtoReflect added in v0.0.181 

func (x *AzureEventHubConn) ProtoReflect() protoreflect.Message

func (*AzureEventHubConn) Reset added in v0.0.46 

func (x *AzureEventHubConn) Reset()

func (*AzureEventHubConn) String added in v0.0.46 

func (x *AzureEventHubConn) String() string

type AzureEventHubReadArgs added in v0.0.47 

type AzureEventHubReadArgs struct {
	// contains filtered or unexported fields
}

func (*AzureEventHubReadArgs) Descriptor deprecated added in v0.0.47 

func (*AzureEventHubReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use AzureEventHubReadArgs.ProtoReflect.Descriptor instead.

func (*AzureEventHubReadArgs) ProtoMessage added in v0.0.47 

func (*AzureEventHubReadArgs) ProtoMessage()

func (*AzureEventHubReadArgs) ProtoReflect added in v0.0.181 

func (x *AzureEventHubReadArgs) ProtoReflect() protoreflect.Message

func (*AzureEventHubReadArgs) Reset added in v0.0.47 

func (x *AzureEventHubReadArgs) Reset()

func (*AzureEventHubReadArgs) String added in v0.0.47 

func (x *AzureEventHubReadArgs) String() string

type AzureEventHubWriteArgs added in v0.0.47 

type AzureEventHubWriteArgs struct {

	// @gotags: kong:"help='Send message with this ID'"
	MessageId string `` /* 128-byte string literal not displayed */
	// @gotags: kong:"help='Send message with this partition key'"
	PartitionKey string `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AzureEventHubWriteArgs) Descriptor deprecated added in v0.0.47 

func (*AzureEventHubWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use AzureEventHubWriteArgs.ProtoReflect.Descriptor instead.

func (*AzureEventHubWriteArgs) GetMessageId added in v0.0.47 

func (x *AzureEventHubWriteArgs) GetMessageId() string

func (*AzureEventHubWriteArgs) GetPartitionKey added in v0.0.47 

func (x *AzureEventHubWriteArgs) GetPartitionKey() string

func (*AzureEventHubWriteArgs) ProtoMessage added in v0.0.47 

func (*AzureEventHubWriteArgs) ProtoMessage()

func (*AzureEventHubWriteArgs) ProtoReflect added in v0.0.181 

func (x *AzureEventHubWriteArgs) ProtoReflect() protoreflect.Message

func (*AzureEventHubWriteArgs) Reset added in v0.0.47 

func (x *AzureEventHubWriteArgs) Reset()

func (*AzureEventHubWriteArgs) String added in v0.0.47 

func (x *AzureEventHubWriteArgs) String() string

type AzureServiceBusConn added in v0.0.46 

type AzureServiceBusConn struct {

	// NOTE: This is an azure-defined env var
	// @gotags: kong:"help='Connection string',env='SERVICEBUS_CONNECTION_STRING',required"
	ConnectionString string `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AzureServiceBusConn) Descriptor deprecated added in v0.0.46 

func (*AzureServiceBusConn) Descriptor() ([]byte, []int)

Deprecated: Use AzureServiceBusConn.ProtoReflect.Descriptor instead.

func (*AzureServiceBusConn) GetConnectionString added in v0.0.46 

func (x *AzureServiceBusConn) GetConnectionString() string

func (*AzureServiceBusConn) ProtoMessage added in v0.0.46 

func (*AzureServiceBusConn) ProtoMessage()

func (*AzureServiceBusConn) ProtoReflect added in v0.0.181 

func (x *AzureServiceBusConn) ProtoReflect() protoreflect.Message

func (*AzureServiceBusConn) Reset added in v0.0.46 

func (x *AzureServiceBusConn) Reset()

func (*AzureServiceBusConn) String added in v0.0.46 

func (x *AzureServiceBusConn) String() string

type AzureServiceBusReadArgs added in v0.0.47 

type AzureServiceBusReadArgs struct {

	// @gotags: kong:"help='Queue name',env='PLUMBER_RELAY_AZURE_QUEUE_NAME',xor=asb_read"
	Queue string `` /* 138-byte string literal not displayed */
	// @gotags: kong:"help='Topic name',env='PLUMBER_RELAY_AZURE_TOPIC_NAME',xor=asb_read"
	Topic string `` /* 138-byte string literal not displayed */
	// @gotags: kong:"help='Subscription name',env='PLUMBER_RELAY_AZURE_SUBSCRIPTION',required"
	SubscriptionName string `` /* 189-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AzureServiceBusReadArgs) Descriptor deprecated added in v0.0.47 

func (*AzureServiceBusReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use AzureServiceBusReadArgs.ProtoReflect.Descriptor instead.

func (*AzureServiceBusReadArgs) GetQueue added in v0.0.47 

func (x *AzureServiceBusReadArgs) GetQueue() string

func (*AzureServiceBusReadArgs) GetSubscriptionName added in v0.0.47 

func (x *AzureServiceBusReadArgs) GetSubscriptionName() string

func (*AzureServiceBusReadArgs) GetTopic added in v0.0.47 

func (x *AzureServiceBusReadArgs) GetTopic() string

func (*AzureServiceBusReadArgs) ProtoMessage added in v0.0.47 

func (*AzureServiceBusReadArgs) ProtoMessage()

func (*AzureServiceBusReadArgs) ProtoReflect added in v0.0.181 

func (x *AzureServiceBusReadArgs) ProtoReflect() protoreflect.Message

func (*AzureServiceBusReadArgs) Reset added in v0.0.47 

func (x *AzureServiceBusReadArgs) Reset()

func (*AzureServiceBusReadArgs) String added in v0.0.47 

func (x *AzureServiceBusReadArgs) String() string

type AzureServiceBusWriteArgs added in v0.0.47 

type AzureServiceBusWriteArgs struct {

	// @gotags: kong:"help='Queue name',xor=asb_write"
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty" kong:"help='Queue name',xor=asb_write"`
	// @gotags: kong:"help='Topic name',xor=asb_write"
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic name',xor=asb_write"`
	// contains filtered or unexported fields
}

func (*AzureServiceBusWriteArgs) Descriptor deprecated added in v0.0.47 

func (*AzureServiceBusWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use AzureServiceBusWriteArgs.ProtoReflect.Descriptor instead.

func (*AzureServiceBusWriteArgs) GetQueue added in v0.0.47 

func (x *AzureServiceBusWriteArgs) GetQueue() string

func (*AzureServiceBusWriteArgs) GetTopic added in v0.0.47 

func (x *AzureServiceBusWriteArgs) GetTopic() string

func (*AzureServiceBusWriteArgs) ProtoMessage added in v0.0.47 

func (*AzureServiceBusWriteArgs) ProtoMessage()

func (*AzureServiceBusWriteArgs) ProtoReflect added in v0.0.181 

func (x *AzureServiceBusWriteArgs) ProtoReflect() protoreflect.Message

func (*AzureServiceBusWriteArgs) Reset added in v0.0.47 

func (x *AzureServiceBusWriteArgs) Reset()

func (*AzureServiceBusWriteArgs) String added in v0.0.47 

func (x *AzureServiceBusWriteArgs) String() string

type CreateConsumerConfig added in v0.0.46 

type CreateConsumerConfig struct {

	// @gotags: kong:"help='Create the streams if creating a new consumer group',env='PLUMBER_RELAY_REDIS_STREAMS_CREATE_STREAMS'"
	CreateStreams bool `` /* 216-byte string literal not displayed */
	// @gotags: kong:"help='Recreate this consumer group if it does not exist',env='PLUMBER_RELAY_REDIS_STREAMS_RECREATE_CONSUMER_GROUP'"
	RecreateConsumerGroup bool `` /* 249-byte string literal not displayed */
	// @gotags: kong:"help='What offset to start reading at (options: latest oldest)',default=latest,required,env='PLUMBER_RELAY_REDIS_STREAMS_START_ID',type=pbenum,pbenum_lowercase"
	OffsetStart OffsetStart `` /* 291-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateConsumerConfig) Descriptor deprecated added in v0.0.46 

func (*CreateConsumerConfig) Descriptor() ([]byte, []int)

Deprecated: Use CreateConsumerConfig.ProtoReflect.Descriptor instead.

func (*CreateConsumerConfig) GetCreateStreams added in v0.0.46 

func (x *CreateConsumerConfig) GetCreateStreams() bool

func (*CreateConsumerConfig) GetOffsetStart added in v0.0.46 

func (x *CreateConsumerConfig) GetOffsetStart() OffsetStart

func (*CreateConsumerConfig) GetRecreateConsumerGroup added in v0.0.46 

func (x *CreateConsumerConfig) GetRecreateConsumerGroup() bool

func (*CreateConsumerConfig) ProtoMessage added in v0.0.46 

func (*CreateConsumerConfig) ProtoMessage()

func (*CreateConsumerConfig) ProtoReflect added in v0.0.181 

func (x *CreateConsumerConfig) ProtoReflect() protoreflect.Message

func (*CreateConsumerConfig) Reset added in v0.0.46 

func (x *CreateConsumerConfig) Reset()

func (*CreateConsumerConfig) String added in v0.0.46 

func (x *CreateConsumerConfig) String() string

type GCPPubSubConn added in v0.0.46 

type GCPPubSubConn struct {

	// @gotags: kong:"help='Project ID',env='PLUMBER_RELAY_GCP_PROJECT_ID',required"
	ProjectId string `` /* 157-byte string literal not displayed */
	// @gotags: kong:"help='GCP Credentials in JSON format',env='PLUMBER_RELAY_GCP_CREDENTIALS'"
	CredentialsJson string `` /* 187-byte string literal not displayed */
	// @gotags: kong:"help='Path to GCP credentials JSON file',env='GOOGLE_APPLICATION_CREDENTIALS'"
	CredentialsFile string `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GCPPubSubConn) Descriptor deprecated added in v0.0.46 

func (*GCPPubSubConn) Descriptor() ([]byte, []int)

Deprecated: Use GCPPubSubConn.ProtoReflect.Descriptor instead.

func (*GCPPubSubConn) GetCredentialsFile added in v0.0.97 

func (x *GCPPubSubConn) GetCredentialsFile() string

func (*GCPPubSubConn) GetCredentialsJson added in v0.0.97 

func (x *GCPPubSubConn) GetCredentialsJson() string

func (*GCPPubSubConn) GetProjectId added in v0.0.46 

func (x *GCPPubSubConn) GetProjectId() string

func (*GCPPubSubConn) ProtoMessage added in v0.0.46 

func (*GCPPubSubConn) ProtoMessage()

func (*GCPPubSubConn) ProtoReflect added in v0.0.181 

func (x *GCPPubSubConn) ProtoReflect() protoreflect.Message

func (*GCPPubSubConn) Reset added in v0.0.46 

func (x *GCPPubSubConn) Reset()

func (*GCPPubSubConn) String added in v0.0.46 

func (x *GCPPubSubConn) String() string

type GCPPubSubReadArgs added in v0.0.47 

type GCPPubSubReadArgs struct {

	// @gotags: kong:"help='Subscription ID',env='PLUMBER_RELAY_GCP_SUBSCRIPTION_ID',required"
	SubscriptionId string `` /* 182-byte string literal not displayed */
	// @gotags: kong:"help='Whether to acknowledge message receive',env='PLUMBER_RELAY_GCP_ACK_MESSAGE',default=true"
	AckMessages bool `` /* 197-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GCPPubSubReadArgs) Descriptor deprecated added in v0.0.47 

func (*GCPPubSubReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use GCPPubSubReadArgs.ProtoReflect.Descriptor instead.

func (*GCPPubSubReadArgs) GetAckMessages added in v0.0.47 

func (x *GCPPubSubReadArgs) GetAckMessages() bool

func (*GCPPubSubReadArgs) GetSubscriptionId added in v0.0.47 

func (x *GCPPubSubReadArgs) GetSubscriptionId() string

func (*GCPPubSubReadArgs) ProtoMessage added in v0.0.47 

func (*GCPPubSubReadArgs) ProtoMessage()

func (*GCPPubSubReadArgs) ProtoReflect added in v0.0.181 

func (x *GCPPubSubReadArgs) ProtoReflect() protoreflect.Message

func (*GCPPubSubReadArgs) Reset added in v0.0.47 

func (x *GCPPubSubReadArgs) Reset()

func (*GCPPubSubReadArgs) String added in v0.0.47 

func (x *GCPPubSubReadArgs) String() string

type GCPPubSubWriteArgs added in v0.0.47 

type GCPPubSubWriteArgs struct {

	// @gotags: kong:"help='Topic ID to publish message(s) to',required"
	TopicId string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GCPPubSubWriteArgs) Descriptor deprecated added in v0.0.47 

func (*GCPPubSubWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use GCPPubSubWriteArgs.ProtoReflect.Descriptor instead.

func (*GCPPubSubWriteArgs) GetTopicId added in v0.0.47 

func (x *GCPPubSubWriteArgs) GetTopicId() string

func (*GCPPubSubWriteArgs) ProtoMessage added in v0.0.47 

func (*GCPPubSubWriteArgs) ProtoMessage()

func (*GCPPubSubWriteArgs) ProtoReflect added in v0.0.181 

func (x *GCPPubSubWriteArgs) ProtoReflect() protoreflect.Message

func (*GCPPubSubWriteArgs) Reset added in v0.0.47 

func (x *GCPPubSubWriteArgs) Reset()

func (*GCPPubSubWriteArgs) String added in v0.0.47 

func (x *GCPPubSubWriteArgs) String() string

type KafkaConn added in v0.0.46 

type KafkaConn struct {

	// @gotags: kong:"help='Kafka broker address (you may specify this flag multiple times)',env=PLUMBER_RELAY_KAFKA_ADDRESS,default='localhost:9092',required"
	Address []string `` /* 211-byte string literal not displayed */
	// @gotags: kong:"help='Connect timeout',env=PLUMBER_RELAY_TIMEOUT_SECONDS,default=10"
	TimeoutSeconds int32 `` /* 179-byte string literal not displayed */
	// @gotags: kong:"help='Enable TLS usage',env=PLUMBER_RELAY_USE_TLS"
	UseTls bool `` /* 137-byte string literal not displayed */
	// @gotags: kong:"help='Allow insecure TLS usage',env=PLUMBER_RELAY_KAFKA_INSECURE_TLS"
	TlsSkipVerify bool `` /* 179-byte string literal not displayed */
	// @gotags: kong:"help='SASL authentication type (options: none plain scram)',env=PLUMBER_RELAY_KAFKA_SASL_TYPE,type=pbenum,pbenum_lowercase,default=none"
	SaslType SASLType `` /* 255-byte string literal not displayed */
	// @gotags: kong:"help='SASL Username',env=PLUMBER_RELAY_KAFKA_USERNAME"
	SaslUsername string `` /* 158-byte string literal not displayed */
	// Required if sasl_type is not NONE
	// @gotags: kong:"help='SASL Password. You will be prompted for the password if omitted',env=PLUMBER_RELAY_KAFKA_PASSWORD"
	SaslPassword string `` /* 208-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*KafkaConn) Descriptor deprecated added in v0.0.46 

func (*KafkaConn) Descriptor() ([]byte, []int)

Deprecated: Use KafkaConn.ProtoReflect.Descriptor instead.

func (*KafkaConn) GetAddress added in v0.0.46 

func (x *KafkaConn) GetAddress() []string

func (*KafkaConn) GetSaslPassword added in v0.0.46 

func (x *KafkaConn) GetSaslPassword() string

func (*KafkaConn) GetSaslType added in v0.0.46 

func (x *KafkaConn) GetSaslType() SASLType

func (*KafkaConn) GetSaslUsername added in v0.0.46 

func (x *KafkaConn) GetSaslUsername() string

func (*KafkaConn) GetTimeoutSeconds added in v0.0.46 

func (x *KafkaConn) GetTimeoutSeconds() int32

func (*KafkaConn) GetTlsSkipVerify added in v0.0.114 

func (x *KafkaConn) GetTlsSkipVerify() bool

func (*KafkaConn) GetUseTls added in v0.0.46 

func (x *KafkaConn) GetUseTls() bool

func (*KafkaConn) ProtoMessage added in v0.0.46 

func (*KafkaConn) ProtoMessage()

func (*KafkaConn) ProtoReflect added in v0.0.181 

func (x *KafkaConn) ProtoReflect() protoreflect.Message

func (*KafkaConn) Reset added in v0.0.46 

func (x *KafkaConn) Reset()

func (*KafkaConn) String added in v0.0.46 

func (x *KafkaConn) String() string

type KafkaReadArgs added in v0.0.47 

type KafkaReadArgs struct {

	// @gotags: kong:"help='Topic(s) to read from',required"
	Topics []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty" kong:"help='Topic(s) to read from',required"`
	// @gotags: kong:"help='Specify what offset the consumer should read from (only works if --use-consumer-group is false)',default=0"
	ReadOffset int64 `` /* 212-byte string literal not displayed */
	// @gotags: kong:"help='Whether plumber should use a consumer group',default=true"
	UseConsumerGroup bool `` /* 183-byte string literal not displayed */
	// @gotags: kong:"help='Specify a specific group-id to use when reading from kafka',default=plumber"
	ConsumerGroupName string `` /* 203-byte string literal not displayed */
	// @gotags: kong:"help='How long to wait for new data when reading batches of messages',default=1"
	MaxWaitSeconds int32 `` /* 193-byte string literal not displayed */
	// @gotags: kong:"help='Minimum number of bytes to fetch in a single kafka request (throughput optimization)',default=1"
	MinBytes int32 `` /* 195-byte string literal not displayed */
	// @gotags: kong:"help='Maximum number of bytes to fetch in a single kafka request (throughput optimization)',default=1"
	MaxBytes int32 `` /* 195-byte string literal not displayed */
	// @gotags: kong:"help='How often to commit offsets to broker (0 = synchronous)',default=5"
	CommitIntervalSeconds int32 `` /* 207-byte string literal not displayed */
	// @gotags: kong:"help='How long a coordinator will wait for member joins as part of a rebalance',default=0"
	RebalanceTimeoutSeconds int32 `` /* 230-byte string literal not displayed */
	// @gotags: kong:"help='Internal library queue capacity (throughput optimization)',default=1"
	QueueCapacity int32 `` /* 184-byte string literal not displayed */
	// @gotags: kong:"help='Display consumer offset stats during read'"
	IncludeOffsetInfo bool `` /* 172-byte string literal not displayed */
	// @gotags: kong:"help='Only lookup consumer group lag',group=lag"
	Lag bool `protobuf:"varint,12,opt,name=lag,proto3" json:"lag,omitempty" kong:"help='Only lookup consumer group lag',group=lag"`
	// @gotags: kong:"help='What consumer group to lookup lag for (required if --lag is set)',group=lag"
	LagConsumerGroup string `` /* 201-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*KafkaReadArgs) Descriptor deprecated added in v0.0.47 

func (*KafkaReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use KafkaReadArgs.ProtoReflect.Descriptor instead.

func (*KafkaReadArgs) GetCommitIntervalSeconds added in v0.0.47 

func (x *KafkaReadArgs) GetCommitIntervalSeconds() int32

func (*KafkaReadArgs) GetConsumerGroupName added in v0.0.47 

func (x *KafkaReadArgs) GetConsumerGroupName() string

func (*KafkaReadArgs) GetIncludeOffsetInfo added in v0.0.51 

func (x *KafkaReadArgs) GetIncludeOffsetInfo() bool

func (*KafkaReadArgs) GetLag added in v0.0.51 

func (x *KafkaReadArgs) GetLag() bool

func (*KafkaReadArgs) GetLagConsumerGroup added in v0.0.51 

func (x *KafkaReadArgs) GetLagConsumerGroup() string

func (*KafkaReadArgs) GetMaxBytes added in v0.0.47 

func (x *KafkaReadArgs) GetMaxBytes() int32

func (*KafkaReadArgs) GetMaxWaitSeconds added in v0.0.47 

func (x *KafkaReadArgs) GetMaxWaitSeconds() int32

func (*KafkaReadArgs) GetMinBytes added in v0.0.47 

func (x *KafkaReadArgs) GetMinBytes() int32

func (*KafkaReadArgs) GetQueueCapacity added in v0.0.47 

func (x *KafkaReadArgs) GetQueueCapacity() int32

func (*KafkaReadArgs) GetReadOffset added in v0.0.47 

func (x *KafkaReadArgs) GetReadOffset() int64

func (*KafkaReadArgs) GetRebalanceTimeoutSeconds added in v0.0.47 

func (x *KafkaReadArgs) GetRebalanceTimeoutSeconds() int32

func (*KafkaReadArgs) GetTopics added in v0.0.47 

func (x *KafkaReadArgs) GetTopics() []string

func (*KafkaReadArgs) GetUseConsumerGroup added in v0.0.47 

func (x *KafkaReadArgs) GetUseConsumerGroup() bool

func (*KafkaReadArgs) ProtoMessage added in v0.0.47 

func (*KafkaReadArgs) ProtoMessage()

func (*KafkaReadArgs) ProtoReflect added in v0.0.181 

func (x *KafkaReadArgs) ProtoReflect() protoreflect.Message

func (*KafkaReadArgs) Reset added in v0.0.47 

func (x *KafkaReadArgs) Reset()

func (*KafkaReadArgs) String added in v0.0.47 

func (x *KafkaReadArgs) String() string

type KafkaRelayArgs added in v0.0.47 

type KafkaRelayArgs struct {

	// @gotags: kong:"help='Topic(s) to read, write or get lag stats for',env=PLUMBER_RELAY_KAFKA_TOPIC,required"
	Topics []string `` /* 163-byte string literal not displayed */
	// @gotags: kong:"help='Specify what offset the consumer should read from (only works if --use-consumer-group is false)',env=PLUMBER_RELAY_KAFKA_READ_OFFSET,default=0"
	ReadOffset int64 `` /* 248-byte string literal not displayed */
	// @gotags: kong:"help='Whether plumber should use a consumer group',env=PLUMBER_RELAY_KAFKA_USE_CONSUMER_GROUP,default=true"
	UseConsumerGroup bool `` /* 226-byte string literal not displayed */
	// @gotags: kong:"help='Specify a specific group-id to use when reading from kafka',env=PLUMBER_RELAY_KAFKA_GROUP_ID,default=plumber"
	ConsumerGroupName string `` /* 236-byte string literal not displayed */
	// @gotags: kong:"help='How long to wait for new data when reading batches of messages',env=PLUMBER_RELAY_KAFKA_MAX_WAIT,default=5"
	MaxWaitSeconds int32 `` /* 226-byte string literal not displayed */
	// @gotags: kong:"help='Minimum number of bytes to fetch in a single kafka request (throughput optimization)',env=PLUMBER_RELAY_KAFKA_MIN_BYTES,default=1048576"
	MinBytes int32 `` /* 235-byte string literal not displayed */
	// @gotags: kong:"help='Maximum number of bytes to fetch in a single kafka request (throughput optimization)',env=PLUMBER_RELAY_KAFKA_MAX_BYTES,default=1048576"
	MaxBytes int32 `` /* 235-byte string literal not displayed */
	// @gotags: kong:"help='How often to commit offsets to broker (0 = synchronous)',env=PLUMBER_RELAY_KAFKA_COMMIT_INTERVAL,default=5"
	CommitIntervalSeconds int32 `` /* 247-byte string literal not displayed */
	// @gotags: kong:"help='How long a coordinator will wait for member joins as part of a rebalance',env=PLUMBER_RELAY_KAFKA_REBALANCE_TIMEOUT,default=5"
	RebalanceTimeoutSeconds int32 `` /* 272-byte string literal not displayed */
	// @gotags: kong:"help='Internal library queue capacity (throughput optimization)',env=PLUMBER_RELAY_KAFKA_QUEUE_CAPACITY,default=1000"
	QueueCapacity int32 `` /* 226-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*KafkaRelayArgs) Descriptor deprecated added in v0.0.47 

func (*KafkaRelayArgs) Descriptor() ([]byte, []int)

Deprecated: Use KafkaRelayArgs.ProtoReflect.Descriptor instead.

func (*KafkaRelayArgs) GetCommitIntervalSeconds added in v0.0.47 

func (x *KafkaRelayArgs) GetCommitIntervalSeconds() int32

func (*KafkaRelayArgs) GetConsumerGroupName added in v0.0.47 

func (x *KafkaRelayArgs) GetConsumerGroupName() string

func (*KafkaRelayArgs) GetMaxBytes added in v0.0.47 

func (x *KafkaRelayArgs) GetMaxBytes() int32

func (*KafkaRelayArgs) GetMaxWaitSeconds added in v0.0.47 

func (x *KafkaRelayArgs) GetMaxWaitSeconds() int32

func (*KafkaRelayArgs) GetMinBytes added in v0.0.47 

func (x *KafkaRelayArgs) GetMinBytes() int32

func (*KafkaRelayArgs) GetQueueCapacity added in v0.0.47 

func (x *KafkaRelayArgs) GetQueueCapacity() int32

func (*KafkaRelayArgs) GetReadOffset added in v0.0.47 

func (x *KafkaRelayArgs) GetReadOffset() int64

func (*KafkaRelayArgs) GetRebalanceTimeoutSeconds added in v0.0.47 

func (x *KafkaRelayArgs) GetRebalanceTimeoutSeconds() int32

func (*KafkaRelayArgs) GetTopics added in v0.0.47 

func (x *KafkaRelayArgs) GetTopics() []string

func (*KafkaRelayArgs) GetUseConsumerGroup added in v0.0.47 

func (x *KafkaRelayArgs) GetUseConsumerGroup() bool

func (*KafkaRelayArgs) ProtoMessage added in v0.0.47 

func (*KafkaRelayArgs) ProtoMessage()

func (*KafkaRelayArgs) ProtoReflect added in v0.0.181 

func (x *KafkaRelayArgs) ProtoReflect() protoreflect.Message

func (*KafkaRelayArgs) Reset added in v0.0.47 

func (x *KafkaRelayArgs) Reset()

func (*KafkaRelayArgs) String added in v0.0.47 

func (x *KafkaRelayArgs) String() string

type KafkaWriteArgs added in v0.0.47 

type KafkaWriteArgs struct {

	// @gotags: kong:"help='Key to write to kafka (optional)'"
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty" kong:"help='Key to write to kafka (optional)'"`
	// @gotags: kong:"help='Add one or more headers (optional; repeat flags to specify multiple)'"
	Headers map[string]string `` /* 238-byte string literal not displayed */
	// @gotags: kong:"help='Topic(s) to write to',required"
	Topics []string `protobuf:"bytes,3,rep,name=topics,proto3" json:"topics,omitempty" kong:"help='Topic(s) to write to',required"`
	// contains filtered or unexported fields
}

func (*KafkaWriteArgs) Descriptor deprecated added in v0.0.47 

func (*KafkaWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use KafkaWriteArgs.ProtoReflect.Descriptor instead.

func (*KafkaWriteArgs) GetHeaders added in v0.0.47 

func (x *KafkaWriteArgs) GetHeaders() map[string]string

func (*KafkaWriteArgs) GetKey added in v0.0.47 

func (x *KafkaWriteArgs) GetKey() string

func (*KafkaWriteArgs) GetTopics added in v0.0.52 

func (x *KafkaWriteArgs) GetTopics() []string

func (*KafkaWriteArgs) ProtoMessage added in v0.0.47 

func (*KafkaWriteArgs) ProtoMessage()

func (*KafkaWriteArgs) ProtoReflect added in v0.0.181 

func (x *KafkaWriteArgs) ProtoReflect() protoreflect.Message

func (*KafkaWriteArgs) Reset added in v0.0.47 

func (x *KafkaWriteArgs) Reset()

func (*KafkaWriteArgs) String added in v0.0.47 

func (x *KafkaWriteArgs) String() string

type KubeMQQueueConn added in v0.0.46 

type KubeMQQueueConn struct {

	// @gotags: kong:"help='Dial string for KubeMQ server',env='PLUMBER_RELAY_KUBEMQ_QUEUE_ADDRESS',default='localhost:50000',required"
	Address string `` /* 187-byte string literal not displayed */
	// @gotags: kong:"help='Client JWT authentication token',env='PLUMBER_RELAY_KUBEMQ_QUEUE_AUTH_TOKEN'"
	AuthToken string `` /* 178-byte string literal not displayed */
	// @gotags: kong:"help='KubeMQ client cert file',env='PLUMBER_RELAY_KUBEMQ_QUEUE_TLS_CLIENT_CERT'"
	TlsClientCert string `` /* 189-byte string literal not displayed */
	// @gotags: kong:"help='KubeMQ client ID',env='PLUMBER_RELAY_KUBEMQ_QUEUE_CLIENT_ID',default=plumber"
	ClientId string `` /* 175-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*KubeMQQueueConn) Descriptor deprecated added in v0.0.46 

func (*KubeMQQueueConn) Descriptor() ([]byte, []int)

Deprecated: Use KubeMQQueueConn.ProtoReflect.Descriptor instead.

func (*KubeMQQueueConn) GetAddress added in v0.0.46 

func (x *KubeMQQueueConn) GetAddress() string

func (*KubeMQQueueConn) GetAuthToken added in v0.0.46 

func (x *KubeMQQueueConn) GetAuthToken() string

func (*KubeMQQueueConn) GetClientId added in v0.0.101 

func (x *KubeMQQueueConn) GetClientId() string

func (*KubeMQQueueConn) GetTlsClientCert added in v0.0.114 

func (x *KubeMQQueueConn) GetTlsClientCert() string

func (*KubeMQQueueConn) ProtoMessage added in v0.0.46 

func (*KubeMQQueueConn) ProtoMessage()

func (*KubeMQQueueConn) ProtoReflect added in v0.0.181 

func (x *KubeMQQueueConn) ProtoReflect() protoreflect.Message

func (*KubeMQQueueConn) Reset added in v0.0.46 

func (x *KubeMQQueueConn) Reset()

func (*KubeMQQueueConn) String added in v0.0.46 

func (x *KubeMQQueueConn) String() string

type KubeMQQueueReadArgs added in v0.0.47 

type KubeMQQueueReadArgs struct {

	// @gotags: kong:"help='KubeMQ queue name',env='PLUMBER_RELAY_KUBEMQ_QUEUE_QUEUE'"
	QueueName string `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*KubeMQQueueReadArgs) Descriptor deprecated added in v0.0.47 

func (*KubeMQQueueReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use KubeMQQueueReadArgs.ProtoReflect.Descriptor instead.

func (*KubeMQQueueReadArgs) GetQueueName added in v0.0.47 

func (x *KubeMQQueueReadArgs) GetQueueName() string

func (*KubeMQQueueReadArgs) ProtoMessage added in v0.0.47 

func (*KubeMQQueueReadArgs) ProtoMessage()

func (*KubeMQQueueReadArgs) ProtoReflect added in v0.0.181 

func (x *KubeMQQueueReadArgs) ProtoReflect() protoreflect.Message

func (*KubeMQQueueReadArgs) Reset added in v0.0.47 

func (x *KubeMQQueueReadArgs) Reset()

func (*KubeMQQueueReadArgs) String added in v0.0.47 

func (x *KubeMQQueueReadArgs) String() string

type KubeMQQueueWriteArgs added in v0.0.47 

type KubeMQQueueWriteArgs struct {

	// @gotags: kong:"help='KubeMQ queue name'"
	QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty" kong:"help='KubeMQ queue name'"`
	// contains filtered or unexported fields
}

func (*KubeMQQueueWriteArgs) Descriptor deprecated added in v0.0.47 

func (*KubeMQQueueWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use KubeMQQueueWriteArgs.ProtoReflect.Descriptor instead.

func (*KubeMQQueueWriteArgs) GetQueueName added in v0.0.47 

func (x *KubeMQQueueWriteArgs) GetQueueName() string

func (*KubeMQQueueWriteArgs) ProtoMessage added in v0.0.47 

func (*KubeMQQueueWriteArgs) ProtoMessage()

func (*KubeMQQueueWriteArgs) ProtoReflect added in v0.0.181 

func (x *KubeMQQueueWriteArgs) ProtoReflect() protoreflect.Message

func (*KubeMQQueueWriteArgs) Reset added in v0.0.47 

func (x *KubeMQQueueWriteArgs) Reset()

func (*KubeMQQueueWriteArgs) String added in v0.0.47 

func (x *KubeMQQueueWriteArgs) String() string

type MQTTConn added in v0.0.46 

type MQTTConn struct {

	// @gotags: kong:"help='MQTT address',default='tcp://localhost:1883',env='PLUMBER_RELAY_MQTT_ADDRESS',required"
	Address string `` /* 167-byte string literal not displayed */
	// @gotags: kong:"help='How long to attempt to connect for',env='PLUMBER_RELAY_MQTT_CONNECT_TIMEOUT',default=5"
	ConnTimeoutSeconds uint32 `` /* 218-byte string literal not displayed */
	// @gotags: kong:"help='Client id presented to MQTT broker',env='PLUMBER_RELAY_MQTT_CLIENT_ID',default=plumber"
	ClientId string `` /* 185-byte string literal not displayed */
	// @gotags: kong:"help='QoS level to use for pub/sub (options: at_most_once, at_least_once, exactly_once)',env=PLUMBER_RELAY_MQTT_QOS,type=pbenum,pbenum_strip_prefix=MQTT_QOS_LEVEL_,pbenum_lowercase,default=at_most_once"
	QosLevel MQTTQoSLevel `` /* 325-byte string literal not displayed */
	// @gotags: kong:"embed"
	TlsOptions *MQTTTLSOptions `protobuf:"bytes,6,opt,name=tls_options,json=tlsOptions,proto3" json:"tls_options,omitempty" kong:"embed"`
	// contains filtered or unexported fields
}

func (*MQTTConn) Descriptor deprecated added in v0.0.46 

func (*MQTTConn) Descriptor() ([]byte, []int)

Deprecated: Use MQTTConn.ProtoReflect.Descriptor instead.

func (*MQTTConn) GetAddress added in v0.0.46 

func (x *MQTTConn) GetAddress() string

func (*MQTTConn) GetClientId added in v0.0.46 

func (x *MQTTConn) GetClientId() string

func (*MQTTConn) GetConnTimeoutSeconds added in v0.0.46 

func (x *MQTTConn) GetConnTimeoutSeconds() uint32

func (*MQTTConn) GetQosLevel added in v0.0.46 

func (x *MQTTConn) GetQosLevel() MQTTQoSLevel

func (*MQTTConn) GetTlsOptions added in v0.0.46 

func (x *MQTTConn) GetTlsOptions() *MQTTTLSOptions

func (*MQTTConn) ProtoMessage added in v0.0.46 

func (*MQTTConn) ProtoMessage()

func (*MQTTConn) ProtoReflect added in v0.0.181 

func (x *MQTTConn) ProtoReflect() protoreflect.Message

func (*MQTTConn) Reset added in v0.0.46 

func (x *MQTTConn) Reset()

func (*MQTTConn) String added in v0.0.46 

func (x *MQTTConn) String() string

type MQTTQoSLevel added in v0.0.46 

type MQTTQoSLevel int32
const (
	MQTTQoSLevel_MQTT_QOS_LEVEL_AT_MOST_ONCE  MQTTQoSLevel = 0
	MQTTQoSLevel_MQTT_QOS_LEVEL_AT_LEAST_ONCE MQTTQoSLevel = 1
	MQTTQoSLevel_MQTT_QOS_LEVEL_EXACTLY_ONCE  MQTTQoSLevel = 2
)

func (MQTTQoSLevel) Descriptor added in v0.0.181 

func (MQTTQoSLevel) Descriptor() protoreflect.EnumDescriptor

func (MQTTQoSLevel) Enum added in v0.0.181 

func (x MQTTQoSLevel) Enum() *MQTTQoSLevel

func (MQTTQoSLevel) EnumDescriptor deprecated added in v0.0.46 

func (MQTTQoSLevel) EnumDescriptor() ([]byte, []int)

Deprecated: Use MQTTQoSLevel.Descriptor instead.

func (MQTTQoSLevel) Number added in v0.0.181 

func (x MQTTQoSLevel) Number() protoreflect.EnumNumber

func (MQTTQoSLevel) String added in v0.0.46 

func (x MQTTQoSLevel) String() string

func (MQTTQoSLevel) Type added in v0.0.181 

func (MQTTQoSLevel) Type() protoreflect.EnumType

type MQTTReadArgs added in v0.0.47 

type MQTTReadArgs struct {

	// @gotags: kong:"help='Topic to read message(s) from',env='PLUMBER_RELAY_MQTT_TOPIC',required"
	Topic string `` /* 147-byte string literal not displayed */
	// @gotags: kong:"help='How long to attempt to read message(s)',default=0,env='PLUMBER_RELAY_MQTT_READ_TIMEOUT_SECONDS'"
	ReadTimeoutSeconds uint32 `` /* 227-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MQTTReadArgs) Descriptor deprecated added in v0.0.47 

func (*MQTTReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use MQTTReadArgs.ProtoReflect.Descriptor instead.

func (*MQTTReadArgs) GetReadTimeoutSeconds added in v0.0.47 

func (x *MQTTReadArgs) GetReadTimeoutSeconds() uint32

func (*MQTTReadArgs) GetTopic added in v0.0.47 

func (x *MQTTReadArgs) GetTopic() string

func (*MQTTReadArgs) ProtoMessage added in v0.0.47 

func (*MQTTReadArgs) ProtoMessage()

func (*MQTTReadArgs) ProtoReflect added in v0.0.181 

func (x *MQTTReadArgs) ProtoReflect() protoreflect.Message

func (*MQTTReadArgs) Reset added in v0.0.47 

func (x *MQTTReadArgs) Reset()

func (*MQTTReadArgs) String added in v0.0.47 

func (x *MQTTReadArgs) String() string

type MQTTTLSOptions added in v0.0.46 

type MQTTTLSOptions struct {

	// @gotags: kong:"help='CA cert (only needed if addr is ssl://)',env=PLUMBER_RELAY_MQTT_TLS_CA_CERT"
	TlsCaCert string `` /* 179-byte string literal not displayed */
	// @gotags: kong:"help='Client cert file (only needed if addr is ssl://)',env=PLUMBER_RELAY_MQTT_TLS_CLIENT_CERT"
	TlsClientCert string `` /* 204-byte string literal not displayed */
	// @gotags: kong:"help='Client key file (only needed if addr is ssl://)',env=PLUMBER_RELAY_MQTT_TLS_CLIENT_KEY"
	TlsClientKey string `` /* 199-byte string literal not displayed */
	// @gotags: kong:"help='Whether to verify server certificate',env=PLUMBER_RELAY_MQTT_SKIP_VERIFY_TLS"
	TlsSkipVerify bool `` /* 193-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MQTTTLSOptions) Descriptor deprecated added in v0.0.46 

func (*MQTTTLSOptions) Descriptor() ([]byte, []int)

Deprecated: Use MQTTTLSOptions.ProtoReflect.Descriptor instead.

func (*MQTTTLSOptions) GetTlsCaCert added in v0.0.114 

func (x *MQTTTLSOptions) GetTlsCaCert() string

func (*MQTTTLSOptions) GetTlsClientCert added in v0.0.114 

func (x *MQTTTLSOptions) GetTlsClientCert() string

func (*MQTTTLSOptions) GetTlsClientKey added in v0.0.114 

func (x *MQTTTLSOptions) GetTlsClientKey() string

func (*MQTTTLSOptions) GetTlsSkipVerify added in v0.0.114 

func (x *MQTTTLSOptions) GetTlsSkipVerify() bool

func (*MQTTTLSOptions) ProtoMessage added in v0.0.46 

func (*MQTTTLSOptions) ProtoMessage()

func (*MQTTTLSOptions) ProtoReflect added in v0.0.181 

func (x *MQTTTLSOptions) ProtoReflect() protoreflect.Message

func (*MQTTTLSOptions) Reset added in v0.0.46 

func (x *MQTTTLSOptions) Reset()

func (*MQTTTLSOptions) String added in v0.0.46 

func (x *MQTTTLSOptions) String() string

type MQTTWriteArgs added in v0.0.47 

type MQTTWriteArgs struct {

	// @gotags: kong:"help='Topic to write message(s) to',required"
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic to write message(s) to',required"`
	// @gotags: kong:"help='How long to attempt to publish message(s)',default=5"
	WriteTimeoutSeconds uint32 `` /* 187-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MQTTWriteArgs) Descriptor deprecated added in v0.0.47 

func (*MQTTWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use MQTTWriteArgs.ProtoReflect.Descriptor instead.

func (*MQTTWriteArgs) GetTopic added in v0.0.47 

func (x *MQTTWriteArgs) GetTopic() string

func (*MQTTWriteArgs) GetWriteTimeoutSeconds added in v0.0.47 

func (x *MQTTWriteArgs) GetWriteTimeoutSeconds() uint32

func (*MQTTWriteArgs) ProtoMessage added in v0.0.47 

func (*MQTTWriteArgs) ProtoMessage()

func (*MQTTWriteArgs) ProtoReflect added in v0.0.181 

func (x *MQTTWriteArgs) ProtoReflect() protoreflect.Message

func (*MQTTWriteArgs) Reset added in v0.0.47 

func (x *MQTTWriteArgs) Reset()

func (*MQTTWriteArgs) String added in v0.0.47 

func (x *MQTTWriteArgs) String() string

type MemphisConn added in v0.0.177 

type MemphisConn struct {

	// @gotags: kong:"help='Address of Memphis broker (Ex: localhost:6666)',default='localhost:6666'"
	Address string `` /* 153-byte string literal not displayed */
	// @gotags: kong:"help='Broker username',default='plumber'"
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty" kong:"help='Broker username',default='plumber'"`
	// @gotags: kong:"help='Broker access token',default='memphis'"
	BrokerToken string `` /* 146-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MemphisConn) Descriptor deprecated added in v0.0.177 

func (*MemphisConn) Descriptor() ([]byte, []int)

Deprecated: Use MemphisConn.ProtoReflect.Descriptor instead.

func (*MemphisConn) GetAddress added in v0.0.177 

func (x *MemphisConn) GetAddress() string

func (*MemphisConn) GetBrokerToken added in v0.0.177 

func (x *MemphisConn) GetBrokerToken() string

func (*MemphisConn) GetUsername added in v0.0.177 

func (x *MemphisConn) GetUsername() string

func (*MemphisConn) ProtoMessage added in v0.0.177 

func (*MemphisConn) ProtoMessage()

func (*MemphisConn) ProtoReflect added in v0.0.181 

func (x *MemphisConn) ProtoReflect() protoreflect.Message

func (*MemphisConn) Reset added in v0.0.177 

func (x *MemphisConn) Reset()

func (*MemphisConn) String added in v0.0.177 

func (x *MemphisConn) String() string

type MemphisReadArgs added in v0.0.177 

type MemphisReadArgs struct {

	// @gotags: kong:"help='Station name to consume from',required"
	Station string `protobuf:"bytes,1,opt,name=station,proto3" json:"station,omitempty" kong:"help='Station name to consume from',required"`
	// @gotags: kong:"help='Consumer Name',default='plumber'"
	ConsumerName string `` /* 143-byte string literal not displayed */
	// @gotags: kong:"help='Consumer Group, defaults to consumer-name if not specified',env='PLUMBER_RELAY_MEMPHIS_CONSUMER_GROUP'"
	ConsumerGroup string `` /* 216-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MemphisReadArgs) Descriptor deprecated added in v0.0.177 

func (*MemphisReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use MemphisReadArgs.ProtoReflect.Descriptor instead.

func (*MemphisReadArgs) GetConsumerGroup added in v0.0.177 

func (x *MemphisReadArgs) GetConsumerGroup() string

func (*MemphisReadArgs) GetConsumerName added in v0.0.177 

func (x *MemphisReadArgs) GetConsumerName() string

func (*MemphisReadArgs) GetStation added in v0.0.177 

func (x *MemphisReadArgs) GetStation() string

func (*MemphisReadArgs) ProtoMessage added in v0.0.177 

func (*MemphisReadArgs) ProtoMessage()

func (*MemphisReadArgs) ProtoReflect added in v0.0.181 

func (x *MemphisReadArgs) ProtoReflect() protoreflect.Message

func (*MemphisReadArgs) Reset added in v0.0.177 

func (x *MemphisReadArgs) Reset()

func (*MemphisReadArgs) String added in v0.0.177 

func (x *MemphisReadArgs) String() string

type MemphisWriteArgs added in v0.0.177 

type MemphisWriteArgs struct {

	// @gotags: kong:"help='Station name to write to',required"
	Station string `protobuf:"bytes,1,opt,name=station,proto3" json:"station,omitempty" kong:"help='Station name to write to',required"`
	// @gotags: kong:"help='Producer name',default='plumber'"
	ProducerName string `` /* 143-byte string literal not displayed */
	// @gotags: kong:"help='Add one or more headers (optional; repeat flags to specify multiple)'"
	Headers map[string]string `` /* 238-byte string literal not displayed */
	// @gotags: kong:"help='ID to give message'"
	MessageId string `protobuf:"bytes,4,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty" kong:"help='ID to give message'"`
	// contains filtered or unexported fields
}

func (*MemphisWriteArgs) Descriptor deprecated added in v0.0.177 

func (*MemphisWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use MemphisWriteArgs.ProtoReflect.Descriptor instead.

func (*MemphisWriteArgs) GetHeaders added in v0.0.177 

func (x *MemphisWriteArgs) GetHeaders() map[string]string

func (*MemphisWriteArgs) GetMessageId added in v0.0.177 

func (x *MemphisWriteArgs) GetMessageId() string

func (*MemphisWriteArgs) GetProducerName added in v0.0.177 

func (x *MemphisWriteArgs) GetProducerName() string

func (*MemphisWriteArgs) GetStation added in v0.0.177 

func (x *MemphisWriteArgs) GetStation() string

func (*MemphisWriteArgs) ProtoMessage added in v0.0.177 

func (*MemphisWriteArgs) ProtoMessage()

func (*MemphisWriteArgs) ProtoReflect added in v0.0.181 

func (x *MemphisWriteArgs) ProtoReflect() protoreflect.Message

func (*MemphisWriteArgs) Reset added in v0.0.177 

func (x *MemphisWriteArgs) Reset()

func (*MemphisWriteArgs) String added in v0.0.177 

func (x *MemphisWriteArgs) String() string

type MongoConn added in v0.0.46 

type MongoConn struct {

	// @gotags: kong:"help='Dial string for mongo server (Ex: mongodb://localhost:27017)',env='PLUMBER_RELAY_CDCMONGO_DSN',default='mongodb://localhost:27017'"
	Dsn string `` /* 203-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MongoConn) Descriptor deprecated added in v0.0.46 

func (*MongoConn) Descriptor() ([]byte, []int)

Deprecated: Use MongoConn.ProtoReflect.Descriptor instead.

func (*MongoConn) GetDsn added in v0.0.46 

func (x *MongoConn) GetDsn() string

func (*MongoConn) ProtoMessage added in v0.0.46 

func (*MongoConn) ProtoMessage()

func (*MongoConn) ProtoReflect added in v0.0.181 

func (x *MongoConn) ProtoReflect() protoreflect.Message

func (*MongoConn) Reset added in v0.0.46 

func (x *MongoConn) Reset()

func (*MongoConn) String added in v0.0.46 

func (x *MongoConn) String() string

type MongoReadArgs added in v0.0.47 

type MongoReadArgs struct {

	// @gotags: kong:"help='Database name',env='PLUMBER_RELAY_CDCMONGO_DATABASE'"
	Database string `` /* 135-byte string literal not displayed */
	// @gotags: kong:"help='Collection name',env='PLUMBER_RELAY_CDCMONGO_COLLECTION'"
	Collection string `` /* 143-byte string literal not displayed */
	// @gotags: kong:"help='Include full document in update in update changes (default - return deltas only)',env='PLUMBER_RELAY_CDCMONGO_INCLUDE_FULL_DOC'"
	IncludeFullDocument bool `` /* 262-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MongoReadArgs) Descriptor deprecated added in v0.0.47 

func (*MongoReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use MongoReadArgs.ProtoReflect.Descriptor instead.

func (*MongoReadArgs) GetCollection added in v0.0.47 

func (x *MongoReadArgs) GetCollection() string

func (*MongoReadArgs) GetDatabase added in v0.0.47 

func (x *MongoReadArgs) GetDatabase() string

func (*MongoReadArgs) GetIncludeFullDocument added in v0.0.47 

func (x *MongoReadArgs) GetIncludeFullDocument() bool

func (*MongoReadArgs) ProtoMessage added in v0.0.47 

func (*MongoReadArgs) ProtoMessage()

func (*MongoReadArgs) ProtoReflect added in v0.0.181 

func (x *MongoReadArgs) ProtoReflect() protoreflect.Message

func (*MongoReadArgs) Reset added in v0.0.47 

func (x *MongoReadArgs) Reset()

func (*MongoReadArgs) String added in v0.0.47 

func (x *MongoReadArgs) String() string

type NSQConn added in v0.0.46 

type NSQConn struct {

	// @gotags: kong:"help='Address of NSQ server (Ex: localhost:4150)',env='PLUMBER_RELAY_NSQ_NSQD_ADDRESS',default='localhost:4150',xor=nsq_addressZ"
	NsqdAddress string `` /* 230-byte string literal not displayed */
	// @gotags: kong:"help='Address of LookupD server (Ex: localhost:4161)',env='PLUMBER_RELAY_NSQ_LOOKUPD_ADDRESS',xor=nsq_address"
	LookupdAddress string `` /* 220-byte string literal not displayed */
	// @gotags: kong:"help='Enable TLS usage',env='PLUMBER_RELAY_NSQ_USE_TLS'"
	UseTls bool `` /* 143-byte string literal not displayed */
	// @gotags: kong:"help='Whether to verify server certificate',env='PLUMBER_RELAY_NSQ_SKIP_VERIFY_TLS'"
	TlsSkipVerify bool `` /* 194-byte string literal not displayed */
	// @gotags: kong:"help='CA file',env='PLUMBER_RELAY_NSQ_TLS_CA_CERT'"
	TlsCaCert string `` /* 148-byte string literal not displayed */
	// @gotags: kong:"help='Client cert file',env='PLUMBER_RELAY_NSQ_TLS_CLIENT_CERT'"
	TlsClientCert string `` /* 173-byte string literal not displayed */
	// @gotags: kong:"help='Client key file',env='PLUMBER_RELAY_NSQ_TLS_CLIENT_KEY'"
	TlsClientKey string `` /* 168-byte string literal not displayed */
	// @gotags: kong:"help='Authentication secret',env='PLUMBER_RELAY_NSQ_AUTH_SECRET'"
	AuthSecret string `` /* 163-byte string literal not displayed */
	// @gotags: kong:"help='Client ID to identify as',env='PLUMBER_RELAY_NSQ_CLIENT_ID',default=plumber"
	ClientId string `` /* 174-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NSQConn) Descriptor deprecated added in v0.0.46 

func (*NSQConn) Descriptor() ([]byte, []int)

Deprecated: Use NSQConn.ProtoReflect.Descriptor instead.

func (*NSQConn) GetAuthSecret added in v0.0.46 

func (x *NSQConn) GetAuthSecret() string

func (*NSQConn) GetClientId added in v0.0.46 

func (x *NSQConn) GetClientId() string

func (*NSQConn) GetLookupdAddress added in v0.0.46 

func (x *NSQConn) GetLookupdAddress() string

func (*NSQConn) GetNsqdAddress added in v0.0.46 

func (x *NSQConn) GetNsqdAddress() string

func (*NSQConn) GetTlsCaCert added in v0.0.46 

func (x *NSQConn) GetTlsCaCert() string

func (*NSQConn) GetTlsClientCert added in v0.0.46 

func (x *NSQConn) GetTlsClientCert() string

func (*NSQConn) GetTlsClientKey added in v0.0.46 

func (x *NSQConn) GetTlsClientKey() string

func (*NSQConn) GetTlsSkipVerify added in v0.0.114 

func (x *NSQConn) GetTlsSkipVerify() bool

func (*NSQConn) GetUseTls added in v0.0.46 

func (x *NSQConn) GetUseTls() bool

func (*NSQConn) ProtoMessage added in v0.0.46 

func (*NSQConn) ProtoMessage()

func (*NSQConn) ProtoReflect added in v0.0.181 

func (x *NSQConn) ProtoReflect() protoreflect.Message

func (*NSQConn) Reset added in v0.0.46 

func (x *NSQConn) Reset()

func (*NSQConn) String added in v0.0.46 

func (x *NSQConn) String() string

type NSQReadArgs added in v0.0.47 

type NSQReadArgs struct {

	// @gotags: kong:"help='NSQ topic to read from',env='PLUMBER_RELAY_NSQ_TOPIC',required"
	Topic string `` /* 139-byte string literal not displayed */
	// @gotags: kong:"help='Output channel',env='PLUMBER_RELAY_NSQ_CHANNEL',required"
	Channel string `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NSQReadArgs) Descriptor deprecated added in v0.0.47 

func (*NSQReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use NSQReadArgs.ProtoReflect.Descriptor instead.

func (*NSQReadArgs) GetChannel added in v0.0.47 

func (x *NSQReadArgs) GetChannel() string

func (*NSQReadArgs) GetTopic added in v0.0.47 

func (x *NSQReadArgs) GetTopic() string

func (*NSQReadArgs) ProtoMessage added in v0.0.47 

func (*NSQReadArgs) ProtoMessage()

func (*NSQReadArgs) ProtoReflect added in v0.0.181 

func (x *NSQReadArgs) ProtoReflect() protoreflect.Message

func (*NSQReadArgs) Reset added in v0.0.47 

func (x *NSQReadArgs) Reset()

func (*NSQReadArgs) String added in v0.0.47 

func (x *NSQReadArgs) String() string

type NSQWriteArgs added in v0.0.47 

type NSQWriteArgs struct {

	// @gotags: kong:"help='NSQ topic to write to',required"
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='NSQ topic to write to',required"`
	// contains filtered or unexported fields
}

func (*NSQWriteArgs) Descriptor deprecated added in v0.0.47 

func (*NSQWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use NSQWriteArgs.ProtoReflect.Descriptor instead.

func (*NSQWriteArgs) GetTopic added in v0.0.47 

func (x *NSQWriteArgs) GetTopic() string

func (*NSQWriteArgs) ProtoMessage added in v0.0.47 

func (*NSQWriteArgs) ProtoMessage()

func (*NSQWriteArgs) ProtoReflect added in v0.0.181 

func (x *NSQWriteArgs) ProtoReflect() protoreflect.Message

func (*NSQWriteArgs) Reset added in v0.0.47 

func (x *NSQWriteArgs) Reset()

func (*NSQWriteArgs) String added in v0.0.47 

func (x *NSQWriteArgs) String() string

type NatsConn added in v0.0.46 

type NatsConn struct {

	// @gotags: kong:"help='Dial string for NATS server. Ex: nats://localhost:4222',default='nats://localhost:4222',env='PLUMBER_RELAY_NATS_DSN'"
	Dsn string `` /* 189-byte string literal not displayed */
	// @gotags: kong:"help='NATS .creds file containing authentication credentials',env='PLUMBER_RELAY_NATS_CREDENTIALS'"
	UserCredentials string `` /* 212-byte string literal not displayed */
	// @gotags: kong:"embed"
	TlsOptions *NatsTLSOptions `protobuf:"bytes,3,opt,name=tls_options,json=tlsOptions,proto3" json:"tls_options,omitempty" kong:"embed"`
	// @gotags: kong:"help='File containing NATS NKey',env='PLUMBER_RELAY_NATS_NKEY'"
	Nkey string `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NatsConn) Descriptor deprecated added in v0.0.46 

func (*NatsConn) Descriptor() ([]byte, []int)

Deprecated: Use NatsConn.ProtoReflect.Descriptor instead.

func (*NatsConn) GetDsn added in v0.0.46 

func (x *NatsConn) GetDsn() string

func (*NatsConn) GetNkey added in v0.0.166 

func (x *NatsConn) GetNkey() string

func (*NatsConn) GetTlsOptions added in v0.0.125 

func (x *NatsConn) GetTlsOptions() *NatsTLSOptions

func (*NatsConn) GetUserCredentials added in v0.0.46 

func (x *NatsConn) GetUserCredentials() string

func (*NatsConn) ProtoMessage added in v0.0.46 

func (*NatsConn) ProtoMessage()

func (*NatsConn) ProtoReflect added in v0.0.181 

func (x *NatsConn) ProtoReflect() protoreflect.Message

func (*NatsConn) Reset added in v0.0.46 

func (x *NatsConn) Reset()

func (*NatsConn) String added in v0.0.46 

func (x *NatsConn) String() string

type NatsJetstreamConn added in v0.0.119 

type NatsJetstreamConn struct {

	// @gotags: kong:"help='Dial string for NATS server. Ex: nats://localhost:4222',default='nats://localhost:4222',env='PLUMBER_RELAY_NATS_JETSTREAM_DSN'"
	Dsn string `` /* 199-byte string literal not displayed */
	// @gotags: kong:"help='NATS .creds file containing authentication credentials',env='PLUMBER_RELAY_NATS_JETSTREAM_CREDENTIALS'"
	UserCredentials string `` /* 222-byte string literal not displayed */
	// @gotags: kong:"help='User specified client ID to connect with',default=plumber,env='PLUMBER_RELAY_NATS_JETSTREAM_CLIENT_ID'"
	ClientId string `` /* 201-byte string literal not displayed */
	// @gotags: kong:"embed"
	TlsOptions *NatsJetstreamTLSOptions `protobuf:"bytes,4,opt,name=tls_options,json=tlsOptions,proto3" json:"tls_options,omitempty" kong:"embed"`
	// @gotags: kong:"help='File containing NATS NKey',env='PLUMBER_RELAY_NATS_JETSTREAM_NKEY'"
	Nkey string `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NatsJetstreamConn) Descriptor deprecated added in v0.0.119 

func (*NatsJetstreamConn) Descriptor() ([]byte, []int)

Deprecated: Use NatsJetstreamConn.ProtoReflect.Descriptor instead.

func (*NatsJetstreamConn) GetClientId added in v0.0.119 

func (x *NatsJetstreamConn) GetClientId() string

func (*NatsJetstreamConn) GetDsn added in v0.0.119 

func (x *NatsJetstreamConn) GetDsn() string

func (*NatsJetstreamConn) GetNkey added in v0.0.166 

func (x *NatsJetstreamConn) GetNkey() string

func (*NatsJetstreamConn) GetTlsOptions added in v0.0.119 

func (x *NatsJetstreamConn) GetTlsOptions() *NatsJetstreamTLSOptions

func (*NatsJetstreamConn) GetUserCredentials added in v0.0.119 

func (x *NatsJetstreamConn) GetUserCredentials() string

func (*NatsJetstreamConn) ProtoMessage added in v0.0.119 

func (*NatsJetstreamConn) ProtoMessage()

func (*NatsJetstreamConn) ProtoReflect added in v0.0.181 

func (x *NatsJetstreamConn) ProtoReflect() protoreflect.Message

func (*NatsJetstreamConn) Reset added in v0.0.119 

func (x *NatsJetstreamConn) Reset()

func (*NatsJetstreamConn) String added in v0.0.119 

func (x *NatsJetstreamConn) String() string

type NatsJetstreamReadArgs added in v0.0.119 

type NatsJetstreamReadArgs struct {

	// @gotags: kong:"help='NATS JetStream stream name. Ex: orders.>',env='PLUMBER_RELAY_NATS_JETSTREAM_STREAM'"
	Stream string `` /* 162-byte string literal not displayed */
	// @gotags: kong:"help='Consumer name (default: random consumer name; has no effect if create_durable_consumer or existing_durable_consumer is not set)',env='PLUMBER_RELAY_NATS_JETSTREAM_CONSUMER_NAME'"
	ConsumerName string `` /* 288-byte string literal not displayed */
	// @gotags: kong:"help='Create a new durable consumer (default: use ephemeral consumer)',env='PLUMBER_RELAY_NATS_JETSTREAM_CREATE_DURABLE_CONSUMER'"
	CreateDurableConsumer bool `` /* 264-byte string literal not displayed */
	// @gotags: kong:"help='Use an existing durable consumer (default: use ephemeral consumer)',env='PLUMBER_RELAY_NATS_JETSTREAM_EXISTING_DURABLE_CONSUMER'"
	ExistingDurableConsumer bool `` /* 275-byte string literal not displayed */
	// @gotags: kong:"help='Do not delete consumer after operation is done (default: delete on exit)',env='PLUMBER_RELAY_NATS_JETSTREAM_KEEP_CONSUMER'"
	KeepConsumer bool `` /* 234-byte string literal not displayed */
	// @gotags: kong:"help='Where to start read in stream (default: from start)',env='PLUMBER_RELAY_NATS_JETSTREAM_CONSUMER_START_SEQUENCE'"
	ConsumerStartSequence int64 `` /* 252-byte string literal not displayed */
	// @gotags: kong:"help='At what time to start stream (RFC3339 format, Ex: 2016-06-20T12:41:45.14Z)',env='PLUMBER_RELAY_NATS_JETSTREAM_CONSUMER_START_TIME'"
	ConsumerStartTime string `` /* 258-byte string literal not displayed */
	// @gotags: kong:"help='Only receive a subset of messages from the Stream based on the subject',env='PLUMBER_RELAY_NATS_JETSTREAM_CONSUMER_FILTER_SUBJECT'"
	ConsumerFilterSubject string `` /* 270-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NatsJetstreamReadArgs) Descriptor deprecated added in v0.0.119 

func (*NatsJetstreamReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use NatsJetstreamReadArgs.ProtoReflect.Descriptor instead.

func (*NatsJetstreamReadArgs) GetConsumerFilterSubject added in v0.0.161 

func (x *NatsJetstreamReadArgs) GetConsumerFilterSubject() string

func (*NatsJetstreamReadArgs) GetConsumerName added in v0.0.161 

func (x *NatsJetstreamReadArgs) GetConsumerName() string

func (*NatsJetstreamReadArgs) GetConsumerStartSequence added in v0.0.161 

func (x *NatsJetstreamReadArgs) GetConsumerStartSequence() int64

func (*NatsJetstreamReadArgs) GetConsumerStartTime added in v0.0.161 

func (x *NatsJetstreamReadArgs) GetConsumerStartTime() string

func (*NatsJetstreamReadArgs) GetCreateDurableConsumer added in v0.0.162 

func (x *NatsJetstreamReadArgs) GetCreateDurableConsumer() bool

func (*NatsJetstreamReadArgs) GetExistingDurableConsumer added in v0.0.162 

func (x *NatsJetstreamReadArgs) GetExistingDurableConsumer() bool

func (*NatsJetstreamReadArgs) GetKeepConsumer added in v0.0.161 

func (x *NatsJetstreamReadArgs) GetKeepConsumer() bool

func (*NatsJetstreamReadArgs) GetStream added in v0.0.119 

func (x *NatsJetstreamReadArgs) GetStream() string

func (*NatsJetstreamReadArgs) ProtoMessage added in v0.0.119 

func (*NatsJetstreamReadArgs) ProtoMessage()

func (*NatsJetstreamReadArgs) ProtoReflect added in v0.0.181 

func (x *NatsJetstreamReadArgs) ProtoReflect() protoreflect.Message

func (*NatsJetstreamReadArgs) Reset added in v0.0.119 

func (x *NatsJetstreamReadArgs) Reset()

func (*NatsJetstreamReadArgs) String added in v0.0.119 

func (x *NatsJetstreamReadArgs) String() string

type NatsJetstreamTLSOptions added in v0.0.119 

type NatsJetstreamTLSOptions struct {

	// @gotags: kong:"help='CA file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_JETSTREAM_TLS_CA_CERT'"
	TlsCaCert string `` /* 192-byte string literal not displayed */
	// @gotags: kong:"help='Client cert file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_JETSTREAM_TLS_CLIENT_CERT'"
	TlsClientCert string `` /* 217-byte string literal not displayed */
	// @gotags: kong:"help='Client key file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_JETSTREAM_TLS_CLIENT_KEY'"
	TlsClientKey string `` /* 212-byte string literal not displayed */
	// @gotags: kong:"help='Whether to verify server certificate',env='PLUMBER_RELAY_NATS_JETSTREAM_SKIP_VERIFY_TLS'"
	TlsSkipVerify bool `` /* 205-byte string literal not displayed */
	// @gotags: kong:"help='Enable TLS',env='PLUMBER_RELAY_NATS_JETSTREAM_USE_TLS'"
	UseTls bool `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NatsJetstreamTLSOptions) Descriptor deprecated added in v0.0.119 

func (*NatsJetstreamTLSOptions) Descriptor() ([]byte, []int)

Deprecated: Use NatsJetstreamTLSOptions.ProtoReflect.Descriptor instead.

func (*NatsJetstreamTLSOptions) GetTlsCaCert added in v0.0.119 

func (x *NatsJetstreamTLSOptions) GetTlsCaCert() string

func (*NatsJetstreamTLSOptions) GetTlsClientCert added in v0.0.119 

func (x *NatsJetstreamTLSOptions) GetTlsClientCert() string

func (*NatsJetstreamTLSOptions) GetTlsClientKey added in v0.0.119 

func (x *NatsJetstreamTLSOptions) GetTlsClientKey() string

func (*NatsJetstreamTLSOptions) GetTlsSkipVerify added in v0.0.119 

func (x *NatsJetstreamTLSOptions) GetTlsSkipVerify() bool

func (*NatsJetstreamTLSOptions) GetUseTls added in v0.0.144 

func (x *NatsJetstreamTLSOptions) GetUseTls() bool

func (*NatsJetstreamTLSOptions) ProtoMessage added in v0.0.119 

func (*NatsJetstreamTLSOptions) ProtoMessage()

func (*NatsJetstreamTLSOptions) ProtoReflect added in v0.0.181 

func (x *NatsJetstreamTLSOptions) ProtoReflect() protoreflect.Message

func (*NatsJetstreamTLSOptions) Reset added in v0.0.119 

func (x *NatsJetstreamTLSOptions) Reset()

func (*NatsJetstreamTLSOptions) String added in v0.0.119 

func (x *NatsJetstreamTLSOptions) String() string

type NatsJetstreamWriteArgs added in v0.0.119 

type NatsJetstreamWriteArgs struct {

	// @gotags: kong:"help='NATS JetStream subject name to write to. Ex: orders.>'"
	Subject string `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NatsJetstreamWriteArgs) Descriptor deprecated added in v0.0.119 

func (*NatsJetstreamWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use NatsJetstreamWriteArgs.ProtoReflect.Descriptor instead.

func (*NatsJetstreamWriteArgs) GetSubject added in v0.0.164 

func (x *NatsJetstreamWriteArgs) GetSubject() string

func (*NatsJetstreamWriteArgs) ProtoMessage added in v0.0.119 

func (*NatsJetstreamWriteArgs) ProtoMessage()

func (*NatsJetstreamWriteArgs) ProtoReflect added in v0.0.181 

func (x *NatsJetstreamWriteArgs) ProtoReflect() protoreflect.Message

func (*NatsJetstreamWriteArgs) Reset added in v0.0.119 

func (x *NatsJetstreamWriteArgs) Reset()

func (*NatsJetstreamWriteArgs) String added in v0.0.119 

func (x *NatsJetstreamWriteArgs) String() string

type NatsReadArgs added in v0.0.47 

type NatsReadArgs struct {

	// @gotags: kong:"help='NATS Subject. Ex: foo.bar.*',env='PLUMBER_RELAY_NATS_SUBJECT'"
	Subject string `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NatsReadArgs) Descriptor deprecated added in v0.0.47 

func (*NatsReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use NatsReadArgs.ProtoReflect.Descriptor instead.

func (*NatsReadArgs) GetSubject added in v0.0.47 

func (x *NatsReadArgs) GetSubject() string

func (*NatsReadArgs) ProtoMessage added in v0.0.47 

func (*NatsReadArgs) ProtoMessage()

func (*NatsReadArgs) ProtoReflect added in v0.0.181 

func (x *NatsReadArgs) ProtoReflect() protoreflect.Message

func (*NatsReadArgs) Reset added in v0.0.47 

func (x *NatsReadArgs) Reset()

func (*NatsReadArgs) String added in v0.0.47 

func (x *NatsReadArgs) String() string

type NatsStreamingConn added in v0.0.46 

type NatsStreamingConn struct {

	// @gotags: kong:"help='Dial string for NATS server. Ex: nats://localhost:4222',default='nats://localhost:4222',env='PLUMBER_RELAY_NATS_STREAMING_DSN'"
	Dsn string `` /* 199-byte string literal not displayed */
	// @gotags: kong:"help='NATS .creds file containing authentication credentials',env='PLUMBER_RELAY_NATS_STREAMING_CREDENTIALS'"
	UserCredentials string `` /* 222-byte string literal not displayed */
	// @gotags: kong:"help='Cluster ID of the Nats server',required,env='PLUMBER_RELAY_NATS_STREAMING_CLUSTER_ID'"
	ClusterId string `` /* 187-byte string literal not displayed */
	// @gotags: kong:"help='User specified client ID to connect with',default='plumber',env='PLUMBER_RELAY_NATS_STREAMING_CLIENT_ID'"
	ClientId string `` /* 203-byte string literal not displayed */
	// @gotags: kong:"embed"
	TlsOptions *NatsStreamingTLSOptions `protobuf:"bytes,5,opt,name=tls_options,json=tlsOptions,proto3" json:"tls_options,omitempty" kong:"embed"`
	// contains filtered or unexported fields
}

func (*NatsStreamingConn) Descriptor deprecated added in v0.0.46 

func (*NatsStreamingConn) Descriptor() ([]byte, []int)

Deprecated: Use NatsStreamingConn.ProtoReflect.Descriptor instead.

func (*NatsStreamingConn) GetClientId added in v0.0.46 

func (x *NatsStreamingConn) GetClientId() string

func (*NatsStreamingConn) GetClusterId added in v0.0.46 

func (x *NatsStreamingConn) GetClusterId() string

func (*NatsStreamingConn) GetDsn added in v0.0.46 

func (x *NatsStreamingConn) GetDsn() string

func (*NatsStreamingConn) GetTlsOptions added in v0.0.106 

func (x *NatsStreamingConn) GetTlsOptions() *NatsStreamingTLSOptions

func (*NatsStreamingConn) GetUserCredentials added in v0.0.46 

func (x *NatsStreamingConn) GetUserCredentials() string

func (*NatsStreamingConn) ProtoMessage added in v0.0.46 

func (*NatsStreamingConn) ProtoMessage()

func (*NatsStreamingConn) ProtoReflect added in v0.0.181 

func (x *NatsStreamingConn) ProtoReflect() protoreflect.Message

func (*NatsStreamingConn) Reset added in v0.0.46 

func (x *NatsStreamingConn) Reset()

func (*NatsStreamingConn) String added in v0.0.46 

func (x *NatsStreamingConn) String() string

type NatsStreamingReadArgs added in v0.0.47 

type NatsStreamingReadArgs struct {

	// @gotags: kong:"help='NATS stream channel. Ex: orders',env='PLUMBER_RELAY_NATS_STREAMING_CHANNEL'"
	Channel string `` /* 156-byte string literal not displayed */
	// @gotags: kong:"help='Create a durable subscription with this name for the given channel',env='PLUMBER_RELAY_NATS_STREAMING_DURABLE_SUBSCRIPTION_NAME'"
	DurableName string `` /* 236-byte string literal not displayed */
	// @gotags: kong:"help='Deliver starting with last published message',xor=nats_delivery_option,env='PLUMBER_RELAY_NATS_STREAMING_READ_LAST'"
	ReadLastAvailable bool `` /* 244-byte string literal not displayed */
	// @gotags: kong:"help='Deliver messages starting at sequence number',xor=nats_delivery_option,env='PLUMBER_RELAY_NATS_STREAMING_READ_SEQUENCE'"
	ReadSequenceNumber uint32 `` /* 251-byte string literal not displayed */
	// @gotags: kong:"help='Deliver messages in last interval (e.g. 1s, 1h)',xor=nats_delivery_option,env='PLUMBER_RELAY_NATS_STREAMING_READ_SINCE'"
	ReadSince string `` /* 221-byte string literal not displayed */
	// @gotags: kong:"help='Deliver all available messages',xor=nats_delivery_option,env='PLUMBER_RELAY_NATS_STREAMING_READ_ALL'"
	ReadAll bool `` /* 197-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NatsStreamingReadArgs) Descriptor deprecated added in v0.0.47 

func (*NatsStreamingReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use NatsStreamingReadArgs.ProtoReflect.Descriptor instead.

func (*NatsStreamingReadArgs) GetChannel added in v0.0.47 

func (x *NatsStreamingReadArgs) GetChannel() string

func (*NatsStreamingReadArgs) GetDurableName added in v0.0.47 

func (x *NatsStreamingReadArgs) GetDurableName() string

func (*NatsStreamingReadArgs) GetReadAll added in v0.0.47 

func (x *NatsStreamingReadArgs) GetReadAll() bool

func (*NatsStreamingReadArgs) GetReadLastAvailable added in v0.0.47 

func (x *NatsStreamingReadArgs) GetReadLastAvailable() bool

func (*NatsStreamingReadArgs) GetReadSequenceNumber added in v0.0.47 

func (x *NatsStreamingReadArgs) GetReadSequenceNumber() uint32

func (*NatsStreamingReadArgs) GetReadSince added in v0.0.47 

func (x *NatsStreamingReadArgs) GetReadSince() string

func (*NatsStreamingReadArgs) ProtoMessage added in v0.0.47 

func (*NatsStreamingReadArgs) ProtoMessage()

func (*NatsStreamingReadArgs) ProtoReflect added in v0.0.181 

func (x *NatsStreamingReadArgs) ProtoReflect() protoreflect.Message

func (*NatsStreamingReadArgs) Reset added in v0.0.47 

func (x *NatsStreamingReadArgs) Reset()

func (*NatsStreamingReadArgs) String added in v0.0.47 

func (x *NatsStreamingReadArgs) String() string

type NatsStreamingTLSOptions added in v0.0.106 

type NatsStreamingTLSOptions struct {

	// @gotags: kong:"help='CA file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_STREAMING_TLS_CA_CERT'"
	TlsCaCert string `` /* 192-byte string literal not displayed */
	// @gotags: kong:"help='Client cert file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_STREAMING_TLS_CLIENT_CERT'"
	TlsClientCert string `` /* 217-byte string literal not displayed */
	// @gotags: kong:"help='Client key file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_STREAMING_TLS_CLIENT_KEY'"
	TlsClientKey string `` /* 212-byte string literal not displayed */
	// @gotags: kong:"help='Whether to verify server certificate',env='PLUMBER_RELAY_NATS_STREAMING_SKIP_VERIFY_TLS'"
	TlsSkipVerify bool `` /* 205-byte string literal not displayed */
	// @gotags: kong:"help='Enable TLS',env='PLUMBER_RELAY_NATS_STREAMING_USE_TLS'"
	UseTls bool `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NatsStreamingTLSOptions) Descriptor deprecated added in v0.0.106 

func (*NatsStreamingTLSOptions) Descriptor() ([]byte, []int)

Deprecated: Use NatsStreamingTLSOptions.ProtoReflect.Descriptor instead.

func (*NatsStreamingTLSOptions) GetTlsCaCert added in v0.0.114 

func (x *NatsStreamingTLSOptions) GetTlsCaCert() string

func (*NatsStreamingTLSOptions) GetTlsClientCert added in v0.0.114 

func (x *NatsStreamingTLSOptions) GetTlsClientCert() string

func (*NatsStreamingTLSOptions) GetTlsClientKey added in v0.0.114 

func (x *NatsStreamingTLSOptions) GetTlsClientKey() string

func (*NatsStreamingTLSOptions) GetTlsSkipVerify added in v0.0.114 

func (x *NatsStreamingTLSOptions) GetTlsSkipVerify() bool

func (*NatsStreamingTLSOptions) GetUseTls added in v0.0.144 

func (x *NatsStreamingTLSOptions) GetUseTls() bool

func (*NatsStreamingTLSOptions) ProtoMessage added in v0.0.106 

func (*NatsStreamingTLSOptions) ProtoMessage()

func (*NatsStreamingTLSOptions) ProtoReflect added in v0.0.181 

func (x *NatsStreamingTLSOptions) ProtoReflect() protoreflect.Message

func (*NatsStreamingTLSOptions) Reset added in v0.0.106 

func (x *NatsStreamingTLSOptions) Reset()

func (*NatsStreamingTLSOptions) String added in v0.0.106 

func (x *NatsStreamingTLSOptions) String() string

type NatsStreamingWriteArgs added in v0.0.47 

type NatsStreamingWriteArgs struct {

	// @gotags: kong:"help='NATS stream channel. Ex: orders'"
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty" kong:"help='NATS stream channel. Ex: orders'"`
	// contains filtered or unexported fields
}

func (*NatsStreamingWriteArgs) Descriptor deprecated added in v0.0.47 

func (*NatsStreamingWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use NatsStreamingWriteArgs.ProtoReflect.Descriptor instead.

func (*NatsStreamingWriteArgs) GetChannel added in v0.0.47 

func (x *NatsStreamingWriteArgs) GetChannel() string

func (*NatsStreamingWriteArgs) ProtoMessage added in v0.0.47 

func (*NatsStreamingWriteArgs) ProtoMessage()

func (*NatsStreamingWriteArgs) ProtoReflect added in v0.0.181 

func (x *NatsStreamingWriteArgs) ProtoReflect() protoreflect.Message

func (*NatsStreamingWriteArgs) Reset added in v0.0.47 

func (x *NatsStreamingWriteArgs) Reset()

func (*NatsStreamingWriteArgs) String added in v0.0.47 

func (x *NatsStreamingWriteArgs) String() string

type NatsTLSOptions added in v0.0.125 

type NatsTLSOptions struct {

	// @gotags: kong:"help='Whether to verify server certificate',env='PLUMBER_RELAY_NATS_SKIP_VERIFY_TLS'"
	TlsSkipVerify bool `` /* 195-byte string literal not displayed */
	// @gotags: kong:"help='CA file (only needed if addr is tls://)',env='PLUMBER_RELAY_NATS_TLS_CA_CERT'"
	TlsCaCert string `` /* 181-byte string literal not displayed */
	// @gotags: kong:"help='Client cert file (only needed if addr is tls://)',env='PLUMBER_RELAY_NATS_TLS_CLIENT_CERT'"
	TlsClientCert string `` /* 206-byte string literal not displayed */
	// @gotags: kong:"help='client key file (only needed if addr is tls://)',env='PLUMBER_RELAY_NATS_TLS_CLIENT_KEY'"
	TlsClientKey string `` /* 201-byte string literal not displayed */
	// @gotags: kong:"help='Enable TLS',env='PLUMBER_RELAY_NATS_USE_TLS'"
	UseTls bool `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NatsTLSOptions) Descriptor deprecated added in v0.0.125 

func (*NatsTLSOptions) Descriptor() ([]byte, []int)

Deprecated: Use NatsTLSOptions.ProtoReflect.Descriptor instead.

func (*NatsTLSOptions) GetTlsCaCert added in v0.0.125 

func (x *NatsTLSOptions) GetTlsCaCert() string

func (*NatsTLSOptions) GetTlsClientCert added in v0.0.125 

func (x *NatsTLSOptions) GetTlsClientCert() string

func (*NatsTLSOptions) GetTlsClientKey added in v0.0.125 

func (x *NatsTLSOptions) GetTlsClientKey() string

func (*NatsTLSOptions) GetTlsSkipVerify added in v0.0.125 

func (x *NatsTLSOptions) GetTlsSkipVerify() bool

func (*NatsTLSOptions) GetUseTls added in v0.0.144 

func (x *NatsTLSOptions) GetUseTls() bool

func (*NatsTLSOptions) ProtoMessage added in v0.0.125 

func (*NatsTLSOptions) ProtoMessage()

func (*NatsTLSOptions) ProtoReflect added in v0.0.181 

func (x *NatsTLSOptions) ProtoReflect() protoreflect.Message

func (*NatsTLSOptions) Reset added in v0.0.125 

func (x *NatsTLSOptions) Reset()

func (*NatsTLSOptions) String added in v0.0.125 

func (x *NatsTLSOptions) String() string

type NatsWriteArgs added in v0.0.47 

type NatsWriteArgs struct {

	// @gotags: kong:"help='NATS Subject. Ex: foo.bar.*'"
	Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty" kong:"help='NATS Subject. Ex: foo.bar.*'"`
	// contains filtered or unexported fields
}

func (*NatsWriteArgs) Descriptor deprecated added in v0.0.47 

func (*NatsWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use NatsWriteArgs.ProtoReflect.Descriptor instead.

func (*NatsWriteArgs) GetSubject added in v0.0.47 

func (x *NatsWriteArgs) GetSubject() string

func (*NatsWriteArgs) ProtoMessage added in v0.0.47 

func (*NatsWriteArgs) ProtoMessage()

func (*NatsWriteArgs) ProtoReflect added in v0.0.181 

func (x *NatsWriteArgs) ProtoReflect() protoreflect.Message

func (*NatsWriteArgs) Reset added in v0.0.47 

func (x *NatsWriteArgs) Reset()

func (*NatsWriteArgs) String added in v0.0.47 

func (x *NatsWriteArgs) String() string

type OffsetStart added in v0.0.69 

type OffsetStart int32
const (
	OffsetStart_LATEST OffsetStart = 0
	OffsetStart_OLDEST OffsetStart = 1
)

func (OffsetStart) Descriptor added in v0.0.181 

func (OffsetStart) Descriptor() protoreflect.EnumDescriptor

func (OffsetStart) Enum added in v0.0.181 

func (x OffsetStart) Enum() *OffsetStart

func (OffsetStart) EnumDescriptor deprecated added in v0.0.69 

func (OffsetStart) EnumDescriptor() ([]byte, []int)

Deprecated: Use OffsetStart.Descriptor instead.

func (OffsetStart) Number added in v0.0.181 

func (x OffsetStart) Number() protoreflect.EnumNumber

func (OffsetStart) String added in v0.0.69 

func (x OffsetStart) String() string

func (OffsetStart) Type added in v0.0.181 

func (OffsetStart) Type() protoreflect.EnumType

type PostgresConn added in v0.0.46 

type PostgresConn struct {

	// @gotags: kong:"help='Postgres server hostname',env='PLUMBER_RELAY_CDCPOSTGRES_HOSTNAME',required"
	Address string `` /* 156-byte string literal not displayed */
	// @gotags: kong:"help='Postgres port',env='PLUMBER_RELAY_CDCPOSTGRES_PORT',default=5432,required"
	Port uint32 `` /* 149-byte string literal not displayed */
	// @gotags: kong:"help='Postgres username',env='PLUMBER_RELAY_CDCPOSTGRES_USERNAME',required"
	Username string `` /* 151-byte string literal not displayed */
	// @gotags: kong:"help='Postgres server password',env='PLUMBER_RELAY_CDCPOSTGRES_PASSWORD'"
	Password string `` /* 149-byte string literal not displayed */
	// @gotags: kong:"help='Postgres server database name',env='PLUMBER_RELAY_CDCPOSTGRES_DATABASE',required"
	Database string `` /* 163-byte string literal not displayed */
	// @gotags: kong:"help='Enable TLS usage',env='PLUMBER_RELAY_CDCPOSTGRES_USE_TLS'"
	UseTls bool `` /* 151-byte string literal not displayed */
	// @gotags: kong:"help='Whether to verify server certificate',env='PLUMBER_RELAY_CDCPOSTGRES_SKIP_VERIFY_TLS'"
	TlsSkipVerify bool `` /* 202-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PostgresConn) Descriptor deprecated added in v0.0.46 

func (*PostgresConn) Descriptor() ([]byte, []int)

Deprecated: Use PostgresConn.ProtoReflect.Descriptor instead.

func (*PostgresConn) GetAddress added in v0.0.46 

func (x *PostgresConn) GetAddress() string

func (*PostgresConn) GetDatabase added in v0.0.46 

func (x *PostgresConn) GetDatabase() string

func (*PostgresConn) GetPassword added in v0.0.46 

func (x *PostgresConn) GetPassword() string

func (*PostgresConn) GetPort added in v0.0.46 

func (x *PostgresConn) GetPort() uint32

func (*PostgresConn) GetTlsSkipVerify added in v0.0.114 

func (x *PostgresConn) GetTlsSkipVerify() bool

func (*PostgresConn) GetUseTls added in v0.0.46 

func (x *PostgresConn) GetUseTls() bool

func (*PostgresConn) GetUsername added in v0.0.46 

func (x *PostgresConn) GetUsername() string

func (*PostgresConn) ProtoMessage added in v0.0.46 

func (*PostgresConn) ProtoMessage()

func (*PostgresConn) ProtoReflect added in v0.0.181 

func (x *PostgresConn) ProtoReflect() protoreflect.Message

func (*PostgresConn) Reset added in v0.0.46 

func (x *PostgresConn) Reset()

func (*PostgresConn) String added in v0.0.46 

func (x *PostgresConn) String() string

type PostgresReadArgs added in v0.0.47 

type PostgresReadArgs struct {

	// @gotags: kong:"help='CDC replication slot name',env='PLUMBER_RELAY_CDCPOSTGRES_SLOT',required"
	ReplicationSlotName string `` /* 206-byte string literal not displayed */
	// @gotags: kong:"help='CDC publisher name',env='PLUMBER_RELAY_CDCPOSTGRES_PUBLISHER',required"
	PublisherName string `` /* 184-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PostgresReadArgs) Descriptor deprecated added in v0.0.47 

func (*PostgresReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use PostgresReadArgs.ProtoReflect.Descriptor instead.

func (*PostgresReadArgs) GetPublisherName added in v0.0.47 

func (x *PostgresReadArgs) GetPublisherName() string

func (*PostgresReadArgs) GetReplicationSlotName added in v0.0.47 

func (x *PostgresReadArgs) GetReplicationSlotName() string

func (*PostgresReadArgs) ProtoMessage added in v0.0.47 

func (*PostgresReadArgs) ProtoMessage()

func (*PostgresReadArgs) ProtoReflect added in v0.0.181 

func (x *PostgresReadArgs) ProtoReflect() protoreflect.Message

func (*PostgresReadArgs) Reset added in v0.0.47 

func (x *PostgresReadArgs) Reset()

func (*PostgresReadArgs) String added in v0.0.47 

func (x *PostgresReadArgs) String() string

type PulsarConn added in v0.0.46 

type PulsarConn struct {

	// @gotags: kong:"help='Full DSN to connect to Pulsar',default='pulsar://localhost:6650',required"
	Dsn string `` /* 146-byte string literal not displayed */
	// @gotags: kong:"help='Connection timeout',default=10"
	ConnectTimeoutSeconds uint32 `` /* 171-byte string literal not displayed */
	// @gotags: kong:"help='Whether to verify server certificate'"
	TlsSkipVerify bool `` /* 154-byte string literal not displayed */
	// @gotags: kong:"help='TLS client certificate file'"
	TlsClientCert string `` /* 144-byte string literal not displayed */
	// @gotags: kong:"help='TLS client key file'"
	TlsClientKey string `` /* 133-byte string literal not displayed */
	// @gotags: kong:"help='Authentication token file'"
	Token string `protobuf:"bytes,6,opt,name=token,proto3" json:"token,omitempty" kong:"help='Authentication token file'"`
	// @gotags: kong:"help='Listener name'"
	ListenerName string `protobuf:"bytes,7,opt,name=listener_name,json=listenerName,proto3" json:"listener_name,omitempty" kong:"help='Listener name'"`
	// contains filtered or unexported fields
}

func (*PulsarConn) Descriptor deprecated added in v0.0.46 

func (*PulsarConn) Descriptor() ([]byte, []int)

Deprecated: Use PulsarConn.ProtoReflect.Descriptor instead.

func (*PulsarConn) GetConnectTimeoutSeconds added in v0.0.46 

func (x *PulsarConn) GetConnectTimeoutSeconds() uint32

func (*PulsarConn) GetDsn added in v0.0.46 

func (x *PulsarConn) GetDsn() string

func (*PulsarConn) GetListenerName added in v0.0.176 

func (x *PulsarConn) GetListenerName() string

func (*PulsarConn) GetTlsClientCert added in v0.0.46 

func (x *PulsarConn) GetTlsClientCert() string

func (*PulsarConn) GetTlsClientKey added in v0.0.46 

func (x *PulsarConn) GetTlsClientKey() string

func (*PulsarConn) GetTlsSkipVerify added in v0.0.114 

func (x *PulsarConn) GetTlsSkipVerify() bool

func (*PulsarConn) GetToken added in v0.0.176 

func (x *PulsarConn) GetToken() string

func (*PulsarConn) ProtoMessage added in v0.0.46 

func (*PulsarConn) ProtoMessage()

func (*PulsarConn) ProtoReflect added in v0.0.181 

func (x *PulsarConn) ProtoReflect() protoreflect.Message

func (*PulsarConn) Reset added in v0.0.46 

func (x *PulsarConn) Reset()

func (*PulsarConn) String added in v0.0.46 

func (x *PulsarConn) String() string

type PulsarReadArgs added in v0.0.47 

type PulsarReadArgs struct {

	// @gotags: kong:"help='Topic to read messages from',required"
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic to read messages from',required"`
	// @gotags: kong:"help='Subscription name',required"
	SubscriptionName string `` /* 150-byte string literal not displayed */
	// @gotags: kong:"help='Subscription type (options: shared exclusive failover keyshared)',default=shared,type=pbenum,pbenum_lowercase"
	SubscriptionType SubscriptionType `` /* 267-byte string literal not displayed */
	// @gotags: kong:"help='Subscription initial position (options: latest earliest)',default=latest,type=pbenum,pbenum_lowercase,pbenum_strip_prefix=PULSAR_"
	InitialPosition SubscriptionInitialPosition `` /* 295-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PulsarReadArgs) Descriptor deprecated added in v0.0.47 

func (*PulsarReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use PulsarReadArgs.ProtoReflect.Descriptor instead.

func (*PulsarReadArgs) GetInitialPosition added in v0.0.176 

func (x *PulsarReadArgs) GetInitialPosition() SubscriptionInitialPosition

func (*PulsarReadArgs) GetSubscriptionName added in v0.0.47 

func (x *PulsarReadArgs) GetSubscriptionName() string

func (*PulsarReadArgs) GetSubscriptionType added in v0.0.47 

func (x *PulsarReadArgs) GetSubscriptionType() SubscriptionType

func (*PulsarReadArgs) GetTopic added in v0.0.47 

func (x *PulsarReadArgs) GetTopic() string

func (*PulsarReadArgs) ProtoMessage added in v0.0.47 

func (*PulsarReadArgs) ProtoMessage()

func (*PulsarReadArgs) ProtoReflect added in v0.0.181 

func (x *PulsarReadArgs) ProtoReflect() protoreflect.Message

func (*PulsarReadArgs) Reset added in v0.0.47 

func (x *PulsarReadArgs) Reset()

func (*PulsarReadArgs) String added in v0.0.47 

func (x *PulsarReadArgs) String() string

type PulsarWriteArgs added in v0.0.47 

type PulsarWriteArgs struct {

	// @gotags: kong:"help='topic to write messages to'"
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='topic to write messages to'"`
	// contains filtered or unexported fields
}

func (*PulsarWriteArgs) Descriptor deprecated added in v0.0.47 

func (*PulsarWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use PulsarWriteArgs.ProtoReflect.Descriptor instead.

func (*PulsarWriteArgs) GetTopic added in v0.0.47 

func (x *PulsarWriteArgs) GetTopic() string

func (*PulsarWriteArgs) ProtoMessage added in v0.0.47 

func (*PulsarWriteArgs) ProtoMessage()

func (*PulsarWriteArgs) ProtoReflect added in v0.0.181 

func (x *PulsarWriteArgs) ProtoReflect() protoreflect.Message

func (*PulsarWriteArgs) Reset added in v0.0.47 

func (x *PulsarWriteArgs) Reset()

func (*PulsarWriteArgs) String added in v0.0.47 

func (x *PulsarWriteArgs) String() string

type RabbitConn added in v0.0.46 

type RabbitConn struct {

	// @gotags: kong:"help='Destination host address (full DSN)',env='PLUMBER_RELAY_RABBIT_ADDRESS',default='amqp://localhost',required"
	Address string `` /* 188-byte string literal not displayed */
	// @gotags: kong:"help='Force TLS usage (regardless of DSN)',env='PLUMBER_RELAY_RABBIT_USE_TLS'"
	UseTls bool `` /* 165-byte string literal not displayed */
	// @gotags: kong:"help='Whether to verify server TLS certificate',env='PLUMBER_RELAY_RABBIT_SKIP_VERIFY_TLS'"
	TlsSkipVerify bool `` /* 201-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RabbitConn) Descriptor deprecated added in v0.0.46 

func (*RabbitConn) Descriptor() ([]byte, []int)

Deprecated: Use RabbitConn.ProtoReflect.Descriptor instead.

func (*RabbitConn) GetAddress added in v0.0.46 

func (x *RabbitConn) GetAddress() string

func (*RabbitConn) GetTlsSkipVerify added in v0.0.114 

func (x *RabbitConn) GetTlsSkipVerify() bool

func (*RabbitConn) GetUseTls added in v0.0.46 

func (x *RabbitConn) GetUseTls() bool

func (*RabbitConn) ProtoMessage added in v0.0.46 

func (*RabbitConn) ProtoMessage()

func (*RabbitConn) ProtoReflect added in v0.0.181 

func (x *RabbitConn) ProtoReflect() protoreflect.Message

func (*RabbitConn) Reset added in v0.0.46 

func (x *RabbitConn) Reset()

func (*RabbitConn) String added in v0.0.46 

func (x *RabbitConn) String() string

type RabbitReadArgs added in v0.0.47 

type RabbitReadArgs struct {

	// @gotags: kong:"help='Name of the exchange',env='PLUMBER_RELAY_RABBIT_EXCHANGE',required"
	ExchangeName string `` /* 177-byte string literal not displayed */
	// @gotags: kong:"help='Name of the queue where messages will be routed to',env='PLUMBER_RELAY_RABBIT_QUEUE',required"
	QueueName string `` /* 195-byte string literal not displayed */
	// @gotags: kong:"help='Binding key for topic based exchanges',env='PLUMBER_RELAY_RABBIT_ROUTING_KEY',required"
	BindingKey string `` /* 191-byte string literal not displayed */
	// @gotags: kong:"help='Whether plumber should be the only one using the queue',env='PLUMBER_RELAY_RABBIT_QUEUE_EXCLUSIVE'"
	QueueExclusive bool `` /* 216-byte string literal not displayed */
	// @gotags: kong:"help='Whether to create/declare the queue (if it does not exist)',env='PLUMBER_RELAY_RABBIT_QUEUE_DECLARE',default=true"
	QueueDeclare bool `` /* 225-byte string literal not displayed */
	// @gotags: kong:"help='Whether the queue should survive after disconnect',env='PLUMBER_RELAY_RABBIT_QUEUE_DURABLE'"
	QueueDurable bool `` /* 203-byte string literal not displayed */
	// @gotags: kong:"help='Automatically acknowledge receipt of read/received messages',env='PLUMBER_RELAY_RABBIT_AUTOACK',default=true"
	AutoAck bool `` /* 205-byte string literal not displayed */
	// @gotags: kong:"help='How to identify the consumer to RabbitMQ',env='PLUMBER_RELAY_CONSUMER_TAG',default=plumber"
	ConsumerTag string `` /* 198-byte string literal not displayed */
	// @gotags: kong:"help='Whether to auto-delete the queue after plumber has disconnected',env='PLUMBER_RELAY_RABBIT_QUEUE_AUTO_DELETE',default=true"
	QueueDelete bool `` /* 231-byte string literal not displayed */
	// @gotags: kong:"help='Key=Value pair for sending additional queue argument to RabbitMQ. Example: --queue-arg x-dead-letter-exchange=mydlexchange --queue-arg x-queue-mode=lazy',env='PLUMBER_RELAY_RABBIT_QUEUE_ARGS'"
	QueueArg map[string]string `` /* 379-byte string literal not displayed */
	// @gotags: kong:"help='Exclude messages with routing key matching regex',env='PLUMBER_RELAY_RABBIT_BINDING_KEY_EXCLUDE_REGEX'"
	ExcludeBindingKeyRegex string `` /* 248-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RabbitReadArgs) Descriptor deprecated added in v0.0.47 

func (*RabbitReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use RabbitReadArgs.ProtoReflect.Descriptor instead.

func (*RabbitReadArgs) GetAutoAck added in v0.0.47 

func (x *RabbitReadArgs) GetAutoAck() bool

func (*RabbitReadArgs) GetBindingKey added in v0.0.47 

func (x *RabbitReadArgs) GetBindingKey() string

func (*RabbitReadArgs) GetConsumerTag added in v0.0.47 

func (x *RabbitReadArgs) GetConsumerTag() string

func (*RabbitReadArgs) GetExchangeName added in v0.0.47 

func (x *RabbitReadArgs) GetExchangeName() string

func (*RabbitReadArgs) GetExcludeBindingKeyRegex added in v0.0.172 

func (x *RabbitReadArgs) GetExcludeBindingKeyRegex() string

func (*RabbitReadArgs) GetQueueArg added in v0.0.118 

func (x *RabbitReadArgs) GetQueueArg() map[string]string

func (*RabbitReadArgs) GetQueueDeclare added in v0.0.47 

func (x *RabbitReadArgs) GetQueueDeclare() bool

func (*RabbitReadArgs) GetQueueDelete added in v0.0.47 

func (x *RabbitReadArgs) GetQueueDelete() bool

func (*RabbitReadArgs) GetQueueDurable added in v0.0.47 

func (x *RabbitReadArgs) GetQueueDurable() bool

func (*RabbitReadArgs) GetQueueExclusive added in v0.0.47 

func (x *RabbitReadArgs) GetQueueExclusive() bool

func (*RabbitReadArgs) GetQueueName added in v0.0.47 

func (x *RabbitReadArgs) GetQueueName() string

func (*RabbitReadArgs) ProtoMessage added in v0.0.47 

func (*RabbitReadArgs) ProtoMessage()

func (*RabbitReadArgs) ProtoReflect added in v0.0.181 

func (x *RabbitReadArgs) ProtoReflect() protoreflect.Message

func (*RabbitReadArgs) Reset added in v0.0.47 

func (x *RabbitReadArgs) Reset()

func (*RabbitReadArgs) String added in v0.0.47 

func (x *RabbitReadArgs) String() string

type RabbitStreamsConn added in v0.0.46 

type RabbitStreamsConn struct {

	// @gotags: kong:"help='DSN used to connect to RabbitMQ',default='rabbitmq-stream://guest:guest@localhost:5552',required"
	Dsn string `` /* 169-byte string literal not displayed */
	// @gotags: kong:"help='Enable TLS usage (regardless of DSN)'"
	UseTls bool `` /* 131-byte string literal not displayed */
	// @gotags: kong:"help='Whether to verify server certificate'"
	TlsSkipVerify bool `` /* 154-byte string literal not displayed */
	// @gotags: kong:"help='Username to authenticate to server with',default=guest"
	Username string `` /* 137-byte string literal not displayed */
	// @gotags: kong:"help='Password used to authenticate to server with',default=guest"
	Password string `` /* 142-byte string literal not displayed */
	// @gotags: kong:"help='Consumer or producer name to identify as to RabbitMQ',default=plumber,required"
	ClientName string `` /* 183-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RabbitStreamsConn) Descriptor deprecated added in v0.0.46 

func (*RabbitStreamsConn) Descriptor() ([]byte, []int)

Deprecated: Use RabbitStreamsConn.ProtoReflect.Descriptor instead.

func (*RabbitStreamsConn) GetClientName added in v0.0.46 

func (x *RabbitStreamsConn) GetClientName() string

func (*RabbitStreamsConn) GetDsn added in v0.0.46 

func (x *RabbitStreamsConn) GetDsn() string

func (*RabbitStreamsConn) GetPassword added in v0.0.46 

func (x *RabbitStreamsConn) GetPassword() string

func (*RabbitStreamsConn) GetTlsSkipVerify added in v0.0.114 

func (x *RabbitStreamsConn) GetTlsSkipVerify() bool

func (*RabbitStreamsConn) GetUseTls added in v0.0.46 

func (x *RabbitStreamsConn) GetUseTls() bool

func (*RabbitStreamsConn) GetUsername added in v0.0.46 

func (x *RabbitStreamsConn) GetUsername() string

func (*RabbitStreamsConn) ProtoMessage added in v0.0.46 

func (*RabbitStreamsConn) ProtoMessage()

func (*RabbitStreamsConn) ProtoReflect added in v0.0.181 

func (x *RabbitStreamsConn) ProtoReflect() protoreflect.Message

func (*RabbitStreamsConn) Reset added in v0.0.46 

func (x *RabbitStreamsConn) Reset()

func (*RabbitStreamsConn) String added in v0.0.46 

func (x *RabbitStreamsConn) String() string

type RabbitStreamsOffsetOptions added in v0.0.46 

type RabbitStreamsOffsetOptions struct {

	// @gotags: kong:"group=offset,xor=offset"
	SpecificOffset int64 `` /* 135-byte string literal not displayed */
	// @gotags: kong:"group=offset,xor=offset"
	LastOffset bool `protobuf:"varint,2,opt,name=last_offset,json=lastOffset,proto3" json:"last_offset,omitempty" kong:"group=offset,xor=offset"`
	// @gotags: kong:"group=offset,xor=offset"
	LastConsumed bool `` /* 129-byte string literal not displayed */
	// @gotags: kong:"group=offset,xor=offset"
	FirstOffset bool `` /* 126-byte string literal not displayed */
	// @gotags: kong:"group=offset,xor=offset"
	NextOffset bool `protobuf:"varint,5,opt,name=next_offset,json=nextOffset,proto3" json:"next_offset,omitempty" kong:"group=offset,xor=offset"`
	// contains filtered or unexported fields
}

func (*RabbitStreamsOffsetOptions) Descriptor deprecated added in v0.0.46 

func (*RabbitStreamsOffsetOptions) Descriptor() ([]byte, []int)

Deprecated: Use RabbitStreamsOffsetOptions.ProtoReflect.Descriptor instead.

func (*RabbitStreamsOffsetOptions) GetFirstOffset added in v0.0.46 

func (x *RabbitStreamsOffsetOptions) GetFirstOffset() bool

func (*RabbitStreamsOffsetOptions) GetLastConsumed added in v0.0.46 

func (x *RabbitStreamsOffsetOptions) GetLastConsumed() bool

func (*RabbitStreamsOffsetOptions) GetLastOffset added in v0.0.46 

func (x *RabbitStreamsOffsetOptions) GetLastOffset() bool

func (*RabbitStreamsOffsetOptions) GetNextOffset added in v0.0.46 

func (x *RabbitStreamsOffsetOptions) GetNextOffset() bool

func (*RabbitStreamsOffsetOptions) GetSpecificOffset added in v0.0.46 

func (x *RabbitStreamsOffsetOptions) GetSpecificOffset() int64

func (*RabbitStreamsOffsetOptions) ProtoMessage added in v0.0.46 

func (*RabbitStreamsOffsetOptions) ProtoMessage()

func (*RabbitStreamsOffsetOptions) ProtoReflect added in v0.0.181 

func (x *RabbitStreamsOffsetOptions) ProtoReflect() protoreflect.Message

func (*RabbitStreamsOffsetOptions) Reset added in v0.0.46 

func (x *RabbitStreamsOffsetOptions) Reset()

func (*RabbitStreamsOffsetOptions) String added in v0.0.46 

func (x *RabbitStreamsOffsetOptions) String() string

type RabbitStreamsReadArgs added in v0.0.47 

type RabbitStreamsReadArgs struct {

	// @gotags: kong:"help='Stream name',required"
	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty" kong:"help='Stream name',required"`
	// @gotags: kong:"help='Declare the stream if it does not exist'"
	DeclareStream bool `` /* 155-byte string literal not displayed */
	// @gotags: kong:"help='Stream capacity to declare (required if declare_stream is true; ex: 1024k; 10mb; 3gb)'"
	DeclareStreamSize string `` /* 214-byte string literal not displayed */
	// TODO: Will this break? Might just need to be a string.
	// @gotags: kong:"help='Offset to start reading at',embed"
	OffsetOptions *RabbitStreamsOffsetOptions `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RabbitStreamsReadArgs) Descriptor deprecated added in v0.0.47 

func (*RabbitStreamsReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use RabbitStreamsReadArgs.ProtoReflect.Descriptor instead.

func (*RabbitStreamsReadArgs) GetDeclareStream added in v0.0.47 

func (x *RabbitStreamsReadArgs) GetDeclareStream() bool

func (*RabbitStreamsReadArgs) GetDeclareStreamSize added in v0.0.47 

func (x *RabbitStreamsReadArgs) GetDeclareStreamSize() string

func (*RabbitStreamsReadArgs) GetOffsetOptions added in v0.0.47 

func (x *RabbitStreamsReadArgs) GetOffsetOptions() *RabbitStreamsOffsetOptions

func (*RabbitStreamsReadArgs) GetStream added in v0.0.47 

func (x *RabbitStreamsReadArgs) GetStream() string

func (*RabbitStreamsReadArgs) ProtoMessage added in v0.0.47 

func (*RabbitStreamsReadArgs) ProtoMessage()

func (*RabbitStreamsReadArgs) ProtoReflect added in v0.0.181 

func (x *RabbitStreamsReadArgs) ProtoReflect() protoreflect.Message

func (*RabbitStreamsReadArgs) Reset added in v0.0.47 

func (x *RabbitStreamsReadArgs) Reset()

func (*RabbitStreamsReadArgs) String added in v0.0.47 

func (x *RabbitStreamsReadArgs) String() string

type RabbitStreamsWriteArgs added in v0.0.47 

type RabbitStreamsWriteArgs struct {

	// @gotags: kong:"help='Stream name',required"
	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty" kong:"help='Stream name',required"`
	// @gotags: kong:"help='Declare the stream if it does not exist'"
	DeclareStream bool `` /* 155-byte string literal not displayed */
	// @gotags: kong:"help='Stream capacity to declare (required if declare_stream is true; ex: 1024k, 10mb, 3gb',default=10mb"
	DeclareStreamSize string `` /* 226-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RabbitStreamsWriteArgs) Descriptor deprecated added in v0.0.47 

func (*RabbitStreamsWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use RabbitStreamsWriteArgs.ProtoReflect.Descriptor instead.

func (*RabbitStreamsWriteArgs) GetDeclareStream added in v0.0.47 

func (x *RabbitStreamsWriteArgs) GetDeclareStream() bool

func (*RabbitStreamsWriteArgs) GetDeclareStreamSize added in v0.0.47 

func (x *RabbitStreamsWriteArgs) GetDeclareStreamSize() string

func (*RabbitStreamsWriteArgs) GetStream added in v0.0.47 

func (x *RabbitStreamsWriteArgs) GetStream() string

func (*RabbitStreamsWriteArgs) ProtoMessage added in v0.0.47 

func (*RabbitStreamsWriteArgs) ProtoMessage()

func (*RabbitStreamsWriteArgs) ProtoReflect added in v0.0.181 

func (x *RabbitStreamsWriteArgs) ProtoReflect() protoreflect.Message

func (*RabbitStreamsWriteArgs) Reset added in v0.0.47 

func (x *RabbitStreamsWriteArgs) Reset()

func (*RabbitStreamsWriteArgs) String added in v0.0.47 

func (x *RabbitStreamsWriteArgs) String() string

type RabbitWriteArgs added in v0.0.47 

type RabbitWriteArgs struct {

	// @gotags: kong:"help='Exchange to write message(s) to',required"
	ExchangeName string `` /* 152-byte string literal not displayed */
	// @gotags: kong:"help='Routing key to write message(s) to',required"
	RoutingKey string `` /* 149-byte string literal not displayed */
	// @gotags: kong:"help='Fills message properties $app_id with this value',default=plumber"
	AppId string `` /* 148-byte string literal not displayed */
	// @gotags: kong:"help='The type of exchange we are working with',enum='direct,topic,headers,fanout',default=topic,group=exchange"
	ExchangeType string `` /* 216-byte string literal not displayed */
	// @gotags: kong:"help='Whether to declare an exchange (if it does not exist)',group=exchange"
	ExchangeDeclare bool `` /* 190-byte string literal not displayed */
	// @gotags: kong:"help='Whether to make a declared exchange durable',group=exchange"
	ExchangeDurable bool `` /* 180-byte string literal not displayed */
	// @gotags: kong:"help='Whether to auto-delete the exchange (after writes)',group=exchange"
	ExchangeAutoDelete bool `` /* 198-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RabbitWriteArgs) Descriptor deprecated added in v0.0.47 

func (*RabbitWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use RabbitWriteArgs.ProtoReflect.Descriptor instead.

func (*RabbitWriteArgs) GetAppId added in v0.0.47 

func (x *RabbitWriteArgs) GetAppId() string

func (*RabbitWriteArgs) GetExchangeAutoDelete added in v0.0.54 

func (x *RabbitWriteArgs) GetExchangeAutoDelete() bool

func (*RabbitWriteArgs) GetExchangeDeclare added in v0.0.54 

func (x *RabbitWriteArgs) GetExchangeDeclare() bool

func (*RabbitWriteArgs) GetExchangeDurable added in v0.0.54 

func (x *RabbitWriteArgs) GetExchangeDurable() bool

func (*RabbitWriteArgs) GetExchangeName added in v0.0.47 

func (x *RabbitWriteArgs) GetExchangeName() string

func (*RabbitWriteArgs) GetExchangeType added in v0.0.54 

func (x *RabbitWriteArgs) GetExchangeType() string

func (*RabbitWriteArgs) GetRoutingKey added in v0.0.47 

func (x *RabbitWriteArgs) GetRoutingKey() string

func (*RabbitWriteArgs) ProtoMessage added in v0.0.47 

func (*RabbitWriteArgs) ProtoMessage()

func (*RabbitWriteArgs) ProtoReflect added in v0.0.181 

func (x *RabbitWriteArgs) ProtoReflect() protoreflect.Message

func (*RabbitWriteArgs) Reset added in v0.0.47 

func (x *RabbitWriteArgs) Reset()

func (*RabbitWriteArgs) String added in v0.0.47 

func (x *RabbitWriteArgs) String() string

type RedisPubSubConn added in v0.0.46 

type RedisPubSubConn struct {

	// @gotags: kong:"help='Address of redis server',env='PLUMBER_RELAY_REDIS_PUBSUB_ADDRESS',default=localhost:6379"
	Address string `` /* 169-byte string literal not displayed */
	// @gotags: kong:"help='Optional username to auth with (redis >= v6.0.0)',env='PLUMBER_RELAY_REDIS_PUBSUB_USERNAME'"
	Username string `` /* 174-byte string literal not displayed */
	// @gotags: kong:"help='Optional password to auth with (redis >= v6.0.0)',env='PLUMBER_RELAY_REDIS_PUBSUB_PASSWORD'"
	Password string `` /* 174-byte string literal not displayed */
	// @gotags: kong:"help='Database (0-16)',env='PLUMBER_RELAY_REDIS_PUBSUB_DATABASE'"
	Database uint32 `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RedisPubSubConn) Descriptor deprecated added in v0.0.46 

func (*RedisPubSubConn) Descriptor() ([]byte, []int)

Deprecated: Use RedisPubSubConn.ProtoReflect.Descriptor instead.

func (*RedisPubSubConn) GetAddress added in v0.0.46 

func (x *RedisPubSubConn) GetAddress() string

func (*RedisPubSubConn) GetDatabase added in v0.0.96 

func (x *RedisPubSubConn) GetDatabase() uint32

func (*RedisPubSubConn) GetPassword added in v0.0.46 

func (x *RedisPubSubConn) GetPassword() string

func (*RedisPubSubConn) GetUsername added in v0.0.46 

func (x *RedisPubSubConn) GetUsername() string

func (*RedisPubSubConn) ProtoMessage added in v0.0.46 

func (*RedisPubSubConn) ProtoMessage()

func (*RedisPubSubConn) ProtoReflect added in v0.0.181 

func (x *RedisPubSubConn) ProtoReflect() protoreflect.Message

func (*RedisPubSubConn) Reset added in v0.0.46 

func (x *RedisPubSubConn) Reset()

func (*RedisPubSubConn) String added in v0.0.46 

func (x *RedisPubSubConn) String() string

type RedisPubSubReadArgs added in v0.0.47 

type RedisPubSubReadArgs struct {

	// @gotags: kong:"help='Comma separated list of channels to read from',env='PLUMBER_RELAY_REDIS_PUBSUB_CHANNELS',required"
	Channels []string `` /* 180-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RedisPubSubReadArgs) Descriptor deprecated added in v0.0.47 

func (*RedisPubSubReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use RedisPubSubReadArgs.ProtoReflect.Descriptor instead.

func (*RedisPubSubReadArgs) GetChannels added in v0.0.114 

func (x *RedisPubSubReadArgs) GetChannels() []string

func (*RedisPubSubReadArgs) ProtoMessage added in v0.0.47 

func (*RedisPubSubReadArgs) ProtoMessage()

func (*RedisPubSubReadArgs) ProtoReflect added in v0.0.181 

func (x *RedisPubSubReadArgs) ProtoReflect() protoreflect.Message

func (*RedisPubSubReadArgs) Reset added in v0.0.47 

func (x *RedisPubSubReadArgs) Reset()

func (*RedisPubSubReadArgs) String added in v0.0.47 

func (x *RedisPubSubReadArgs) String() string

type RedisPubSubWriteArgs added in v0.0.47 

type RedisPubSubWriteArgs struct {

	// @gotags: kong:"help='Comma separated list of channels to write to',required"
	Channels []string `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RedisPubSubWriteArgs) Descriptor deprecated added in v0.0.47 

func (*RedisPubSubWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use RedisPubSubWriteArgs.ProtoReflect.Descriptor instead.

func (*RedisPubSubWriteArgs) GetChannels added in v0.0.114 

func (x *RedisPubSubWriteArgs) GetChannels() []string

func (*RedisPubSubWriteArgs) ProtoMessage added in v0.0.47 

func (*RedisPubSubWriteArgs) ProtoMessage()

func (*RedisPubSubWriteArgs) ProtoReflect added in v0.0.181 

func (x *RedisPubSubWriteArgs) ProtoReflect() protoreflect.Message

func (*RedisPubSubWriteArgs) Reset added in v0.0.47 

func (x *RedisPubSubWriteArgs) Reset()

func (*RedisPubSubWriteArgs) String added in v0.0.47 

func (x *RedisPubSubWriteArgs) String() string

type RedisStreamsConn added in v0.0.46 

type RedisStreamsConn struct {

	// @gotags: kong:"help='Address of redis server',default=localhost:6379,required,env='PLUMBER_RELAY_REDIS_STREAMS_ADDRESS'"
	Address string `` /* 179-byte string literal not displayed */
	// @gotags: kong:"help='Username (redis >= v6.0.0)',env='PLUMBER_RELAY_REDIS_STREAMS_USERNAME'"
	Username string `` /* 153-byte string literal not displayed */
	// @gotags: kong:"help='Password (redis >= v6.0.0)',env='PLUMBER_RELAY_REDIS_STREAMS_PASSWORD'"
	Password string `` /* 153-byte string literal not displayed */
	// @gotags: kong:"help='Database (0-16)',env='PLUMBER_RELAY_REDIS_PUBSUB_DATABASE'"
	Database uint32 `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RedisStreamsConn) Descriptor deprecated added in v0.0.46 

func (*RedisStreamsConn) Descriptor() ([]byte, []int)

Deprecated: Use RedisStreamsConn.ProtoReflect.Descriptor instead.

func (*RedisStreamsConn) GetAddress added in v0.0.46 

func (x *RedisStreamsConn) GetAddress() string

func (*RedisStreamsConn) GetDatabase added in v0.0.96 

func (x *RedisStreamsConn) GetDatabase() uint32

func (*RedisStreamsConn) GetPassword added in v0.0.46 

func (x *RedisStreamsConn) GetPassword() string

func (*RedisStreamsConn) GetUsername added in v0.0.46 

func (x *RedisStreamsConn) GetUsername() string

func (*RedisStreamsConn) ProtoMessage added in v0.0.46 

func (*RedisStreamsConn) ProtoMessage()

func (*RedisStreamsConn) ProtoReflect added in v0.0.181 

func (x *RedisStreamsConn) ProtoReflect() protoreflect.Message

func (*RedisStreamsConn) Reset added in v0.0.46 

func (x *RedisStreamsConn) Reset()

func (*RedisStreamsConn) String added in v0.0.46 

func (x *RedisStreamsConn) String() string

type RedisStreamsReadArgs added in v0.0.47 

type RedisStreamsReadArgs struct {

	// @gotags: kong:"help='Streams to read from',required,env='PLUMBER_RELAY_REDIS_STREAMS_STREAMS'"
	Streams []string `` /* 153-byte string literal not displayed */
	// @gotags: kong:"help='Consumer group name',env='PLUMBER_RELAY_REDIS_STREAMS_CONSUMER_GROUP',default=plumber"
	ConsumerGroup string `` /* 199-byte string literal not displayed */
	// @gotags: kong:"help='Consumer name',env='PLUMBER_RELAY_REDIS_STREAMS_CONSUMER_NAME',default=plumber-consumer-1"
	ConsumerName string `` /* 200-byte string literal not displayed */
	// @gotags: kong:"help='Number of records to read from stream(s) per read',env='PLUMBER_RELAY_REDIS_STREAMS_COUNT',default=10"
	Count uint32 `` /* 179-byte string literal not displayed */
	// @gotags: kong:"embed"
	CreateConsumerConfig *CreateConsumerConfig `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RedisStreamsReadArgs) Descriptor deprecated added in v0.0.47 

func (*RedisStreamsReadArgs) Descriptor() ([]byte, []int)

Deprecated: Use RedisStreamsReadArgs.ProtoReflect.Descriptor instead.

func (*RedisStreamsReadArgs) GetConsumerGroup added in v0.0.47 

func (x *RedisStreamsReadArgs) GetConsumerGroup() string

func (*RedisStreamsReadArgs) GetConsumerName added in v0.0.47 

func (x *RedisStreamsReadArgs) GetConsumerName() string

func (*RedisStreamsReadArgs) GetCount added in v0.0.47 

func (x *RedisStreamsReadArgs) GetCount() uint32

func (*RedisStreamsReadArgs) GetCreateConsumerConfig added in v0.0.47 

func (x *RedisStreamsReadArgs) GetCreateConsumerConfig() *CreateConsumerConfig

func (*RedisStreamsReadArgs) GetStreams added in v0.0.114 

func (x *RedisStreamsReadArgs) GetStreams() []string

func (*RedisStreamsReadArgs) ProtoMessage added in v0.0.47 

func (*RedisStreamsReadArgs) ProtoMessage()

func (*RedisStreamsReadArgs) ProtoReflect added in v0.0.181 

func (x *RedisStreamsReadArgs) ProtoReflect() protoreflect.Message

func (*RedisStreamsReadArgs) Reset added in v0.0.47 

func (x *RedisStreamsReadArgs) Reset()

func (*RedisStreamsReadArgs) String added in v0.0.47 

func (x *RedisStreamsReadArgs) String() string

type RedisStreamsWriteArgs added in v0.0.47 

type RedisStreamsWriteArgs struct {

	// @gotags: kong:"help='What redis ID to use for input data (* = auto-generate)',default='*'"
	WriteId string `` /* 164-byte string literal not displayed */
	// @gotags: kong:"help='Streams to write to'"
	Streams []string `protobuf:"bytes,2,rep,name=streams,proto3" json:"streams,omitempty" kong:"help='Streams to write to'"`
	// @gotags: kong:"help='Key name to write input data to'"
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty" kong:"help='Key name to write input data to'"`
	// contains filtered or unexported fields
}

func (*RedisStreamsWriteArgs) Descriptor deprecated added in v0.0.47 

func (*RedisStreamsWriteArgs) Descriptor() ([]byte, []int)

Deprecated: Use RedisStreamsWriteArgs.ProtoReflect.Descriptor instead.

func (*RedisStreamsWriteArgs) GetKey added in v0.0.47 

func (x *RedisStreamsWriteArgs) GetKey() string

func (*RedisStreamsWriteArgs) GetStreams added in v0.0.47 

func (x *RedisStreamsWriteArgs) GetStreams() []string

func (*RedisStreamsWriteArgs) GetWriteId added in v0.0.47 

func (x *RedisStreamsWriteArgs) GetWriteId() string

func (*RedisStreamsWriteArgs) ProtoMessage added in v0.0.47 

func (*RedisStreamsWriteArgs) ProtoMessage()

func (*RedisStreamsWriteArgs) ProtoReflect added in v0.0.181 

func (x *RedisStreamsWriteArgs) ProtoReflect() protoreflect.Message

func (*RedisStreamsWriteArgs) Reset added in v0.0.47 

func (x *RedisStreamsWriteArgs) Reset()

func (*RedisStreamsWriteArgs) String added in v0.0.47 

func (x *RedisStreamsWriteArgs) String() string

type SASLType added in v0.0.69 

type SASLType int32
const (
	SASLType_NONE  SASLType = 0
	SASLType_PLAIN SASLType = 1
	SASLType_SCRAM SASLType = 2
)

func (SASLType) Descriptor added in v0.0.181 

func (SASLType) Descriptor() protoreflect.EnumDescriptor

func (SASLType) Enum added in v0.0.181 

func (x SASLType) Enum() *SASLType

func (SASLType) EnumDescriptor deprecated added in v0.0.69 

func (SASLType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SASLType.Descriptor instead.

func (SASLType) Number added in v0.0.181 

func (x SASLType) Number() protoreflect.EnumNumber

func (SASLType) String added in v0.0.69 

func (x SASLType) String() string

func (SASLType) Type added in v0.0.181 

func (SASLType) Type() protoreflect.EnumType

type SubscriptionInitialPosition added in v0.0.176 

type SubscriptionInitialPosition int32
const (
	SubscriptionInitialPosition_PULSAR_LATEST   SubscriptionInitialPosition = 0
	SubscriptionInitialPosition_PULSAR_EARLIEST SubscriptionInitialPosition = 1
)

func (SubscriptionInitialPosition) Descriptor added in v0.0.181 

func (SubscriptionInitialPosition) Descriptor() protoreflect.EnumDescriptor

func (SubscriptionInitialPosition) Enum added in v0.0.181 

func (x SubscriptionInitialPosition) Enum() *SubscriptionInitialPosition

func (SubscriptionInitialPosition) EnumDescriptor deprecated added in v0.0.176 

func (SubscriptionInitialPosition) EnumDescriptor() ([]byte, []int)

Deprecated: Use SubscriptionInitialPosition.Descriptor instead.

func (SubscriptionInitialPosition) Number added in v0.0.181 

func (x SubscriptionInitialPosition) Number() protoreflect.EnumNumber

func (SubscriptionInitialPosition) String added in v0.0.176 

func (x SubscriptionInitialPosition) String() string

func (SubscriptionInitialPosition) Type added in v0.0.181 

func (SubscriptionInitialPosition) Type() protoreflect.EnumType

type SubscriptionType added in v0.0.46 

type SubscriptionType int32
const (
	SubscriptionType_SHARED    SubscriptionType = 0
	SubscriptionType_EXCLUSIVE SubscriptionType = 1
	SubscriptionType_FAILOVER  SubscriptionType = 2
	SubscriptionType_KEYSHARED SubscriptionType = 3
)

func (SubscriptionType) Descriptor added in v0.0.181 

func (SubscriptionType) Descriptor() protoreflect.EnumDescriptor

func (SubscriptionType) Enum added in v0.0.181 

func (x SubscriptionType) Enum() *SubscriptionType

func (SubscriptionType) EnumDescriptor deprecated added in v0.0.46 

func (SubscriptionType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SubscriptionType.Descriptor instead.

func (SubscriptionType) Number added in v0.0.181 

func (x SubscriptionType) Number() protoreflect.EnumNumber

func (SubscriptionType) String added in v0.0.46 

func (x SubscriptionType) String() string

func (SubscriptionType) Type added in v0.0.181 

func (SubscriptionType) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.