args

package
v0.0.46 Latest Latest
Warning

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

 Go to latest Published: Sep 8, 2021 License: Apache-2.0 Imports: 3 Imported by: 23

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CreateConsumerConfig_OffsetStart_name = map[int32]string{
	0: "Latest",
	1: "Oldest",
}
View Source 
var CreateConsumerConfig_OffsetStart_value = map[string]int32{
	"Latest": 0,
	"Oldest": 1,
}
View Source 
var KafkaConn_SASLType_name = map[int32]string{
	0: "NONE",
	1: "PLAIN",
	2: "SCRAM",
}
View Source 
var KafkaConn_SASLType_value = map[string]int32{
	"NONE":  0,
	"PLAIN": 1,
	"SCRAM": 2,
}
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",
}
View Source 
var 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,
}
View Source 
var SubscriptionType_name = map[int32]string{
	0: "SHARED",
	1: "EXCLUSIVE",
	2: "FAILOVER",
	3: "KEYSHARED",
}
View Source 
var SubscriptionType_value = map[string]int32{
	"SHARED":    0,
	"EXCLUSIVE": 1,
	"FAILOVER":  2,
	"KEYSHARED": 3,
}

Functions

This section is empty.

Types

type AWSSNSConn added in v0.0.46 

type AWSSNSConn struct {
	// @gotags: kong:"en=AWS_DEFAULT_REGION,hidden,required"
	AwsRegion string `` /* 133-byte string literal not displayed */
	// @gotags: kong:"env=AWS_ACCESS_KEY_ID,hidden,required"
	AwsAccessKeyId string `` /* 152-byte string literal not displayed */
	// @gotags: kong:"env=AWS_SECRET_ACCESS_KEY,hidden,required"
	AwsSecretAccessKey   string   `` /* 168-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AWSSNSConn) Descriptor added in v0.0.46 

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

func (*AWSSNSConn) GetAwsAccessKeyId added in v0.0.46 

func (m *AWSSNSConn) GetAwsAccessKeyId() string

func (*AWSSNSConn) GetAwsRegion added in v0.0.46 

func (m *AWSSNSConn) GetAwsRegion() string

func (*AWSSNSConn) GetAwsSecretAccessKey added in v0.0.46 

func (m *AWSSNSConn) GetAwsSecretAccessKey() string

func (*AWSSNSConn) ProtoMessage added in v0.0.46 

func (*AWSSNSConn) ProtoMessage()

func (*AWSSNSConn) Reset added in v0.0.46 

func (m *AWSSNSConn) Reset()

func (*AWSSNSConn) String added in v0.0.46 

func (m *AWSSNSConn) String() string

func (*AWSSNSConn) XXX_DiscardUnknown added in v0.0.46 

func (m *AWSSNSConn) XXX_DiscardUnknown()

func (*AWSSNSConn) XXX_Marshal added in v0.0.46 

func (m *AWSSNSConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AWSSNSConn) XXX_Merge added in v0.0.46 

func (m *AWSSNSConn) XXX_Merge(src proto.Message)

func (*AWSSNSConn) XXX_Size added in v0.0.46 

func (m *AWSSNSConn) XXX_Size() int

func (*AWSSNSConn) XXX_Unmarshal added in v0.0.46 

func (m *AWSSNSConn) XXX_Unmarshal(b []byte) error

type AWSSNSWriteOpts added in v0.0.46 

type AWSSNSWriteOpts struct {
	// @gotags: kong:"help='Topic ARN',required"
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic ARN',required"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AWSSNSWriteOpts) Descriptor added in v0.0.46 

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

func (*AWSSNSWriteOpts) GetTopic added in v0.0.46 

func (m *AWSSNSWriteOpts) GetTopic() string

func (*AWSSNSWriteOpts) ProtoMessage added in v0.0.46 

func (*AWSSNSWriteOpts) ProtoMessage()

func (*AWSSNSWriteOpts) Reset added in v0.0.46 

func (m *AWSSNSWriteOpts) Reset()

func (*AWSSNSWriteOpts) String added in v0.0.46 

func (m *AWSSNSWriteOpts) String() string

func (*AWSSNSWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *AWSSNSWriteOpts) XXX_DiscardUnknown()

func (*AWSSNSWriteOpts) XXX_Marshal added in v0.0.46 

func (m *AWSSNSWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AWSSNSWriteOpts) XXX_Merge added in v0.0.46 

func (m *AWSSNSWriteOpts) XXX_Merge(src proto.Message)

func (*AWSSNSWriteOpts) XXX_Size added in v0.0.46 

func (m *AWSSNSWriteOpts) XXX_Size() int

func (*AWSSNSWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *AWSSNSWriteOpts) XXX_Unmarshal(b []byte) error

type AWSSQSConn added in v0.0.46 

type AWSSQSConn struct {
	// @gotags: kong:"en=AWS_DEFAULT_REGION,hidden,required"
	AwsRegion string `` /* 133-byte string literal not displayed */
	// @gotags: kong:"env=AWS_ACCESS_KEY_ID,hidden,required"
	AwsAccessKeyId string `` /* 152-byte string literal not displayed */
	// @gotags: kong:"env=AWS_SECRET_ACCESS_KEY,hidden,required"
	AwsSecretAccessKey   string   `` /* 168-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AWSSQSConn) Descriptor added in v0.0.46 

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

func (*AWSSQSConn) GetAwsAccessKeyId added in v0.0.46 

func (m *AWSSQSConn) GetAwsAccessKeyId() string

func (*AWSSQSConn) GetAwsRegion added in v0.0.46 

func (m *AWSSQSConn) GetAwsRegion() string

func (*AWSSQSConn) GetAwsSecretAccessKey added in v0.0.46 

func (m *AWSSQSConn) GetAwsSecretAccessKey() string

func (*AWSSQSConn) ProtoMessage added in v0.0.46 

func (*AWSSQSConn) ProtoMessage()

func (*AWSSQSConn) Reset added in v0.0.46 

func (m *AWSSQSConn) Reset()

func (*AWSSQSConn) String added in v0.0.46 

func (m *AWSSQSConn) String() string

func (*AWSSQSConn) XXX_DiscardUnknown added in v0.0.46 

func (m *AWSSQSConn) XXX_DiscardUnknown()

func (*AWSSQSConn) XXX_Marshal added in v0.0.46 

func (m *AWSSQSConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AWSSQSConn) XXX_Merge added in v0.0.46 

func (m *AWSSQSConn) XXX_Merge(src proto.Message)

func (*AWSSQSConn) XXX_Size added in v0.0.46 

func (m *AWSSQSConn) XXX_Size() int

func (*AWSSQSConn) XXX_Unmarshal added in v0.0.46 

func (m *AWSSQSConn) XXX_Unmarshal(b []byte) error

type AWSSQSReadOpts added in v0.0.46 

type AWSSQSReadOpts 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 uint32 `` /* 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      uint32   `` /* 207-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AWSSQSReadOpts) Descriptor added in v0.0.46 

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

func (*AWSSQSReadOpts) GetAutoDelete added in v0.0.46 

func (m *AWSSQSReadOpts) GetAutoDelete() bool

func (*AWSSQSReadOpts) GetMaxNumMessages added in v0.0.46 

func (m *AWSSQSReadOpts) GetMaxNumMessages() uint32

func (*AWSSQSReadOpts) GetQueueName added in v0.0.46 

func (m *AWSSQSReadOpts) GetQueueName() string

func (*AWSSQSReadOpts) GetReceiveRequestAttemptId added in v0.0.46 

func (m *AWSSQSReadOpts) GetReceiveRequestAttemptId() string

func (*AWSSQSReadOpts) GetRemoteAccountId added in v0.0.46 

func (m *AWSSQSReadOpts) GetRemoteAccountId() string

func (*AWSSQSReadOpts) GetWaitTimeSeconds added in v0.0.46 

func (m *AWSSQSReadOpts) GetWaitTimeSeconds() uint32

func (*AWSSQSReadOpts) ProtoMessage added in v0.0.46 

func (*AWSSQSReadOpts) ProtoMessage()

func (*AWSSQSReadOpts) Reset added in v0.0.46 

func (m *AWSSQSReadOpts) Reset()

func (*AWSSQSReadOpts) String added in v0.0.46 

func (m *AWSSQSReadOpts) String() string

func (*AWSSQSReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *AWSSQSReadOpts) XXX_DiscardUnknown()

func (*AWSSQSReadOpts) XXX_Marshal added in v0.0.46 

func (m *AWSSQSReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AWSSQSReadOpts) XXX_Merge added in v0.0.46 

func (m *AWSSQSReadOpts) XXX_Merge(src proto.Message)

func (*AWSSQSReadOpts) XXX_Size added in v0.0.46 

func (m *AWSSQSReadOpts) XXX_Size() int

func (*AWSSQSReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *AWSSQSReadOpts) XXX_Unmarshal(b []byte) error

type AWSSQSRelayOpts added in v0.0.46 

type AWSSQSRelayOpts 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 uint32 `` /* 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      int32    `` /* 247-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*AWSSQSRelayOpts) Descriptor added in v0.0.46 

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

func (*AWSSQSRelayOpts) GetAutoDelete added in v0.0.46 

func (m *AWSSQSRelayOpts) GetAutoDelete() bool

func (*AWSSQSRelayOpts) GetMaxNumMessages added in v0.0.46 

func (m *AWSSQSRelayOpts) GetMaxNumMessages() uint32

func (*AWSSQSRelayOpts) GetQueueName added in v0.0.46 

func (m *AWSSQSRelayOpts) GetQueueName() string

func (*AWSSQSRelayOpts) GetReceiveRequestAttemptId added in v0.0.46 

func (m *AWSSQSRelayOpts) GetReceiveRequestAttemptId() string

func (*AWSSQSRelayOpts) GetRemoteAccountId added in v0.0.46 

func (m *AWSSQSRelayOpts) GetRemoteAccountId() string

func (*AWSSQSRelayOpts) GetWaitTimeSeconds added in v0.0.46 

func (m *AWSSQSRelayOpts) GetWaitTimeSeconds() int32

func (*AWSSQSRelayOpts) ProtoMessage added in v0.0.46 

func (*AWSSQSRelayOpts) ProtoMessage()

func (*AWSSQSRelayOpts) Reset added in v0.0.46 

func (m *AWSSQSRelayOpts) Reset()

func (*AWSSQSRelayOpts) String added in v0.0.46 

func (m *AWSSQSRelayOpts) String() string

func (*AWSSQSRelayOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *AWSSQSRelayOpts) XXX_DiscardUnknown()

func (*AWSSQSRelayOpts) XXX_Marshal added in v0.0.46 

func (m *AWSSQSRelayOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AWSSQSRelayOpts) XXX_Merge added in v0.0.46 

func (m *AWSSQSRelayOpts) XXX_Merge(src proto.Message)

func (*AWSSQSRelayOpts) XXX_Size added in v0.0.46 

func (m *AWSSQSRelayOpts) XXX_Size() int

func (*AWSSQSRelayOpts) XXX_Unmarshal added in v0.0.46 

func (m *AWSSQSRelayOpts) XXX_Unmarshal(b []byte) error

type AWSSQSWriteOpts added in v0.0.46 

type AWSSQSWriteOpts 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 uint32 `` /* 168-byte string literal not displayed */
	// @gotags: kong:"help='Add optional attributes to outgoing message (k=v, delimited by ;)'"
	Attributes map[string]string `` /* 241-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 */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

func (*AWSSQSWriteOpts) Descriptor added in v0.0.46 

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

func (*AWSSQSWriteOpts) GetAttributes added in v0.0.46 

func (m *AWSSQSWriteOpts) GetAttributes() map[string]string

func (*AWSSQSWriteOpts) GetDelaySeconds added in v0.0.46 

func (m *AWSSQSWriteOpts) GetDelaySeconds() uint32

func (*AWSSQSWriteOpts) GetMessageDeduplicationId added in v0.0.46 

func (m *AWSSQSWriteOpts) GetMessageDeduplicationId() string

func (*AWSSQSWriteOpts) GetMessageGroupId added in v0.0.46 

func (m *AWSSQSWriteOpts) GetMessageGroupId() string

func (*AWSSQSWriteOpts) GetQueueName added in v0.0.46 

func (m *AWSSQSWriteOpts) GetQueueName() string

func (*AWSSQSWriteOpts) GetRemoteAccountId added in v0.0.46 

func (m *AWSSQSWriteOpts) GetRemoteAccountId() string

func (*AWSSQSWriteOpts) ProtoMessage added in v0.0.46 

func (*AWSSQSWriteOpts) ProtoMessage()

func (*AWSSQSWriteOpts) Reset added in v0.0.46 

func (m *AWSSQSWriteOpts) Reset()

func (*AWSSQSWriteOpts) String added in v0.0.46 

func (m *AWSSQSWriteOpts) String() string

func (*AWSSQSWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *AWSSQSWriteOpts) XXX_DiscardUnknown()

func (*AWSSQSWriteOpts) XXX_Marshal added in v0.0.46 

func (m *AWSSQSWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AWSSQSWriteOpts) XXX_Merge added in v0.0.46 

func (m *AWSSQSWriteOpts) XXX_Merge(src proto.Message)

func (*AWSSQSWriteOpts) XXX_Size added in v0.0.46 

func (m *AWSSQSWriteOpts) XXX_Size() int

func (*AWSSQSWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *AWSSQSWriteOpts) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActiveMQConn) Descriptor added in v0.0.46 

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

func (*ActiveMQConn) GetAddress added in v0.0.46 

func (m *ActiveMQConn) GetAddress() string

func (*ActiveMQConn) ProtoMessage added in v0.0.46 

func (*ActiveMQConn) ProtoMessage()

func (*ActiveMQConn) Reset added in v0.0.46 

func (m *ActiveMQConn) Reset()

func (*ActiveMQConn) String added in v0.0.46 

func (m *ActiveMQConn) String() string

func (*ActiveMQConn) XXX_DiscardUnknown added in v0.0.46 

func (m *ActiveMQConn) XXX_DiscardUnknown()

func (*ActiveMQConn) XXX_Marshal added in v0.0.46 

func (m *ActiveMQConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActiveMQConn) XXX_Merge added in v0.0.46 

func (m *ActiveMQConn) XXX_Merge(src proto.Message)

func (*ActiveMQConn) XXX_Size added in v0.0.46 

func (m *ActiveMQConn) XXX_Size() int

func (*ActiveMQConn) XXX_Unmarshal added in v0.0.46 

func (m *ActiveMQConn) XXX_Unmarshal(b []byte) error

type ActiveMQReadOpts added in v0.0.46 

type ActiveMQReadOpts 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActiveMQReadOpts) Descriptor added in v0.0.46 

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

func (*ActiveMQReadOpts) GetQueue added in v0.0.46 

func (m *ActiveMQReadOpts) GetQueue() string

func (*ActiveMQReadOpts) GetTopic added in v0.0.46 

func (m *ActiveMQReadOpts) GetTopic() string

func (*ActiveMQReadOpts) ProtoMessage added in v0.0.46 

func (*ActiveMQReadOpts) ProtoMessage()

func (*ActiveMQReadOpts) Reset added in v0.0.46 

func (m *ActiveMQReadOpts) Reset()

func (*ActiveMQReadOpts) String added in v0.0.46 

func (m *ActiveMQReadOpts) String() string

func (*ActiveMQReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *ActiveMQReadOpts) XXX_DiscardUnknown()

func (*ActiveMQReadOpts) XXX_Marshal added in v0.0.46 

func (m *ActiveMQReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActiveMQReadOpts) XXX_Merge added in v0.0.46 

func (m *ActiveMQReadOpts) XXX_Merge(src proto.Message)

func (*ActiveMQReadOpts) XXX_Size added in v0.0.46 

func (m *ActiveMQReadOpts) XXX_Size() int

func (*ActiveMQReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *ActiveMQReadOpts) XXX_Unmarshal(b []byte) error

type ActiveMQWriteOpts added in v0.0.46 

type ActiveMQWriteOpts 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActiveMQWriteOpts) Descriptor added in v0.0.46 

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

func (*ActiveMQWriteOpts) GetQueue added in v0.0.46 

func (m *ActiveMQWriteOpts) GetQueue() string

func (*ActiveMQWriteOpts) GetTopic added in v0.0.46 

func (m *ActiveMQWriteOpts) GetTopic() string

func (*ActiveMQWriteOpts) ProtoMessage added in v0.0.46 

func (*ActiveMQWriteOpts) ProtoMessage()

func (*ActiveMQWriteOpts) Reset added in v0.0.46 

func (m *ActiveMQWriteOpts) Reset()

func (*ActiveMQWriteOpts) String added in v0.0.46 

func (m *ActiveMQWriteOpts) String() string

func (*ActiveMQWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *ActiveMQWriteOpts) XXX_DiscardUnknown()

func (*ActiveMQWriteOpts) XXX_Marshal added in v0.0.46 

func (m *ActiveMQWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActiveMQWriteOpts) XXX_Merge added in v0.0.46 

func (m *ActiveMQWriteOpts) XXX_Merge(src proto.Message)

func (*ActiveMQWriteOpts) XXX_Size added in v0.0.46 

func (m *ActiveMQWriteOpts) XXX_Size() int

func (*ActiveMQWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *ActiveMQWriteOpts) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AzureEventHubConn) Descriptor added in v0.0.46 

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

func (*AzureEventHubConn) GetConnectionString added in v0.0.46 

func (m *AzureEventHubConn) GetConnectionString() string

func (*AzureEventHubConn) ProtoMessage added in v0.0.46 

func (*AzureEventHubConn) ProtoMessage()

func (*AzureEventHubConn) Reset added in v0.0.46 

func (m *AzureEventHubConn) Reset()

func (*AzureEventHubConn) String added in v0.0.46 

func (m *AzureEventHubConn) String() string

func (*AzureEventHubConn) XXX_DiscardUnknown added in v0.0.46 

func (m *AzureEventHubConn) XXX_DiscardUnknown()

func (*AzureEventHubConn) XXX_Marshal added in v0.0.46 

func (m *AzureEventHubConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AzureEventHubConn) XXX_Merge added in v0.0.46 

func (m *AzureEventHubConn) XXX_Merge(src proto.Message)

func (*AzureEventHubConn) XXX_Size added in v0.0.46 

func (m *AzureEventHubConn) XXX_Size() int

func (*AzureEventHubConn) XXX_Unmarshal added in v0.0.46 

func (m *AzureEventHubConn) XXX_Unmarshal(b []byte) error

type AzureEventHubReadOpts added in v0.0.46 

type AzureEventHubReadOpts struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AzureEventHubReadOpts) Descriptor added in v0.0.46 

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

func (*AzureEventHubReadOpts) ProtoMessage added in v0.0.46 

func (*AzureEventHubReadOpts) ProtoMessage()

func (*AzureEventHubReadOpts) Reset added in v0.0.46 

func (m *AzureEventHubReadOpts) Reset()

func (*AzureEventHubReadOpts) String added in v0.0.46 

func (m *AzureEventHubReadOpts) String() string

func (*AzureEventHubReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *AzureEventHubReadOpts) XXX_DiscardUnknown()

func (*AzureEventHubReadOpts) XXX_Marshal added in v0.0.46 

func (m *AzureEventHubReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AzureEventHubReadOpts) XXX_Merge added in v0.0.46 

func (m *AzureEventHubReadOpts) XXX_Merge(src proto.Message)

func (*AzureEventHubReadOpts) XXX_Size added in v0.0.46 

func (m *AzureEventHubReadOpts) XXX_Size() int

func (*AzureEventHubReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *AzureEventHubReadOpts) XXX_Unmarshal(b []byte) error

type AzureEventHubWriteOpts added in v0.0.46 

type AzureEventHubWriteOpts 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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AzureEventHubWriteOpts) Descriptor added in v0.0.46 

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

func (*AzureEventHubWriteOpts) GetMessageId added in v0.0.46 

func (m *AzureEventHubWriteOpts) GetMessageId() string

func (*AzureEventHubWriteOpts) GetPartitionKey added in v0.0.46 

func (m *AzureEventHubWriteOpts) GetPartitionKey() string

func (*AzureEventHubWriteOpts) ProtoMessage added in v0.0.46 

func (*AzureEventHubWriteOpts) ProtoMessage()

func (*AzureEventHubWriteOpts) Reset added in v0.0.46 

func (m *AzureEventHubWriteOpts) Reset()

func (*AzureEventHubWriteOpts) String added in v0.0.46 

func (m *AzureEventHubWriteOpts) String() string

func (*AzureEventHubWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *AzureEventHubWriteOpts) XXX_DiscardUnknown()

func (*AzureEventHubWriteOpts) XXX_Marshal added in v0.0.46 

func (m *AzureEventHubWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AzureEventHubWriteOpts) XXX_Merge added in v0.0.46 

func (m *AzureEventHubWriteOpts) XXX_Merge(src proto.Message)

func (*AzureEventHubWriteOpts) XXX_Size added in v0.0.46 

func (m *AzureEventHubWriteOpts) XXX_Size() int

func (*AzureEventHubWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *AzureEventHubWriteOpts) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AzureServiceBusConn) Descriptor added in v0.0.46 

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

func (*AzureServiceBusConn) GetConnectionString added in v0.0.46 

func (m *AzureServiceBusConn) GetConnectionString() string

func (*AzureServiceBusConn) ProtoMessage added in v0.0.46 

func (*AzureServiceBusConn) ProtoMessage()

func (*AzureServiceBusConn) Reset added in v0.0.46 

func (m *AzureServiceBusConn) Reset()

func (*AzureServiceBusConn) String added in v0.0.46 

func (m *AzureServiceBusConn) String() string

func (*AzureServiceBusConn) XXX_DiscardUnknown added in v0.0.46 

func (m *AzureServiceBusConn) XXX_DiscardUnknown()

func (*AzureServiceBusConn) XXX_Marshal added in v0.0.46 

func (m *AzureServiceBusConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AzureServiceBusConn) XXX_Merge added in v0.0.46 

func (m *AzureServiceBusConn) XXX_Merge(src proto.Message)

func (*AzureServiceBusConn) XXX_Size added in v0.0.46 

func (m *AzureServiceBusConn) XXX_Size() int

func (*AzureServiceBusConn) XXX_Unmarshal added in v0.0.46 

func (m *AzureServiceBusConn) XXX_Unmarshal(b []byte) error

type AzureServiceBusReadOpts added in v0.0.46 

type AzureServiceBusReadOpts struct {
	// @gotags: kong:"help='Queue name',env='PLUMBER_RELAY_AZURE_QUEUE_NAME',required"
	Queue string `` /* 134-byte string literal not displayed */
	// @gotags: kong:"help='Topic name',env='PLUMBER_RELAY_AZURE_TOPIC_NAME',required"
	Topic string `` /* 134-byte string literal not displayed */
	// @gotags: kong:"help='Subscription name',env='PLUMBER_RELAY_AZURE_SUBSCRIPTION',required"
	SubscriptionName     string   `` /* 189-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AzureServiceBusReadOpts) Descriptor added in v0.0.46 

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

func (*AzureServiceBusReadOpts) GetQueue added in v0.0.46 

func (m *AzureServiceBusReadOpts) GetQueue() string

func (*AzureServiceBusReadOpts) GetSubscriptionName added in v0.0.46 

func (m *AzureServiceBusReadOpts) GetSubscriptionName() string

func (*AzureServiceBusReadOpts) GetTopic added in v0.0.46 

func (m *AzureServiceBusReadOpts) GetTopic() string

func (*AzureServiceBusReadOpts) ProtoMessage added in v0.0.46 

func (*AzureServiceBusReadOpts) ProtoMessage()

func (*AzureServiceBusReadOpts) Reset added in v0.0.46 

func (m *AzureServiceBusReadOpts) Reset()

func (*AzureServiceBusReadOpts) String added in v0.0.46 

func (m *AzureServiceBusReadOpts) String() string

func (*AzureServiceBusReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *AzureServiceBusReadOpts) XXX_DiscardUnknown()

func (*AzureServiceBusReadOpts) XXX_Marshal added in v0.0.46 

func (m *AzureServiceBusReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AzureServiceBusReadOpts) XXX_Merge added in v0.0.46 

func (m *AzureServiceBusReadOpts) XXX_Merge(src proto.Message)

func (*AzureServiceBusReadOpts) XXX_Size added in v0.0.46 

func (m *AzureServiceBusReadOpts) XXX_Size() int

func (*AzureServiceBusReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *AzureServiceBusReadOpts) XXX_Unmarshal(b []byte) error

type AzureServiceBusWriteOpts added in v0.0.46 

type AzureServiceBusWriteOpts struct {
	// @gotags: kong:"help='Queue name',required"
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty" kong:"help='Queue name',required"`
	// @gotags: kong:"help='Topic name',required"
	Topic                string   `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic name',required"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AzureServiceBusWriteOpts) Descriptor added in v0.0.46 

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

func (*AzureServiceBusWriteOpts) GetQueue added in v0.0.46 

func (m *AzureServiceBusWriteOpts) GetQueue() string

func (*AzureServiceBusWriteOpts) GetTopic added in v0.0.46 

func (m *AzureServiceBusWriteOpts) GetTopic() string

func (*AzureServiceBusWriteOpts) ProtoMessage added in v0.0.46 

func (*AzureServiceBusWriteOpts) ProtoMessage()

func (*AzureServiceBusWriteOpts) Reset added in v0.0.46 

func (m *AzureServiceBusWriteOpts) Reset()

func (*AzureServiceBusWriteOpts) String added in v0.0.46 

func (m *AzureServiceBusWriteOpts) String() string

func (*AzureServiceBusWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *AzureServiceBusWriteOpts) XXX_DiscardUnknown()

func (*AzureServiceBusWriteOpts) XXX_Marshal added in v0.0.46 

func (m *AzureServiceBusWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AzureServiceBusWriteOpts) XXX_Merge added in v0.0.46 

func (m *AzureServiceBusWriteOpts) XXX_Merge(src proto.Message)

func (*AzureServiceBusWriteOpts) XXX_Size added in v0.0.46 

func (m *AzureServiceBusWriteOpts) XXX_Size() int

func (*AzureServiceBusWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *AzureServiceBusWriteOpts) XXX_Unmarshal(b []byte) error

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 (0: latest, 1: oldest)',default=0,required,env='PLUMBER_RELAY_REDIS_STREAMS_START_ID'"
	OffsetStart          CreateConsumerConfig_OffsetStart `` /* 276-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*CreateConsumerConfig) Descriptor added in v0.0.46 

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

func (*CreateConsumerConfig) GetCreateStreams added in v0.0.46 

func (m *CreateConsumerConfig) GetCreateStreams() bool

func (*CreateConsumerConfig) GetOffsetStart added in v0.0.46 

func (m *CreateConsumerConfig) GetOffsetStart() CreateConsumerConfig_OffsetStart

func (*CreateConsumerConfig) GetRecreateConsumerGroup added in v0.0.46 

func (m *CreateConsumerConfig) GetRecreateConsumerGroup() bool

func (*CreateConsumerConfig) ProtoMessage added in v0.0.46 

func (*CreateConsumerConfig) ProtoMessage()

func (*CreateConsumerConfig) Reset added in v0.0.46 

func (m *CreateConsumerConfig) Reset()

func (*CreateConsumerConfig) String added in v0.0.46 

func (m *CreateConsumerConfig) String() string

func (*CreateConsumerConfig) XXX_DiscardUnknown added in v0.0.46 

func (m *CreateConsumerConfig) XXX_DiscardUnknown()

func (*CreateConsumerConfig) XXX_Marshal added in v0.0.46 

func (m *CreateConsumerConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateConsumerConfig) XXX_Merge added in v0.0.46 

func (m *CreateConsumerConfig) XXX_Merge(src proto.Message)

func (*CreateConsumerConfig) XXX_Size added in v0.0.46 

func (m *CreateConsumerConfig) XXX_Size() int

func (*CreateConsumerConfig) XXX_Unmarshal added in v0.0.46 

func (m *CreateConsumerConfig) XXX_Unmarshal(b []byte) error

type CreateConsumerConfig_OffsetStart added in v0.0.46 

type CreateConsumerConfig_OffsetStart int32
const (
	CreateConsumerConfig_Latest CreateConsumerConfig_OffsetStart = 0
	CreateConsumerConfig_Oldest CreateConsumerConfig_OffsetStart = 1
)

func (CreateConsumerConfig_OffsetStart) EnumDescriptor added in v0.0.46 

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

func (CreateConsumerConfig_OffsetStart) String added in v0.0.46 

func (x CreateConsumerConfig_OffsetStart) 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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GCPPubSubConn) Descriptor added in v0.0.46 

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

func (*GCPPubSubConn) GetProjectId added in v0.0.46 

func (m *GCPPubSubConn) GetProjectId() string

func (*GCPPubSubConn) ProtoMessage added in v0.0.46 

func (*GCPPubSubConn) ProtoMessage()

func (*GCPPubSubConn) Reset added in v0.0.46 

func (m *GCPPubSubConn) Reset()

func (*GCPPubSubConn) String added in v0.0.46 

func (m *GCPPubSubConn) String() string

func (*GCPPubSubConn) XXX_DiscardUnknown added in v0.0.46 

func (m *GCPPubSubConn) XXX_DiscardUnknown()

func (*GCPPubSubConn) XXX_Marshal added in v0.0.46 

func (m *GCPPubSubConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GCPPubSubConn) XXX_Merge added in v0.0.46 

func (m *GCPPubSubConn) XXX_Merge(src proto.Message)

func (*GCPPubSubConn) XXX_Size added in v0.0.46 

func (m *GCPPubSubConn) XXX_Size() int

func (*GCPPubSubConn) XXX_Unmarshal added in v0.0.46 

func (m *GCPPubSubConn) XXX_Unmarshal(b []byte) error

type GCPPubSubReadOpts added in v0.0.46 

type GCPPubSubReadOpts 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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GCPPubSubReadOpts) Descriptor added in v0.0.46 

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

func (*GCPPubSubReadOpts) GetAckMessages added in v0.0.46 

func (m *GCPPubSubReadOpts) GetAckMessages() bool

func (*GCPPubSubReadOpts) GetSubscriptionId added in v0.0.46 

func (m *GCPPubSubReadOpts) GetSubscriptionId() string

func (*GCPPubSubReadOpts) ProtoMessage added in v0.0.46 

func (*GCPPubSubReadOpts) ProtoMessage()

func (*GCPPubSubReadOpts) Reset added in v0.0.46 

func (m *GCPPubSubReadOpts) Reset()

func (*GCPPubSubReadOpts) String added in v0.0.46 

func (m *GCPPubSubReadOpts) String() string

func (*GCPPubSubReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *GCPPubSubReadOpts) XXX_DiscardUnknown()

func (*GCPPubSubReadOpts) XXX_Marshal added in v0.0.46 

func (m *GCPPubSubReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GCPPubSubReadOpts) XXX_Merge added in v0.0.46 

func (m *GCPPubSubReadOpts) XXX_Merge(src proto.Message)

func (*GCPPubSubReadOpts) XXX_Size added in v0.0.46 

func (m *GCPPubSubReadOpts) XXX_Size() int

func (*GCPPubSubReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *GCPPubSubReadOpts) XXX_Unmarshal(b []byte) error

type GCPPubSubWriteOpts added in v0.0.46 

type GCPPubSubWriteOpts struct {
	// @gotags: kong:"help='Topic ID to publish message(s) to',required"
	TopicId              string   `` /* 139-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GCPPubSubWriteOpts) Descriptor added in v0.0.46 

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

func (*GCPPubSubWriteOpts) GetTopicId added in v0.0.46 

func (m *GCPPubSubWriteOpts) GetTopicId() string

func (*GCPPubSubWriteOpts) ProtoMessage added in v0.0.46 

func (*GCPPubSubWriteOpts) ProtoMessage()

func (*GCPPubSubWriteOpts) Reset added in v0.0.46 

func (m *GCPPubSubWriteOpts) Reset()

func (*GCPPubSubWriteOpts) String added in v0.0.46 

func (m *GCPPubSubWriteOpts) String() string

func (*GCPPubSubWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *GCPPubSubWriteOpts) XXX_DiscardUnknown()

func (*GCPPubSubWriteOpts) XXX_Marshal added in v0.0.46 

func (m *GCPPubSubWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GCPPubSubWriteOpts) XXX_Merge added in v0.0.46 

func (m *GCPPubSubWriteOpts) XXX_Merge(src proto.Message)

func (*GCPPubSubWriteOpts) XXX_Size added in v0.0.46 

func (m *GCPPubSubWriteOpts) XXX_Size() int

func (*GCPPubSubWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *GCPPubSubWriteOpts) XXX_Unmarshal(b []byte) error

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 `` /* 210-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"
	InsecureTls bool `` /* 171-byte string literal not displayed */
	// @gotags: kong:"help='SASL authentication type (0 - none, 1 - plain, 2 - scram)',env=PLUMBER_RELAY_KAFKA_SASL_TYPE,default=2"
	SaslType KafkaConn_SASLType `` /* 238-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. If omitted, you will be prompted for the password',env=PLUMBER_RELAY_KAFKA_PASSWORD"
	SaslPassword         string   `` /* 209-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KafkaConn) Descriptor added in v0.0.46 

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

func (*KafkaConn) GetAddress added in v0.0.46 

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

func (*KafkaConn) GetInsecureTls added in v0.0.46 

func (m *KafkaConn) GetInsecureTls() bool

func (*KafkaConn) GetSaslPassword added in v0.0.46 

func (m *KafkaConn) GetSaslPassword() string

func (*KafkaConn) GetSaslType added in v0.0.46 

func (m *KafkaConn) GetSaslType() KafkaConn_SASLType

func (*KafkaConn) GetSaslUsername added in v0.0.46 

func (m *KafkaConn) GetSaslUsername() string

func (*KafkaConn) GetTimeoutSeconds added in v0.0.46 

func (m *KafkaConn) GetTimeoutSeconds() int32

func (*KafkaConn) GetUseTls added in v0.0.46 

func (m *KafkaConn) GetUseTls() bool

func (*KafkaConn) ProtoMessage added in v0.0.46 

func (*KafkaConn) ProtoMessage()

func (*KafkaConn) Reset added in v0.0.46 

func (m *KafkaConn) Reset()

func (*KafkaConn) String added in v0.0.46 

func (m *KafkaConn) String() string

func (*KafkaConn) XXX_DiscardUnknown added in v0.0.46 

func (m *KafkaConn) XXX_DiscardUnknown()

func (*KafkaConn) XXX_Marshal added in v0.0.46 

func (m *KafkaConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KafkaConn) XXX_Merge added in v0.0.46 

func (m *KafkaConn) XXX_Merge(src proto.Message)

func (*KafkaConn) XXX_Size added in v0.0.46 

func (m *KafkaConn) XXX_Size() int

func (*KafkaConn) XXX_Unmarshal added in v0.0.46 

func (m *KafkaConn) XXX_Unmarshal(b []byte) error

type KafkaConn_SASLType added in v0.0.46 

type KafkaConn_SASLType int32
const (
	KafkaConn_NONE  KafkaConn_SASLType = 0
	KafkaConn_PLAIN KafkaConn_SASLType = 1
	KafkaConn_SCRAM KafkaConn_SASLType = 2
)

func (KafkaConn_SASLType) EnumDescriptor added in v0.0.46 

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

func (KafkaConn_SASLType) String added in v0.0.46 

func (x KafkaConn_SASLType) String() string

type KafkaLagArgs added in v0.0.46 

type KafkaLagArgs struct {
	// @gotags: kong:"help='What consumer group to look up lag for (leave blank if all)'"
	GroupId              string   `` /* 156-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KafkaLagArgs) Descriptor added in v0.0.46 

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

func (*KafkaLagArgs) GetGroupId added in v0.0.46 

func (m *KafkaLagArgs) GetGroupId() string

func (*KafkaLagArgs) ProtoMessage added in v0.0.46 

func (*KafkaLagArgs) ProtoMessage()

func (*KafkaLagArgs) Reset added in v0.0.46 

func (m *KafkaLagArgs) Reset()

func (*KafkaLagArgs) String added in v0.0.46 

func (m *KafkaLagArgs) String() string

func (*KafkaLagArgs) XXX_DiscardUnknown added in v0.0.46 

func (m *KafkaLagArgs) XXX_DiscardUnknown()

func (*KafkaLagArgs) XXX_Marshal added in v0.0.46 

func (m *KafkaLagArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KafkaLagArgs) XXX_Merge added in v0.0.46 

func (m *KafkaLagArgs) XXX_Merge(src proto.Message)

func (*KafkaLagArgs) XXX_Size added in v0.0.46 

func (m *KafkaLagArgs) XXX_Size() int

func (*KafkaLagArgs) XXX_Unmarshal added in v0.0.46 

func (m *KafkaLagArgs) XXX_Unmarshal(b []byte) error

type KafkaReadOpts added in v0.0.46 

type KafkaReadOpts struct {
	// @gotags: kong:"help='Topic(s) to read, write or get lag stats for',required"
	Topics []string `` /* 133-byte string literal not displayed */
	// @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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KafkaReadOpts) Descriptor added in v0.0.46 

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

func (*KafkaReadOpts) GetCommitIntervalSeconds added in v0.0.46 

func (m *KafkaReadOpts) GetCommitIntervalSeconds() int32

func (*KafkaReadOpts) GetConsumerGroupName added in v0.0.46 

func (m *KafkaReadOpts) GetConsumerGroupName() string

func (*KafkaReadOpts) GetMaxBytes added in v0.0.46 

func (m *KafkaReadOpts) GetMaxBytes() int32

func (*KafkaReadOpts) GetMaxWaitSeconds added in v0.0.46 

func (m *KafkaReadOpts) GetMaxWaitSeconds() int32

func (*KafkaReadOpts) GetMinBytes added in v0.0.46 

func (m *KafkaReadOpts) GetMinBytes() int32

func (*KafkaReadOpts) GetQueueCapacity added in v0.0.46 

func (m *KafkaReadOpts) GetQueueCapacity() int32

func (*KafkaReadOpts) GetReadOffset added in v0.0.46 

func (m *KafkaReadOpts) GetReadOffset() int64

func (*KafkaReadOpts) GetRebalanceTimeoutSeconds added in v0.0.46 

func (m *KafkaReadOpts) GetRebalanceTimeoutSeconds() int32

func (*KafkaReadOpts) GetTopics added in v0.0.46 

func (m *KafkaReadOpts) GetTopics() []string

func (*KafkaReadOpts) GetUseConsumerGroup added in v0.0.46 

func (m *KafkaReadOpts) GetUseConsumerGroup() bool

func (*KafkaReadOpts) ProtoMessage added in v0.0.46 

func (*KafkaReadOpts) ProtoMessage()

func (*KafkaReadOpts) Reset added in v0.0.46 

func (m *KafkaReadOpts) Reset()

func (*KafkaReadOpts) String added in v0.0.46 

func (m *KafkaReadOpts) String() string

func (*KafkaReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *KafkaReadOpts) XXX_DiscardUnknown()

func (*KafkaReadOpts) XXX_Marshal added in v0.0.46 

func (m *KafkaReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KafkaReadOpts) XXX_Merge added in v0.0.46 

func (m *KafkaReadOpts) XXX_Merge(src proto.Message)

func (*KafkaReadOpts) XXX_Size added in v0.0.46 

func (m *KafkaReadOpts) XXX_Size() int

func (*KafkaReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *KafkaReadOpts) XXX_Unmarshal(b []byte) error

type KafkaRelayOpts added in v0.0.46 

type KafkaRelayOpts 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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KafkaRelayOpts) Descriptor added in v0.0.46 

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

func (*KafkaRelayOpts) GetCommitIntervalSeconds added in v0.0.46 

func (m *KafkaRelayOpts) GetCommitIntervalSeconds() int32

func (*KafkaRelayOpts) GetConsumerGroupName added in v0.0.46 

func (m *KafkaRelayOpts) GetConsumerGroupName() string

func (*KafkaRelayOpts) GetMaxBytes added in v0.0.46 

func (m *KafkaRelayOpts) GetMaxBytes() int32

func (*KafkaRelayOpts) GetMaxWaitSeconds added in v0.0.46 

func (m *KafkaRelayOpts) GetMaxWaitSeconds() int32

func (*KafkaRelayOpts) GetMinBytes added in v0.0.46 

func (m *KafkaRelayOpts) GetMinBytes() int32

func (*KafkaRelayOpts) GetQueueCapacity added in v0.0.46 

func (m *KafkaRelayOpts) GetQueueCapacity() int32

func (*KafkaRelayOpts) GetReadOffset added in v0.0.46 

func (m *KafkaRelayOpts) GetReadOffset() int64

func (*KafkaRelayOpts) GetRebalanceTimeoutSeconds added in v0.0.46 

func (m *KafkaRelayOpts) GetRebalanceTimeoutSeconds() int32

func (*KafkaRelayOpts) GetTopics added in v0.0.46 

func (m *KafkaRelayOpts) GetTopics() []string

func (*KafkaRelayOpts) GetUseConsumerGroup added in v0.0.46 

func (m *KafkaRelayOpts) GetUseConsumerGroup() bool

func (*KafkaRelayOpts) ProtoMessage added in v0.0.46 

func (*KafkaRelayOpts) ProtoMessage()

func (*KafkaRelayOpts) Reset added in v0.0.46 

func (m *KafkaRelayOpts) Reset()

func (*KafkaRelayOpts) String added in v0.0.46 

func (m *KafkaRelayOpts) String() string

func (*KafkaRelayOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *KafkaRelayOpts) XXX_DiscardUnknown()

func (*KafkaRelayOpts) XXX_Marshal added in v0.0.46 

func (m *KafkaRelayOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KafkaRelayOpts) XXX_Merge added in v0.0.46 

func (m *KafkaRelayOpts) XXX_Merge(src proto.Message)

func (*KafkaRelayOpts) XXX_Size added in v0.0.46 

func (m *KafkaRelayOpts) XXX_Size() int

func (*KafkaRelayOpts) XXX_Unmarshal added in v0.0.46 

func (m *KafkaRelayOpts) XXX_Unmarshal(b []byte) error

type KafkaWriteOpts added in v0.0.46 

type KafkaWriteOpts 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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*KafkaWriteOpts) Descriptor added in v0.0.46 

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

func (*KafkaWriteOpts) GetHeaders added in v0.0.46 

func (m *KafkaWriteOpts) GetHeaders() map[string]string

func (*KafkaWriteOpts) GetKey added in v0.0.46 

func (m *KafkaWriteOpts) GetKey() string

func (*KafkaWriteOpts) ProtoMessage added in v0.0.46 

func (*KafkaWriteOpts) ProtoMessage()

func (*KafkaWriteOpts) Reset added in v0.0.46 

func (m *KafkaWriteOpts) Reset()

func (*KafkaWriteOpts) String added in v0.0.46 

func (m *KafkaWriteOpts) String() string

func (*KafkaWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *KafkaWriteOpts) XXX_DiscardUnknown()

func (*KafkaWriteOpts) XXX_Marshal added in v0.0.46 

func (m *KafkaWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KafkaWriteOpts) XXX_Merge added in v0.0.46 

func (m *KafkaWriteOpts) XXX_Merge(src proto.Message)

func (*KafkaWriteOpts) XXX_Size added in v0.0.46 

func (m *KafkaWriteOpts) XXX_Size() int

func (*KafkaWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *KafkaWriteOpts) XXX_Unmarshal(b []byte) error

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_CERT_FILE',type=existingfile"
	TlsCertFile          string   `` /* 199-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KubeMQQueueConn) Descriptor added in v0.0.46 

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

func (*KubeMQQueueConn) GetAddress added in v0.0.46 

func (m *KubeMQQueueConn) GetAddress() string

func (*KubeMQQueueConn) GetAuthToken added in v0.0.46 

func (m *KubeMQQueueConn) GetAuthToken() string

func (*KubeMQQueueConn) GetTlsCertFile added in v0.0.46 

func (m *KubeMQQueueConn) GetTlsCertFile() string

func (*KubeMQQueueConn) ProtoMessage added in v0.0.46 

func (*KubeMQQueueConn) ProtoMessage()

func (*KubeMQQueueConn) Reset added in v0.0.46 

func (m *KubeMQQueueConn) Reset()

func (*KubeMQQueueConn) String added in v0.0.46 

func (m *KubeMQQueueConn) String() string

func (*KubeMQQueueConn) XXX_DiscardUnknown added in v0.0.46 

func (m *KubeMQQueueConn) XXX_DiscardUnknown()

func (*KubeMQQueueConn) XXX_Marshal added in v0.0.46 

func (m *KubeMQQueueConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KubeMQQueueConn) XXX_Merge added in v0.0.46 

func (m *KubeMQQueueConn) XXX_Merge(src proto.Message)

func (*KubeMQQueueConn) XXX_Size added in v0.0.46 

func (m *KubeMQQueueConn) XXX_Size() int

func (*KubeMQQueueConn) XXX_Unmarshal added in v0.0.46 

func (m *KubeMQQueueConn) XXX_Unmarshal(b []byte) error

type KubeMQQueueReadOpts added in v0.0.46 

type KubeMQQueueReadOpts struct {
	// @gotags: kong:"help='KubeMQ client ID',env='PLUMBER_RELAY_KUBEMQ_QUEUE_CLIENT_ID',default=plumber"
	ClientId string `` /* 175-byte string literal not displayed */
	// @gotags: kong:"help='KubeMQ queue name',env='PLUMBER_RELAY_KUBEMQ_QUEUE_QUEUE'"
	QueueName            string   `` /* 159-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KubeMQQueueReadOpts) Descriptor added in v0.0.46 

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

func (*KubeMQQueueReadOpts) GetClientId added in v0.0.46 

func (m *KubeMQQueueReadOpts) GetClientId() string

func (*KubeMQQueueReadOpts) GetQueueName added in v0.0.46 

func (m *KubeMQQueueReadOpts) GetQueueName() string

func (*KubeMQQueueReadOpts) ProtoMessage added in v0.0.46 

func (*KubeMQQueueReadOpts) ProtoMessage()

func (*KubeMQQueueReadOpts) Reset added in v0.0.46 

func (m *KubeMQQueueReadOpts) Reset()

func (*KubeMQQueueReadOpts) String added in v0.0.46 

func (m *KubeMQQueueReadOpts) String() string

func (*KubeMQQueueReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *KubeMQQueueReadOpts) XXX_DiscardUnknown()

func (*KubeMQQueueReadOpts) XXX_Marshal added in v0.0.46 

func (m *KubeMQQueueReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KubeMQQueueReadOpts) XXX_Merge added in v0.0.46 

func (m *KubeMQQueueReadOpts) XXX_Merge(src proto.Message)

func (*KubeMQQueueReadOpts) XXX_Size added in v0.0.46 

func (m *KubeMQQueueReadOpts) XXX_Size() int

func (*KubeMQQueueReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *KubeMQQueueReadOpts) XXX_Unmarshal(b []byte) error

type KubeMQQueueWriteOpts added in v0.0.46 

type KubeMQQueueWriteOpts struct {
	// @gotags: kong:"help='KubeMQ client ID',default=plumber"
	ClientId string `` /* 132-byte string literal not displayed */
	// @gotags: kong:"help='KubeMQ queue name'"
	QueueName            string   `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty" kong:"help='KubeMQ queue name'"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KubeMQQueueWriteOpts) Descriptor added in v0.0.46 

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

func (*KubeMQQueueWriteOpts) GetClientId added in v0.0.46 

func (m *KubeMQQueueWriteOpts) GetClientId() string

func (*KubeMQQueueWriteOpts) GetQueueName added in v0.0.46 

func (m *KubeMQQueueWriteOpts) GetQueueName() string

func (*KubeMQQueueWriteOpts) ProtoMessage added in v0.0.46 

func (*KubeMQQueueWriteOpts) ProtoMessage()

func (*KubeMQQueueWriteOpts) Reset added in v0.0.46 

func (m *KubeMQQueueWriteOpts) Reset()

func (*KubeMQQueueWriteOpts) String added in v0.0.46 

func (m *KubeMQQueueWriteOpts) String() string

func (*KubeMQQueueWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *KubeMQQueueWriteOpts) XXX_DiscardUnknown()

func (*KubeMQQueueWriteOpts) XXX_Marshal added in v0.0.46 

func (m *KubeMQQueueWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KubeMQQueueWriteOpts) XXX_Merge added in v0.0.46 

func (m *KubeMQQueueWriteOpts) XXX_Merge(src proto.Message)

func (*KubeMQQueueWriteOpts) XXX_Size added in v0.0.46 

func (m *KubeMQQueueWriteOpts) XXX_Size() int

func (*KubeMQQueueWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *KubeMQQueueWriteOpts) XXX_Unmarshal(b []byte) error

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 (0: at most once, 1: at least once, 2: exactly once)',enum='0,1,2',env=PLUMBER_RELAY_MQTT_QOS,default=0"
	QosLevel uint32 `` /* 232-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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*MQTTConn) Descriptor added in v0.0.46 

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

func (*MQTTConn) GetAddress added in v0.0.46 

func (m *MQTTConn) GetAddress() string

func (*MQTTConn) GetClientId added in v0.0.46 

func (m *MQTTConn) GetClientId() string

func (*MQTTConn) GetConnTimeoutSeconds added in v0.0.46 

func (m *MQTTConn) GetConnTimeoutSeconds() uint32

func (*MQTTConn) GetQosLevel added in v0.0.46 

func (m *MQTTConn) GetQosLevel() uint32

func (*MQTTConn) GetTlsOptions added in v0.0.46 

func (m *MQTTConn) GetTlsOptions() *MQTTTLSOptions

func (*MQTTConn) ProtoMessage added in v0.0.46 

func (*MQTTConn) ProtoMessage()

func (*MQTTConn) Reset added in v0.0.46 

func (m *MQTTConn) Reset()

func (*MQTTConn) String added in v0.0.46 

func (m *MQTTConn) String() string

func (*MQTTConn) XXX_DiscardUnknown added in v0.0.46 

func (m *MQTTConn) XXX_DiscardUnknown()

func (*MQTTConn) XXX_Marshal added in v0.0.46 

func (m *MQTTConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MQTTConn) XXX_Merge added in v0.0.46 

func (m *MQTTConn) XXX_Merge(src proto.Message)

func (*MQTTConn) XXX_Size added in v0.0.46 

func (m *MQTTConn) XXX_Size() int

func (*MQTTConn) XXX_Unmarshal added in v0.0.46 

func (m *MQTTConn) XXX_Unmarshal(b []byte) error

type MQTTQoSLevel added in v0.0.46 

type MQTTQoSLevel int32

TODO: This needs to be used by CLI 

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) EnumDescriptor added in v0.0.46 

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

func (MQTTQoSLevel) String added in v0.0.46 

func (x MQTTQoSLevel) String() string

type MQTTReadOpts added in v0.0.46 

type MQTTReadOpts 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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MQTTReadOpts) Descriptor added in v0.0.46 

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

func (*MQTTReadOpts) GetReadTimeoutSeconds added in v0.0.46 

func (m *MQTTReadOpts) GetReadTimeoutSeconds() uint32

func (*MQTTReadOpts) GetTopic added in v0.0.46 

func (m *MQTTReadOpts) GetTopic() string

func (*MQTTReadOpts) ProtoMessage added in v0.0.46 

func (*MQTTReadOpts) ProtoMessage()

func (*MQTTReadOpts) Reset added in v0.0.46 

func (m *MQTTReadOpts) Reset()

func (*MQTTReadOpts) String added in v0.0.46 

func (m *MQTTReadOpts) String() string

func (*MQTTReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *MQTTReadOpts) XXX_DiscardUnknown()

func (*MQTTReadOpts) XXX_Marshal added in v0.0.46 

func (m *MQTTReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MQTTReadOpts) XXX_Merge added in v0.0.46 

func (m *MQTTReadOpts) XXX_Merge(src proto.Message)

func (*MQTTReadOpts) XXX_Size added in v0.0.46 

func (m *MQTTReadOpts) XXX_Size() int

func (*MQTTReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *MQTTReadOpts) XXX_Unmarshal(b []byte) error

type MQTTTLSOptions added in v0.0.46 

type MQTTTLSOptions struct {
	// @gotags: kong:"help='CA file (only needed if addr is ssl://)',env=PLUMBER_RELAY_MQTT_TLS_CA_FILE,type=existingfile"
	CaFile string `` /* 186-byte string literal not displayed */
	// @gotags: kong:"help='Client cert file (only needed if addr is ssl://)',env=PLUMBER_RELAY_MQTT_TLS_CERT_FILE,type=existingfile"
	CertFile string `` /* 203-byte string literal not displayed */
	// @gotags: kong:"help='Client key file (only needed if addr is ssl://)',env=PLUMBER_RELAY_MQTT_TLS_KEY_FILE,type=existingfile"
	KeyFile string `` /* 198-byte string literal not displayed */
	// @gotags: kong:"help='Whether to verify server certificate',env=PLUMBER_RELAY_MQTT_SKIP_VERIFY_TLS"
	SkipVerify           bool     `` /* 182-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MQTTTLSOptions) Descriptor added in v0.0.46 

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

func (*MQTTTLSOptions) GetCaFile added in v0.0.46 

func (m *MQTTTLSOptions) GetCaFile() string

func (*MQTTTLSOptions) GetCertFile added in v0.0.46 

func (m *MQTTTLSOptions) GetCertFile() string

func (*MQTTTLSOptions) GetKeyFile added in v0.0.46 

func (m *MQTTTLSOptions) GetKeyFile() string

func (*MQTTTLSOptions) GetSkipVerify added in v0.0.46 

func (m *MQTTTLSOptions) GetSkipVerify() bool

func (*MQTTTLSOptions) ProtoMessage added in v0.0.46 

func (*MQTTTLSOptions) ProtoMessage()

func (*MQTTTLSOptions) Reset added in v0.0.46 

func (m *MQTTTLSOptions) Reset()

func (*MQTTTLSOptions) String added in v0.0.46 

func (m *MQTTTLSOptions) String() string

func (*MQTTTLSOptions) XXX_DiscardUnknown added in v0.0.46 

func (m *MQTTTLSOptions) XXX_DiscardUnknown()

func (*MQTTTLSOptions) XXX_Marshal added in v0.0.46 

func (m *MQTTTLSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MQTTTLSOptions) XXX_Merge added in v0.0.46 

func (m *MQTTTLSOptions) XXX_Merge(src proto.Message)

func (*MQTTTLSOptions) XXX_Size added in v0.0.46 

func (m *MQTTTLSOptions) XXX_Size() int

func (*MQTTTLSOptions) XXX_Unmarshal added in v0.0.46 

func (m *MQTTTLSOptions) XXX_Unmarshal(b []byte) error

type MQTTWriteOpts added in v0.0.46 

type MQTTWriteOpts 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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MQTTWriteOpts) Descriptor added in v0.0.46 

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

func (*MQTTWriteOpts) GetTopic added in v0.0.46 

func (m *MQTTWriteOpts) GetTopic() string

func (*MQTTWriteOpts) GetWriteTimeoutSeconds added in v0.0.46 

func (m *MQTTWriteOpts) GetWriteTimeoutSeconds() uint32

func (*MQTTWriteOpts) ProtoMessage added in v0.0.46 

func (*MQTTWriteOpts) ProtoMessage()

func (*MQTTWriteOpts) Reset added in v0.0.46 

func (m *MQTTWriteOpts) Reset()

func (*MQTTWriteOpts) String added in v0.0.46 

func (m *MQTTWriteOpts) String() string

func (*MQTTWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *MQTTWriteOpts) XXX_DiscardUnknown()

func (*MQTTWriteOpts) XXX_Marshal added in v0.0.46 

func (m *MQTTWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MQTTWriteOpts) XXX_Merge added in v0.0.46 

func (m *MQTTWriteOpts) XXX_Merge(src proto.Message)

func (*MQTTWriteOpts) XXX_Size added in v0.0.46 

func (m *MQTTWriteOpts) XXX_Size() int

func (*MQTTWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *MQTTWriteOpts) XXX_Unmarshal(b []byte) error

type MongoConn added in v0.0.46 

type MongoConn struct {
	// @gotags: kong:"help='Dial string for mongo server (Ex: mongodb://localhost:27017)',env=,default=PLUMBER_RELAY_CDCMONGO_DSN'mongodb://localhost:27017'"
	Dsn                  string   `` /* 201-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MongoConn) Descriptor added in v0.0.46 

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

func (*MongoConn) GetDsn added in v0.0.46 

func (m *MongoConn) GetDsn() string

func (*MongoConn) ProtoMessage added in v0.0.46 

func (*MongoConn) ProtoMessage()

func (*MongoConn) Reset added in v0.0.46 

func (m *MongoConn) Reset()

func (*MongoConn) String added in v0.0.46 

func (m *MongoConn) String() string

func (*MongoConn) XXX_DiscardUnknown added in v0.0.46 

func (m *MongoConn) XXX_DiscardUnknown()

func (*MongoConn) XXX_Marshal added in v0.0.46 

func (m *MongoConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MongoConn) XXX_Merge added in v0.0.46 

func (m *MongoConn) XXX_Merge(src proto.Message)

func (*MongoConn) XXX_Size added in v0.0.46 

func (m *MongoConn) XXX_Size() int

func (*MongoConn) XXX_Unmarshal added in v0.0.46 

func (m *MongoConn) XXX_Unmarshal(b []byte) error

type MongoReadOpts added in v0.0.46 

type MongoReadOpts 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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MongoReadOpts) Descriptor added in v0.0.46 

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

func (*MongoReadOpts) GetCollection added in v0.0.46 

func (m *MongoReadOpts) GetCollection() string

func (*MongoReadOpts) GetDatabase added in v0.0.46 

func (m *MongoReadOpts) GetDatabase() string

func (*MongoReadOpts) GetIncludeFullDocument added in v0.0.46 

func (m *MongoReadOpts) GetIncludeFullDocument() bool

func (*MongoReadOpts) ProtoMessage added in v0.0.46 

func (*MongoReadOpts) ProtoMessage()

func (*MongoReadOpts) Reset added in v0.0.46 

func (m *MongoReadOpts) Reset()

func (*MongoReadOpts) String added in v0.0.46 

func (m *MongoReadOpts) String() string

func (*MongoReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *MongoReadOpts) XXX_DiscardUnknown()

func (*MongoReadOpts) XXX_Marshal added in v0.0.46 

func (m *MongoReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MongoReadOpts) XXX_Merge added in v0.0.46 

func (m *MongoReadOpts) XXX_Merge(src proto.Message)

func (*MongoReadOpts) XXX_Size added in v0.0.46 

func (m *MongoReadOpts) XXX_Size() int

func (*MongoReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *MongoReadOpts) XXX_Unmarshal(b []byte) error

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'"
	InsecureTls bool `` /* 186-byte string literal not displayed */
	// @gotags: kong:"help='CA file',env='PLUMBER_RELAY_NSQ_TLS_CA_FILE',type=existingfile"
	TlsCaCert []byte `` /* 166-byte string literal not displayed */
	// @gotags: kong:"help=”,env='PLUMBER_RELAY_NSQ_TLS_CERT_FILE',type=existingfile"
	TlsClientCert []byte `` /* 173-byte string literal not displayed */
	// @gotags: kong:"help=”,env='PLUMBER_RELAY_NSQ_TLS_KEY_FILE',type=existingfile"
	TlsClientKey []byte `` /* 169-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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NSQConn) Descriptor added in v0.0.46 

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

func (*NSQConn) GetAuthSecret added in v0.0.46 

func (m *NSQConn) GetAuthSecret() string

func (*NSQConn) GetClientId added in v0.0.46 

func (m *NSQConn) GetClientId() string

func (*NSQConn) GetInsecureTls added in v0.0.46 

func (m *NSQConn) GetInsecureTls() bool

func (*NSQConn) GetLookupdAddress added in v0.0.46 

func (m *NSQConn) GetLookupdAddress() string

func (*NSQConn) GetNsqdAddress added in v0.0.46 

func (m *NSQConn) GetNsqdAddress() string

func (*NSQConn) GetTlsCaCert added in v0.0.46 

func (m *NSQConn) GetTlsCaCert() []byte

func (*NSQConn) GetTlsClientCert added in v0.0.46 

func (m *NSQConn) GetTlsClientCert() []byte

func (*NSQConn) GetTlsClientKey added in v0.0.46 

func (m *NSQConn) GetTlsClientKey() []byte

func (*NSQConn) GetUseTls added in v0.0.46 

func (m *NSQConn) GetUseTls() bool

func (*NSQConn) ProtoMessage added in v0.0.46 

func (*NSQConn) ProtoMessage()

func (*NSQConn) Reset added in v0.0.46 

func (m *NSQConn) Reset()

func (*NSQConn) String added in v0.0.46 

func (m *NSQConn) String() string

func (*NSQConn) XXX_DiscardUnknown added in v0.0.46 

func (m *NSQConn) XXX_DiscardUnknown()

func (*NSQConn) XXX_Marshal added in v0.0.46 

func (m *NSQConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NSQConn) XXX_Merge added in v0.0.46 

func (m *NSQConn) XXX_Merge(src proto.Message)

func (*NSQConn) XXX_Size added in v0.0.46 

func (m *NSQConn) XXX_Size() int

func (*NSQConn) XXX_Unmarshal added in v0.0.46 

func (m *NSQConn) XXX_Unmarshal(b []byte) error

type NSQReadOpts added in v0.0.46 

type NSQReadOpts 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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NSQReadOpts) Descriptor added in v0.0.46 

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

func (*NSQReadOpts) GetChannel added in v0.0.46 

func (m *NSQReadOpts) GetChannel() string

func (*NSQReadOpts) GetTopic added in v0.0.46 

func (m *NSQReadOpts) GetTopic() string

func (*NSQReadOpts) ProtoMessage added in v0.0.46 

func (*NSQReadOpts) ProtoMessage()

func (*NSQReadOpts) Reset added in v0.0.46 

func (m *NSQReadOpts) Reset()

func (*NSQReadOpts) String added in v0.0.46 

func (m *NSQReadOpts) String() string

func (*NSQReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *NSQReadOpts) XXX_DiscardUnknown()

func (*NSQReadOpts) XXX_Marshal added in v0.0.46 

func (m *NSQReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NSQReadOpts) XXX_Merge added in v0.0.46 

func (m *NSQReadOpts) XXX_Merge(src proto.Message)

func (*NSQReadOpts) XXX_Size added in v0.0.46 

func (m *NSQReadOpts) XXX_Size() int

func (*NSQReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *NSQReadOpts) XXX_Unmarshal(b []byte) error

type NSQWriteOpts added in v0.0.46 

type NSQWriteOpts 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NSQWriteOpts) Descriptor added in v0.0.46 

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

func (*NSQWriteOpts) GetTopic added in v0.0.46 

func (m *NSQWriteOpts) GetTopic() string

func (*NSQWriteOpts) ProtoMessage added in v0.0.46 

func (*NSQWriteOpts) ProtoMessage()

func (*NSQWriteOpts) Reset added in v0.0.46 

func (m *NSQWriteOpts) Reset()

func (*NSQWriteOpts) String added in v0.0.46 

func (m *NSQWriteOpts) String() string

func (*NSQWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *NSQWriteOpts) XXX_DiscardUnknown()

func (*NSQWriteOpts) XXX_Marshal added in v0.0.46 

func (m *NSQWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NSQWriteOpts) XXX_Merge added in v0.0.46 

func (m *NSQWriteOpts) XXX_Merge(src proto.Message)

func (*NSQWriteOpts) XXX_Size added in v0.0.46 

func (m *NSQWriteOpts) XXX_Size() int

func (*NSQWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *NSQWriteOpts) XXX_Unmarshal(b []byte) error

type NatsConn added in v0.0.46 

type NatsConn struct {
	// @gotags: kong:"help='Dial string for NATS server. Ex: nats://localhost:4222',default='nas://localhost:4222'"
	Dsn string `` /* 159-byte string literal not displayed */
	// @gotags: kong:"help='Whether to verify server certificate'"
	InsecureTls bool `` /* 146-byte string literal not displayed */
	// @gotags: kong:"help='CA file (only needed if addr is tls://)',type=existingfile"
	TlsCaCert []byte `` /* 162-byte string literal not displayed */
	// @gotags: kong:"help='Client cert file (only needed if addr is tls://)',type=existingfile"
	TlsClientCert []byte `` /* 183-byte string literal not displayed */
	// @gotags: kong:"help='client key file (only needed if addr is tls://)',type=existingfile"
	TlsClientKey []byte `` /* 179-byte string literal not displayed */
	// @gotags: kong:"help='NATS .creds file containing authentication credentials',type=existingfile"
	UserCredentials      []byte   `` /* 193-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NatsConn) Descriptor added in v0.0.46 

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

func (*NatsConn) GetDsn added in v0.0.46 

func (m *NatsConn) GetDsn() string

func (*NatsConn) GetInsecureTls added in v0.0.46 

func (m *NatsConn) GetInsecureTls() bool

func (*NatsConn) GetTlsCaCert added in v0.0.46 

func (m *NatsConn) GetTlsCaCert() []byte

func (*NatsConn) GetTlsClientCert added in v0.0.46 

func (m *NatsConn) GetTlsClientCert() []byte

func (*NatsConn) GetTlsClientKey added in v0.0.46 

func (m *NatsConn) GetTlsClientKey() []byte

func (*NatsConn) GetUserCredentials added in v0.0.46 

func (m *NatsConn) GetUserCredentials() []byte

func (*NatsConn) ProtoMessage added in v0.0.46 

func (*NatsConn) ProtoMessage()

func (*NatsConn) Reset added in v0.0.46 

func (m *NatsConn) Reset()

func (*NatsConn) String added in v0.0.46 

func (m *NatsConn) String() string

func (*NatsConn) XXX_DiscardUnknown added in v0.0.46 

func (m *NatsConn) XXX_DiscardUnknown()

func (*NatsConn) XXX_Marshal added in v0.0.46 

func (m *NatsConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NatsConn) XXX_Merge added in v0.0.46 

func (m *NatsConn) XXX_Merge(src proto.Message)

func (*NatsConn) XXX_Size added in v0.0.46 

func (m *NatsConn) XXX_Size() int

func (*NatsConn) XXX_Unmarshal added in v0.0.46 

func (m *NatsConn) XXX_Unmarshal(b []byte) error

type NatsReadOpts added in v0.0.46 

type NatsReadOpts 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.*'"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NatsReadOpts) Descriptor added in v0.0.46 

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

func (*NatsReadOpts) GetSubject added in v0.0.46 

func (m *NatsReadOpts) GetSubject() string

func (*NatsReadOpts) ProtoMessage added in v0.0.46 

func (*NatsReadOpts) ProtoMessage()

func (*NatsReadOpts) Reset added in v0.0.46 

func (m *NatsReadOpts) Reset()

func (*NatsReadOpts) String added in v0.0.46 

func (m *NatsReadOpts) String() string

func (*NatsReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *NatsReadOpts) XXX_DiscardUnknown()

func (*NatsReadOpts) XXX_Marshal added in v0.0.46 

func (m *NatsReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NatsReadOpts) XXX_Merge added in v0.0.46 

func (m *NatsReadOpts) XXX_Merge(src proto.Message)

func (*NatsReadOpts) XXX_Size added in v0.0.46 

func (m *NatsReadOpts) XXX_Size() int

func (*NatsReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *NatsReadOpts) XXX_Unmarshal(b []byte) error

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'"
	Dsn string `` /* 160-byte string literal not displayed */
	// @gotags: kong:"help='Whether to verify server certificate'"
	InsecureTls bool `` /* 146-byte string literal not displayed */
	// @gotags: kong:"help='CA file (only needed if addr is tls://)*',type=existingfile"
	TlsCaCert []byte `` /* 163-byte string literal not displayed */
	// @gotags: kong:"help='Cient cert file (only needed if addr is tls://*)',type=existingfile"
	TlsClientCert []byte `` /* 183-byte string literal not displayed */
	// @gotags: kong:"help='Client key file (only needed if addr is tls://*)',type=existingfile"
	TlsClientKey []byte `` /* 180-byte string literal not displayed */
	// @gotags: kong:"help='NATS .creds file containing authentication credentials'"
	UserCredentials []byte `` /* 175-byte string literal not displayed */
	// @gotags: kong:"help='Cluster ID of the Nats server',required"
	ClusterId string `` /* 141-byte string literal not displayed */
	// @gotags: kong:"help='User specified client ID to connect with',default=plumber"
	ClientId             string   `` /* 156-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NatsStreamingConn) Descriptor added in v0.0.46 

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

func (*NatsStreamingConn) GetClientId added in v0.0.46 

func (m *NatsStreamingConn) GetClientId() string

func (*NatsStreamingConn) GetClusterId added in v0.0.46 

func (m *NatsStreamingConn) GetClusterId() string

func (*NatsStreamingConn) GetDsn added in v0.0.46 

func (m *NatsStreamingConn) GetDsn() string

func (*NatsStreamingConn) GetInsecureTls added in v0.0.46 

func (m *NatsStreamingConn) GetInsecureTls() bool

func (*NatsStreamingConn) GetTlsCaCert added in v0.0.46 

func (m *NatsStreamingConn) GetTlsCaCert() []byte

func (*NatsStreamingConn) GetTlsClientCert added in v0.0.46 

func (m *NatsStreamingConn) GetTlsClientCert() []byte

func (*NatsStreamingConn) GetTlsClientKey added in v0.0.46 

func (m *NatsStreamingConn) GetTlsClientKey() []byte

func (*NatsStreamingConn) GetUserCredentials added in v0.0.46 

func (m *NatsStreamingConn) GetUserCredentials() []byte

func (*NatsStreamingConn) ProtoMessage added in v0.0.46 

func (*NatsStreamingConn) ProtoMessage()

func (*NatsStreamingConn) Reset added in v0.0.46 

func (m *NatsStreamingConn) Reset()

func (*NatsStreamingConn) String added in v0.0.46 

func (m *NatsStreamingConn) String() string

func (*NatsStreamingConn) XXX_DiscardUnknown added in v0.0.46 

func (m *NatsStreamingConn) XXX_DiscardUnknown()

func (*NatsStreamingConn) XXX_Marshal added in v0.0.46 

func (m *NatsStreamingConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NatsStreamingConn) XXX_Merge added in v0.0.46 

func (m *NatsStreamingConn) XXX_Merge(src proto.Message)

func (*NatsStreamingConn) XXX_Size added in v0.0.46 

func (m *NatsStreamingConn) XXX_Size() int

func (*NatsStreamingConn) XXX_Unmarshal added in v0.0.46 

func (m *NatsStreamingConn) XXX_Unmarshal(b []byte) error

type NatsStreamingReadOpts added in v0.0.46 

type NatsStreamingReadOpts 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'"`
	// @gotags: kong:"help='Create a durable subscription with this name for the given channel'"
	DurableName string `` /* 175-byte string literal not displayed */
	// @gotags: kong:"help='Deliver starting with last published message',xor=nats_delivery_option"
	ReadLastAvailable bool `` /* 199-byte string literal not displayed */
	// @gotags: kong:"help='Deliver messages starting at sequence number',xor=nats_delivery_option"
	ReadSequenceNumber uint32 `` /* 202-byte string literal not displayed */
	// @gotags: kong:"help='Deliver messages in last interval (e.g. 1s, 1h)',xor=nats_delivery_option"
	ReadSince string `` /* 175-byte string literal not displayed */
	// @gotags: kong:"help='Deliver all available messages',xor=nats_delivery_option"
	ReadAll              bool     `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NatsStreamingReadOpts) Descriptor added in v0.0.46 

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

func (*NatsStreamingReadOpts) GetChannel added in v0.0.46 

func (m *NatsStreamingReadOpts) GetChannel() string

func (*NatsStreamingReadOpts) GetDurableName added in v0.0.46 

func (m *NatsStreamingReadOpts) GetDurableName() string

func (*NatsStreamingReadOpts) GetReadAll added in v0.0.46 

func (m *NatsStreamingReadOpts) GetReadAll() bool

func (*NatsStreamingReadOpts) GetReadLastAvailable added in v0.0.46 

func (m *NatsStreamingReadOpts) GetReadLastAvailable() bool

func (*NatsStreamingReadOpts) GetReadSequenceNumber added in v0.0.46 

func (m *NatsStreamingReadOpts) GetReadSequenceNumber() uint32

func (*NatsStreamingReadOpts) GetReadSince added in v0.0.46 

func (m *NatsStreamingReadOpts) GetReadSince() string

func (*NatsStreamingReadOpts) ProtoMessage added in v0.0.46 

func (*NatsStreamingReadOpts) ProtoMessage()

func (*NatsStreamingReadOpts) Reset added in v0.0.46 

func (m *NatsStreamingReadOpts) Reset()

func (*NatsStreamingReadOpts) String added in v0.0.46 

func (m *NatsStreamingReadOpts) String() string

func (*NatsStreamingReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *NatsStreamingReadOpts) XXX_DiscardUnknown()

func (*NatsStreamingReadOpts) XXX_Marshal added in v0.0.46 

func (m *NatsStreamingReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NatsStreamingReadOpts) XXX_Merge added in v0.0.46 

func (m *NatsStreamingReadOpts) XXX_Merge(src proto.Message)

func (*NatsStreamingReadOpts) XXX_Size added in v0.0.46 

func (m *NatsStreamingReadOpts) XXX_Size() int

func (*NatsStreamingReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *NatsStreamingReadOpts) XXX_Unmarshal(b []byte) error

type NatsStreamingWriteOpts added in v0.0.46 

type NatsStreamingWriteOpts 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'"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NatsStreamingWriteOpts) Descriptor added in v0.0.46 

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

func (*NatsStreamingWriteOpts) GetChannel added in v0.0.46 

func (m *NatsStreamingWriteOpts) GetChannel() string

func (*NatsStreamingWriteOpts) ProtoMessage added in v0.0.46 

func (*NatsStreamingWriteOpts) ProtoMessage()

func (*NatsStreamingWriteOpts) Reset added in v0.0.46 

func (m *NatsStreamingWriteOpts) Reset()

func (*NatsStreamingWriteOpts) String added in v0.0.46 

func (m *NatsStreamingWriteOpts) String() string

func (*NatsStreamingWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *NatsStreamingWriteOpts) XXX_DiscardUnknown()

func (*NatsStreamingWriteOpts) XXX_Marshal added in v0.0.46 

func (m *NatsStreamingWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NatsStreamingWriteOpts) XXX_Merge added in v0.0.46 

func (m *NatsStreamingWriteOpts) XXX_Merge(src proto.Message)

func (*NatsStreamingWriteOpts) XXX_Size added in v0.0.46 

func (m *NatsStreamingWriteOpts) XXX_Size() int

func (*NatsStreamingWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *NatsStreamingWriteOpts) XXX_Unmarshal(b []byte) error

type NatsWriteOpts added in v0.0.46 

type NatsWriteOpts 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.*'"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NatsWriteOpts) Descriptor added in v0.0.46 

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

func (*NatsWriteOpts) GetSubject added in v0.0.46 

func (m *NatsWriteOpts) GetSubject() string

func (*NatsWriteOpts) ProtoMessage added in v0.0.46 

func (*NatsWriteOpts) ProtoMessage()

func (*NatsWriteOpts) Reset added in v0.0.46 

func (m *NatsWriteOpts) Reset()

func (*NatsWriteOpts) String added in v0.0.46 

func (m *NatsWriteOpts) String() string

func (*NatsWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *NatsWriteOpts) XXX_DiscardUnknown()

func (*NatsWriteOpts) XXX_Marshal added in v0.0.46 

func (m *NatsWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NatsWriteOpts) XXX_Merge added in v0.0.46 

func (m *NatsWriteOpts) XXX_Merge(src proto.Message)

func (*NatsWriteOpts) XXX_Size added in v0.0.46 

func (m *NatsWriteOpts) XXX_Size() int

func (*NatsWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *NatsWriteOpts) XXX_Unmarshal(b []byte) error

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_USERNAME',default=5432,required"
	Port uint32 `` /* 153-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'"
	InsecureTls          bool     `` /* 194-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostgresConn) Descriptor added in v0.0.46 

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

func (*PostgresConn) GetAddress added in v0.0.46 

func (m *PostgresConn) GetAddress() string

func (*PostgresConn) GetDatabase added in v0.0.46 

func (m *PostgresConn) GetDatabase() string

func (*PostgresConn) GetInsecureTls added in v0.0.46 

func (m *PostgresConn) GetInsecureTls() bool

func (*PostgresConn) GetPassword added in v0.0.46 

func (m *PostgresConn) GetPassword() string

func (*PostgresConn) GetPort added in v0.0.46 

func (m *PostgresConn) GetPort() uint32

func (*PostgresConn) GetUseTls added in v0.0.46 

func (m *PostgresConn) GetUseTls() bool

func (*PostgresConn) GetUsername added in v0.0.46 

func (m *PostgresConn) GetUsername() string

func (*PostgresConn) ProtoMessage added in v0.0.46 

func (*PostgresConn) ProtoMessage()

func (*PostgresConn) Reset added in v0.0.46 

func (m *PostgresConn) Reset()

func (*PostgresConn) String added in v0.0.46 

func (m *PostgresConn) String() string

func (*PostgresConn) XXX_DiscardUnknown added in v0.0.46 

func (m *PostgresConn) XXX_DiscardUnknown()

func (*PostgresConn) XXX_Marshal added in v0.0.46 

func (m *PostgresConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PostgresConn) XXX_Merge added in v0.0.46 

func (m *PostgresConn) XXX_Merge(src proto.Message)

func (*PostgresConn) XXX_Size added in v0.0.46 

func (m *PostgresConn) XXX_Size() int

func (*PostgresConn) XXX_Unmarshal added in v0.0.46 

func (m *PostgresConn) XXX_Unmarshal(b []byte) error

type PostgresReadOpts added in v0.0.46 

type PostgresReadOpts 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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostgresReadOpts) Descriptor added in v0.0.46 

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

func (*PostgresReadOpts) GetPublisherName added in v0.0.46 

func (m *PostgresReadOpts) GetPublisherName() string

func (*PostgresReadOpts) GetReplicationSlotName added in v0.0.46 

func (m *PostgresReadOpts) GetReplicationSlotName() string

func (*PostgresReadOpts) ProtoMessage added in v0.0.46 

func (*PostgresReadOpts) ProtoMessage()

func (*PostgresReadOpts) Reset added in v0.0.46 

func (m *PostgresReadOpts) Reset()

func (*PostgresReadOpts) String added in v0.0.46 

func (m *PostgresReadOpts) String() string

func (*PostgresReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *PostgresReadOpts) XXX_DiscardUnknown()

func (*PostgresReadOpts) XXX_Marshal added in v0.0.46 

func (m *PostgresReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PostgresReadOpts) XXX_Merge added in v0.0.46 

func (m *PostgresReadOpts) XXX_Merge(src proto.Message)

func (*PostgresReadOpts) XXX_Size added in v0.0.46 

func (m *PostgresReadOpts) XXX_Size() int

func (*PostgresReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *PostgresReadOpts) XXX_Unmarshal(b []byte) error

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'"
	InsecureTls bool `` /* 146-byte string literal not displayed */
	// @gotags: kong:"help='TLS client certificate file',type=existingfile"
	TlsClientCert []byte `` /* 162-byte string literal not displayed */
	// @gotags: kong:"help='TLS client key file',type=existingfile"
	TlsClientKey         []byte   `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PulsarConn) Descriptor added in v0.0.46 

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

func (*PulsarConn) GetConnectTimeoutSeconds added in v0.0.46 

func (m *PulsarConn) GetConnectTimeoutSeconds() uint32

func (*PulsarConn) GetDsn added in v0.0.46 

func (m *PulsarConn) GetDsn() string

func (*PulsarConn) GetInsecureTls added in v0.0.46 

func (m *PulsarConn) GetInsecureTls() bool

func (*PulsarConn) GetTlsClientCert added in v0.0.46 

func (m *PulsarConn) GetTlsClientCert() []byte

func (*PulsarConn) GetTlsClientKey added in v0.0.46 

func (m *PulsarConn) GetTlsClientKey() []byte

func (*PulsarConn) ProtoMessage added in v0.0.46 

func (*PulsarConn) ProtoMessage()

func (*PulsarConn) Reset added in v0.0.46 

func (m *PulsarConn) Reset()

func (*PulsarConn) String added in v0.0.46 

func (m *PulsarConn) String() string

func (*PulsarConn) XXX_DiscardUnknown added in v0.0.46 

func (m *PulsarConn) XXX_DiscardUnknown()

func (*PulsarConn) XXX_Marshal added in v0.0.46 

func (m *PulsarConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PulsarConn) XXX_Merge added in v0.0.46 

func (m *PulsarConn) XXX_Merge(src proto.Message)

func (*PulsarConn) XXX_Size added in v0.0.46 

func (m *PulsarConn) XXX_Size() int

func (*PulsarConn) XXX_Unmarshal added in v0.0.46 

func (m *PulsarConn) XXX_Unmarshal(b []byte) error

type PulsarReadOpts added in v0.0.46 

type PulsarReadOpts 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 (0: shared, 1: exclusive, 2: failover, 3: keyshared)',required"
	SubscriptionType     SubscriptionType `` /* 238-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*PulsarReadOpts) Descriptor added in v0.0.46 

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

func (*PulsarReadOpts) GetSubscriptionName added in v0.0.46 

func (m *PulsarReadOpts) GetSubscriptionName() string

func (*PulsarReadOpts) GetSubscriptionType added in v0.0.46 

func (m *PulsarReadOpts) GetSubscriptionType() SubscriptionType

func (*PulsarReadOpts) GetTopic added in v0.0.46 

func (m *PulsarReadOpts) GetTopic() string

func (*PulsarReadOpts) ProtoMessage added in v0.0.46 

func (*PulsarReadOpts) ProtoMessage()

func (*PulsarReadOpts) Reset added in v0.0.46 

func (m *PulsarReadOpts) Reset()

func (*PulsarReadOpts) String added in v0.0.46 

func (m *PulsarReadOpts) String() string

func (*PulsarReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *PulsarReadOpts) XXX_DiscardUnknown()

func (*PulsarReadOpts) XXX_Marshal added in v0.0.46 

func (m *PulsarReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PulsarReadOpts) XXX_Merge added in v0.0.46 

func (m *PulsarReadOpts) XXX_Merge(src proto.Message)

func (*PulsarReadOpts) XXX_Size added in v0.0.46 

func (m *PulsarReadOpts) XXX_Size() int

func (*PulsarReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *PulsarReadOpts) XXX_Unmarshal(b []byte) error

type PulsarWriteOpts added in v0.0.46 

type PulsarWriteOpts 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'"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PulsarWriteOpts) Descriptor added in v0.0.46 

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

func (*PulsarWriteOpts) GetTopic added in v0.0.46 

func (m *PulsarWriteOpts) GetTopic() string

func (*PulsarWriteOpts) ProtoMessage added in v0.0.46 

func (*PulsarWriteOpts) ProtoMessage()

func (*PulsarWriteOpts) Reset added in v0.0.46 

func (m *PulsarWriteOpts) Reset()

func (*PulsarWriteOpts) String added in v0.0.46 

func (m *PulsarWriteOpts) String() string

func (*PulsarWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *PulsarWriteOpts) XXX_DiscardUnknown()

func (*PulsarWriteOpts) XXX_Marshal added in v0.0.46 

func (m *PulsarWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PulsarWriteOpts) XXX_Merge added in v0.0.46 

func (m *PulsarWriteOpts) XXX_Merge(src proto.Message)

func (*PulsarWriteOpts) XXX_Size added in v0.0.46 

func (m *PulsarWriteOpts) XXX_Size() int

func (*PulsarWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *PulsarWriteOpts) XXX_Unmarshal(b []byte) error

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'"
	InsecureTls          bool     `` /* 193-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RabbitConn) Descriptor added in v0.0.46 

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

func (*RabbitConn) GetAddress added in v0.0.46 

func (m *RabbitConn) GetAddress() string

func (*RabbitConn) GetInsecureTls added in v0.0.46 

func (m *RabbitConn) GetInsecureTls() bool

func (*RabbitConn) GetUseTls added in v0.0.46 

func (m *RabbitConn) GetUseTls() bool

func (*RabbitConn) ProtoMessage added in v0.0.46 

func (*RabbitConn) ProtoMessage()

func (*RabbitConn) Reset added in v0.0.46 

func (m *RabbitConn) Reset()

func (*RabbitConn) String added in v0.0.46 

func (m *RabbitConn) String() string

func (*RabbitConn) XXX_DiscardUnknown added in v0.0.46 

func (m *RabbitConn) XXX_DiscardUnknown()

func (*RabbitConn) XXX_Marshal added in v0.0.46 

func (m *RabbitConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RabbitConn) XXX_Merge added in v0.0.46 

func (m *RabbitConn) XXX_Merge(src proto.Message)

func (*RabbitConn) XXX_Size added in v0.0.46 

func (m *RabbitConn) XXX_Size() int

func (*RabbitConn) XXX_Unmarshal added in v0.0.46 

func (m *RabbitConn) XXX_Unmarshal(b []byte) error

type RabbitReadOpts added in v0.0.46 

type RabbitReadOpts 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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RabbitReadOpts) Descriptor added in v0.0.46 

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

func (*RabbitReadOpts) GetAutoAck added in v0.0.46 

func (m *RabbitReadOpts) GetAutoAck() bool

func (*RabbitReadOpts) GetBindingKey added in v0.0.46 

func (m *RabbitReadOpts) GetBindingKey() string

func (*RabbitReadOpts) GetConsumerTag added in v0.0.46 

func (m *RabbitReadOpts) GetConsumerTag() string

func (*RabbitReadOpts) GetExchangeName added in v0.0.46 

func (m *RabbitReadOpts) GetExchangeName() string

func (*RabbitReadOpts) GetQueueDeclare added in v0.0.46 

func (m *RabbitReadOpts) GetQueueDeclare() bool

func (*RabbitReadOpts) GetQueueDelete added in v0.0.46 

func (m *RabbitReadOpts) GetQueueDelete() bool

func (*RabbitReadOpts) GetQueueDurable added in v0.0.46 

func (m *RabbitReadOpts) GetQueueDurable() bool

func (*RabbitReadOpts) GetQueueExclusive added in v0.0.46 

func (m *RabbitReadOpts) GetQueueExclusive() bool

func (*RabbitReadOpts) GetQueueName added in v0.0.46 

func (m *RabbitReadOpts) GetQueueName() string

func (*RabbitReadOpts) ProtoMessage added in v0.0.46 

func (*RabbitReadOpts) ProtoMessage()

func (*RabbitReadOpts) Reset added in v0.0.46 

func (m *RabbitReadOpts) Reset()

func (*RabbitReadOpts) String added in v0.0.46 

func (m *RabbitReadOpts) String() string

func (*RabbitReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *RabbitReadOpts) XXX_DiscardUnknown()

func (*RabbitReadOpts) XXX_Marshal added in v0.0.46 

func (m *RabbitReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RabbitReadOpts) XXX_Merge added in v0.0.46 

func (m *RabbitReadOpts) XXX_Merge(src proto.Message)

func (*RabbitReadOpts) XXX_Size added in v0.0.46 

func (m *RabbitReadOpts) XXX_Size() int

func (*RabbitReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *RabbitReadOpts) XXX_Unmarshal(b []byte) error

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'"
	InsecureTls bool `` /* 146-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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RabbitStreamsConn) Descriptor added in v0.0.46 

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

func (*RabbitStreamsConn) GetClientName added in v0.0.46 

func (m *RabbitStreamsConn) GetClientName() string

func (*RabbitStreamsConn) GetDsn added in v0.0.46 

func (m *RabbitStreamsConn) GetDsn() string

func (*RabbitStreamsConn) GetInsecureTls added in v0.0.46 

func (m *RabbitStreamsConn) GetInsecureTls() bool

func (*RabbitStreamsConn) GetPassword added in v0.0.46 

func (m *RabbitStreamsConn) GetPassword() string

func (*RabbitStreamsConn) GetUseTls added in v0.0.46 

func (m *RabbitStreamsConn) GetUseTls() bool

func (*RabbitStreamsConn) GetUsername added in v0.0.46 

func (m *RabbitStreamsConn) GetUsername() string

func (*RabbitStreamsConn) ProtoMessage added in v0.0.46 

func (*RabbitStreamsConn) ProtoMessage()

func (*RabbitStreamsConn) Reset added in v0.0.46 

func (m *RabbitStreamsConn) Reset()

func (*RabbitStreamsConn) String added in v0.0.46 

func (m *RabbitStreamsConn) String() string

func (*RabbitStreamsConn) XXX_DiscardUnknown added in v0.0.46 

func (m *RabbitStreamsConn) XXX_DiscardUnknown()

func (*RabbitStreamsConn) XXX_Marshal added in v0.0.46 

func (m *RabbitStreamsConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RabbitStreamsConn) XXX_Merge added in v0.0.46 

func (m *RabbitStreamsConn) XXX_Merge(src proto.Message)

func (*RabbitStreamsConn) XXX_Size added in v0.0.46 

func (m *RabbitStreamsConn) XXX_Size() int

func (*RabbitStreamsConn) XXX_Unmarshal added in v0.0.46 

func (m *RabbitStreamsConn) XXX_Unmarshal(b []byte) error

type RabbitStreamsOffsetOptions added in v0.0.46 

type RabbitStreamsOffsetOptions struct {
	// @gotags: kong:"group=offset,xor=offset"
	SpecificOffset uint64 `` /* 135-byte string literal not displayed */
	// @gotags: kong:"group=offset,xor=offset"
	LastOffset uint64 `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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RabbitStreamsOffsetOptions) Descriptor added in v0.0.46 

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

func (*RabbitStreamsOffsetOptions) GetFirstOffset added in v0.0.46 

func (m *RabbitStreamsOffsetOptions) GetFirstOffset() bool

func (*RabbitStreamsOffsetOptions) GetLastConsumed added in v0.0.46 

func (m *RabbitStreamsOffsetOptions) GetLastConsumed() bool

func (*RabbitStreamsOffsetOptions) GetLastOffset added in v0.0.46 

func (m *RabbitStreamsOffsetOptions) GetLastOffset() uint64

func (*RabbitStreamsOffsetOptions) GetNextOffset added in v0.0.46 

func (m *RabbitStreamsOffsetOptions) GetNextOffset() bool

func (*RabbitStreamsOffsetOptions) GetSpecificOffset added in v0.0.46 

func (m *RabbitStreamsOffsetOptions) GetSpecificOffset() uint64

func (*RabbitStreamsOffsetOptions) ProtoMessage added in v0.0.46 

func (*RabbitStreamsOffsetOptions) ProtoMessage()

func (*RabbitStreamsOffsetOptions) Reset added in v0.0.46 

func (m *RabbitStreamsOffsetOptions) Reset()

func (*RabbitStreamsOffsetOptions) String added in v0.0.46 

func (m *RabbitStreamsOffsetOptions) String() string

func (*RabbitStreamsOffsetOptions) XXX_DiscardUnknown added in v0.0.46 

func (m *RabbitStreamsOffsetOptions) XXX_DiscardUnknown()

func (*RabbitStreamsOffsetOptions) XXX_Marshal added in v0.0.46 

func (m *RabbitStreamsOffsetOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RabbitStreamsOffsetOptions) XXX_Merge added in v0.0.46 

func (m *RabbitStreamsOffsetOptions) XXX_Merge(src proto.Message)

func (*RabbitStreamsOffsetOptions) XXX_Size added in v0.0.46 

func (m *RabbitStreamsOffsetOptions) XXX_Size() int

func (*RabbitStreamsOffsetOptions) XXX_Unmarshal added in v0.0.46 

func (m *RabbitStreamsOffsetOptions) XXX_Unmarshal(b []byte) error

type RabbitStreamsReadOpts added in v0.0.46 

type RabbitStreamsReadOpts 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 `` /* 213-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 */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*RabbitStreamsReadOpts) Descriptor added in v0.0.46 

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

func (*RabbitStreamsReadOpts) GetDeclareStream added in v0.0.46 

func (m *RabbitStreamsReadOpts) GetDeclareStream() bool

func (*RabbitStreamsReadOpts) GetDeclareStreamSize added in v0.0.46 

func (m *RabbitStreamsReadOpts) GetDeclareStreamSize() string

func (*RabbitStreamsReadOpts) GetOffsetOptions added in v0.0.46 

func (m *RabbitStreamsReadOpts) GetOffsetOptions() *RabbitStreamsOffsetOptions

func (*RabbitStreamsReadOpts) GetStream added in v0.0.46 

func (m *RabbitStreamsReadOpts) GetStream() string

func (*RabbitStreamsReadOpts) ProtoMessage added in v0.0.46 

func (*RabbitStreamsReadOpts) ProtoMessage()

func (*RabbitStreamsReadOpts) Reset added in v0.0.46 

func (m *RabbitStreamsReadOpts) Reset()

func (*RabbitStreamsReadOpts) String added in v0.0.46 

func (m *RabbitStreamsReadOpts) String() string

func (*RabbitStreamsReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *RabbitStreamsReadOpts) XXX_DiscardUnknown()

func (*RabbitStreamsReadOpts) XXX_Marshal added in v0.0.46 

func (m *RabbitStreamsReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RabbitStreamsReadOpts) XXX_Merge added in v0.0.46 

func (m *RabbitStreamsReadOpts) XXX_Merge(src proto.Message)

func (*RabbitStreamsReadOpts) XXX_Size added in v0.0.46 

func (m *RabbitStreamsReadOpts) XXX_Size() int

func (*RabbitStreamsReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *RabbitStreamsReadOpts) XXX_Unmarshal(b []byte) error

type RabbitStreamsWriteOpts added in v0.0.46 

type RabbitStreamsWriteOpts struct {
	// @gotags: kong:"help=”,required"
	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty" kong:"help='',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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RabbitStreamsWriteOpts) Descriptor added in v0.0.46 

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

func (*RabbitStreamsWriteOpts) GetDeclareStream added in v0.0.46 

func (m *RabbitStreamsWriteOpts) GetDeclareStream() bool

func (*RabbitStreamsWriteOpts) GetDeclareStreamSize added in v0.0.46 

func (m *RabbitStreamsWriteOpts) GetDeclareStreamSize() string

func (*RabbitStreamsWriteOpts) GetStream added in v0.0.46 

func (m *RabbitStreamsWriteOpts) GetStream() string

func (*RabbitStreamsWriteOpts) ProtoMessage added in v0.0.46 

func (*RabbitStreamsWriteOpts) ProtoMessage()

func (*RabbitStreamsWriteOpts) Reset added in v0.0.46 

func (m *RabbitStreamsWriteOpts) Reset()

func (*RabbitStreamsWriteOpts) String added in v0.0.46 

func (m *RabbitStreamsWriteOpts) String() string

func (*RabbitStreamsWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *RabbitStreamsWriteOpts) XXX_DiscardUnknown()

func (*RabbitStreamsWriteOpts) XXX_Marshal added in v0.0.46 

func (m *RabbitStreamsWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RabbitStreamsWriteOpts) XXX_Merge added in v0.0.46 

func (m *RabbitStreamsWriteOpts) XXX_Merge(src proto.Message)

func (*RabbitStreamsWriteOpts) XXX_Size added in v0.0.46 

func (m *RabbitStreamsWriteOpts) XXX_Size() int

func (*RabbitStreamsWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *RabbitStreamsWriteOpts) XXX_Unmarshal(b []byte) error

type RabbitWriteOpts added in v0.0.46 

type RabbitWriteOpts 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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RabbitWriteOpts) Descriptor added in v0.0.46 

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

func (*RabbitWriteOpts) GetAppId added in v0.0.46 

func (m *RabbitWriteOpts) GetAppId() string

func (*RabbitWriteOpts) GetExchangeName added in v0.0.46 

func (m *RabbitWriteOpts) GetExchangeName() string

func (*RabbitWriteOpts) GetRoutingKey added in v0.0.46 

func (m *RabbitWriteOpts) GetRoutingKey() string

func (*RabbitWriteOpts) ProtoMessage added in v0.0.46 

func (*RabbitWriteOpts) ProtoMessage()

func (*RabbitWriteOpts) Reset added in v0.0.46 

func (m *RabbitWriteOpts) Reset()

func (*RabbitWriteOpts) String added in v0.0.46 

func (m *RabbitWriteOpts) String() string

func (*RabbitWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *RabbitWriteOpts) XXX_DiscardUnknown()

func (*RabbitWriteOpts) XXX_Marshal added in v0.0.46 

func (m *RabbitWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RabbitWriteOpts) XXX_Merge added in v0.0.46 

func (m *RabbitWriteOpts) XXX_Merge(src proto.Message)

func (*RabbitWriteOpts) XXX_Size added in v0.0.46 

func (m *RabbitWriteOpts) XXX_Size() int

func (*RabbitWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *RabbitWriteOpts) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RedisPubSubConn) Descriptor added in v0.0.46 

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

func (*RedisPubSubConn) GetAddress added in v0.0.46 

func (m *RedisPubSubConn) GetAddress() string

func (*RedisPubSubConn) GetPassword added in v0.0.46 

func (m *RedisPubSubConn) GetPassword() string

func (*RedisPubSubConn) GetUsername added in v0.0.46 

func (m *RedisPubSubConn) GetUsername() string

func (*RedisPubSubConn) ProtoMessage added in v0.0.46 

func (*RedisPubSubConn) ProtoMessage()

func (*RedisPubSubConn) Reset added in v0.0.46 

func (m *RedisPubSubConn) Reset()

func (*RedisPubSubConn) String added in v0.0.46 

func (m *RedisPubSubConn) String() string

func (*RedisPubSubConn) XXX_DiscardUnknown added in v0.0.46 

func (m *RedisPubSubConn) XXX_DiscardUnknown()

func (*RedisPubSubConn) XXX_Marshal added in v0.0.46 

func (m *RedisPubSubConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RedisPubSubConn) XXX_Merge added in v0.0.46 

func (m *RedisPubSubConn) XXX_Merge(src proto.Message)

func (*RedisPubSubConn) XXX_Size added in v0.0.46 

func (m *RedisPubSubConn) XXX_Size() int

func (*RedisPubSubConn) XXX_Unmarshal added in v0.0.46 

func (m *RedisPubSubConn) XXX_Unmarshal(b []byte) error

type RedisPubSubReadOpts added in v0.0.46 

type RedisPubSubReadOpts struct {
	// @gotags: kong:"help='Database (0-16)',env='PLUMBER_RELAY_REDIS_PUBSUB_DATABASE'"
	Database uint32 `` /* 142-byte string literal not displayed */
	// @gotags: kong:"help='Comma separated list of channels to read from',env='PLUMBER_RELAY_REDIS_PUBSUB_CHANNELS',required"
	Channel              []string `` /* 178-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RedisPubSubReadOpts) Descriptor added in v0.0.46 

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

func (*RedisPubSubReadOpts) GetChannel added in v0.0.46 

func (m *RedisPubSubReadOpts) GetChannel() []string

func (*RedisPubSubReadOpts) GetDatabase added in v0.0.46 

func (m *RedisPubSubReadOpts) GetDatabase() uint32

func (*RedisPubSubReadOpts) ProtoMessage added in v0.0.46 

func (*RedisPubSubReadOpts) ProtoMessage()

func (*RedisPubSubReadOpts) Reset added in v0.0.46 

func (m *RedisPubSubReadOpts) Reset()

func (*RedisPubSubReadOpts) String added in v0.0.46 

func (m *RedisPubSubReadOpts) String() string

func (*RedisPubSubReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *RedisPubSubReadOpts) XXX_DiscardUnknown()

func (*RedisPubSubReadOpts) XXX_Marshal added in v0.0.46 

func (m *RedisPubSubReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RedisPubSubReadOpts) XXX_Merge added in v0.0.46 

func (m *RedisPubSubReadOpts) XXX_Merge(src proto.Message)

func (*RedisPubSubReadOpts) XXX_Size added in v0.0.46 

func (m *RedisPubSubReadOpts) XXX_Size() int

func (*RedisPubSubReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *RedisPubSubReadOpts) XXX_Unmarshal(b []byte) error

type RedisPubSubWriteOpts added in v0.0.46 

type RedisPubSubWriteOpts struct {
	// @gotags: kong:"help='Database (0-16)'"
	Database uint32 `protobuf:"varint,1,opt,name=database,proto3" json:"database,omitempty" kong:"help='Database (0-16)'"`
	// @gotags: kong:"help='Comma separated list of channels to write to',required"
	Channel              []string `` /* 135-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RedisPubSubWriteOpts) Descriptor added in v0.0.46 

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

func (*RedisPubSubWriteOpts) GetChannel added in v0.0.46 

func (m *RedisPubSubWriteOpts) GetChannel() []string

func (*RedisPubSubWriteOpts) GetDatabase added in v0.0.46 

func (m *RedisPubSubWriteOpts) GetDatabase() uint32

func (*RedisPubSubWriteOpts) ProtoMessage added in v0.0.46 

func (*RedisPubSubWriteOpts) ProtoMessage()

func (*RedisPubSubWriteOpts) Reset added in v0.0.46 

func (m *RedisPubSubWriteOpts) Reset()

func (*RedisPubSubWriteOpts) String added in v0.0.46 

func (m *RedisPubSubWriteOpts) String() string

func (*RedisPubSubWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *RedisPubSubWriteOpts) XXX_DiscardUnknown()

func (*RedisPubSubWriteOpts) XXX_Marshal added in v0.0.46 

func (m *RedisPubSubWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RedisPubSubWriteOpts) XXX_Merge added in v0.0.46 

func (m *RedisPubSubWriteOpts) XXX_Merge(src proto.Message)

func (*RedisPubSubWriteOpts) XXX_Size added in v0.0.46 

func (m *RedisPubSubWriteOpts) XXX_Size() int

func (*RedisPubSubWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *RedisPubSubWriteOpts) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RedisStreamsConn) Descriptor added in v0.0.46 

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

func (*RedisStreamsConn) GetAddress added in v0.0.46 

func (m *RedisStreamsConn) GetAddress() string

func (*RedisStreamsConn) GetPassword added in v0.0.46 

func (m *RedisStreamsConn) GetPassword() string

func (*RedisStreamsConn) GetUsername added in v0.0.46 

func (m *RedisStreamsConn) GetUsername() string

func (*RedisStreamsConn) ProtoMessage added in v0.0.46 

func (*RedisStreamsConn) ProtoMessage()

func (*RedisStreamsConn) Reset added in v0.0.46 

func (m *RedisStreamsConn) Reset()

func (*RedisStreamsConn) String added in v0.0.46 

func (m *RedisStreamsConn) String() string

func (*RedisStreamsConn) XXX_DiscardUnknown added in v0.0.46 

func (m *RedisStreamsConn) XXX_DiscardUnknown()

func (*RedisStreamsConn) XXX_Marshal added in v0.0.46 

func (m *RedisStreamsConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RedisStreamsConn) XXX_Merge added in v0.0.46 

func (m *RedisStreamsConn) XXX_Merge(src proto.Message)

func (*RedisStreamsConn) XXX_Size added in v0.0.46 

func (m *RedisStreamsConn) XXX_Size() int

func (*RedisStreamsConn) XXX_Unmarshal added in v0.0.46 

func (m *RedisStreamsConn) XXX_Unmarshal(b []byte) error

type RedisStreamsReadOpts added in v0.0.46 

type RedisStreamsReadOpts struct {
	// @gotags: kong:"help='Database',required,default=0,env='PLUMBER_RELAY_REDIS_STREAMS_DATABASE'"
	Database uint32 `` /* 155-byte string literal not displayed */
	// @gotags: kong:"help='Streams to read from',required,env='PLUMBER_RELAY_REDIS_STREAMS_STREAMS'"
	Stream []string `` /* 151-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 */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*RedisStreamsReadOpts) Descriptor added in v0.0.46 

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

func (*RedisStreamsReadOpts) GetConsumerGroup added in v0.0.46 

func (m *RedisStreamsReadOpts) GetConsumerGroup() string

func (*RedisStreamsReadOpts) GetConsumerName added in v0.0.46 

func (m *RedisStreamsReadOpts) GetConsumerName() string

func (*RedisStreamsReadOpts) GetCount added in v0.0.46 

func (m *RedisStreamsReadOpts) GetCount() uint32

func (*RedisStreamsReadOpts) GetCreateConsumerConfig added in v0.0.46 

func (m *RedisStreamsReadOpts) GetCreateConsumerConfig() *CreateConsumerConfig

func (*RedisStreamsReadOpts) GetDatabase added in v0.0.46 

func (m *RedisStreamsReadOpts) GetDatabase() uint32

func (*RedisStreamsReadOpts) GetStream added in v0.0.46 

func (m *RedisStreamsReadOpts) GetStream() []string

func (*RedisStreamsReadOpts) ProtoMessage added in v0.0.46 

func (*RedisStreamsReadOpts) ProtoMessage()

func (*RedisStreamsReadOpts) Reset added in v0.0.46 

func (m *RedisStreamsReadOpts) Reset()

func (*RedisStreamsReadOpts) String added in v0.0.46 

func (m *RedisStreamsReadOpts) String() string

func (*RedisStreamsReadOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *RedisStreamsReadOpts) XXX_DiscardUnknown()

func (*RedisStreamsReadOpts) XXX_Marshal added in v0.0.46 

func (m *RedisStreamsReadOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RedisStreamsReadOpts) XXX_Merge added in v0.0.46 

func (m *RedisStreamsReadOpts) XXX_Merge(src proto.Message)

func (*RedisStreamsReadOpts) XXX_Size added in v0.0.46 

func (m *RedisStreamsReadOpts) XXX_Size() int

func (*RedisStreamsReadOpts) XXX_Unmarshal added in v0.0.46 

func (m *RedisStreamsReadOpts) XXX_Unmarshal(b []byte) error

type RedisStreamsWriteOpts added in v0.0.46 

type RedisStreamsWriteOpts 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'"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RedisStreamsWriteOpts) Descriptor added in v0.0.46 

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

func (*RedisStreamsWriteOpts) GetKey added in v0.0.46 

func (m *RedisStreamsWriteOpts) GetKey() string

func (*RedisStreamsWriteOpts) GetStreams added in v0.0.46 

func (m *RedisStreamsWriteOpts) GetStreams() []string

func (*RedisStreamsWriteOpts) GetWriteId added in v0.0.46 

func (m *RedisStreamsWriteOpts) GetWriteId() string

func (*RedisStreamsWriteOpts) ProtoMessage added in v0.0.46 

func (*RedisStreamsWriteOpts) ProtoMessage()

func (*RedisStreamsWriteOpts) Reset added in v0.0.46 

func (m *RedisStreamsWriteOpts) Reset()

func (*RedisStreamsWriteOpts) String added in v0.0.46 

func (m *RedisStreamsWriteOpts) String() string

func (*RedisStreamsWriteOpts) XXX_DiscardUnknown added in v0.0.46 

func (m *RedisStreamsWriteOpts) XXX_DiscardUnknown()

func (*RedisStreamsWriteOpts) XXX_Marshal added in v0.0.46 

func (m *RedisStreamsWriteOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RedisStreamsWriteOpts) XXX_Merge added in v0.0.46 

func (m *RedisStreamsWriteOpts) XXX_Merge(src proto.Message)

func (*RedisStreamsWriteOpts) XXX_Size added in v0.0.46 

func (m *RedisStreamsWriteOpts) XXX_Size() int

func (*RedisStreamsWriteOpts) XXX_Unmarshal added in v0.0.46 

func (m *RedisStreamsWriteOpts) XXX_Unmarshal(b []byte) error

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) EnumDescriptor added in v0.0.46 

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

func (SubscriptionType) String added in v0.0.46 

func (x SubscriptionType) String() string

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.