args

package
v0.0.95 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

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 OffsetStart_name = map[int32]string{
	0: "Latest",
	1: "Oldest",
}
View Source 
var OffsetStart_value = map[string]int32{
	"Latest": 0,
	"Oldest": 1,
}
View Source 
var SASLType_name = map[int32]string{
	0: "NONE",
	1: "PLAIN",
	2: "SCRAM",
}
View Source 
var SASLType_value = map[string]int32{
	"NONE":  0,
	"PLAIN": 1,
	"SCRAM": 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 AWSSNSWriteArgs added in v0.0.47 

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

func (*AWSSNSWriteArgs) Descriptor added in v0.0.47 

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

func (*AWSSNSWriteArgs) GetTopic added in v0.0.47 

func (m *AWSSNSWriteArgs) GetTopic() string

func (*AWSSNSWriteArgs) ProtoMessage added in v0.0.47 

func (*AWSSNSWriteArgs) ProtoMessage()

func (*AWSSNSWriteArgs) Reset added in v0.0.47 

func (m *AWSSNSWriteArgs) Reset()

func (*AWSSNSWriteArgs) String added in v0.0.47 

func (m *AWSSNSWriteArgs) String() string

func (*AWSSNSWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *AWSSNSWriteArgs) XXX_DiscardUnknown()

func (*AWSSNSWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*AWSSNSWriteArgs) XXX_Merge added in v0.0.47 

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

func (*AWSSNSWriteArgs) XXX_Size added in v0.0.47 

func (m *AWSSNSWriteArgs) XXX_Size() int

func (*AWSSNSWriteArgs) XXX_Unmarshal added in v0.0.47 

func (m *AWSSNSWriteArgs) 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 AWSSQSReadArgs added in v0.0.47 

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

func (*AWSSQSReadArgs) Descriptor added in v0.0.47 

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

func (*AWSSQSReadArgs) GetAutoDelete added in v0.0.47 

func (m *AWSSQSReadArgs) GetAutoDelete() bool

func (*AWSSQSReadArgs) GetMaxNumMessages added in v0.0.47 

func (m *AWSSQSReadArgs) GetMaxNumMessages() int64

func (*AWSSQSReadArgs) GetQueueName added in v0.0.47 

func (m *AWSSQSReadArgs) GetQueueName() string

func (*AWSSQSReadArgs) GetReceiveRequestAttemptId added in v0.0.47 

func (m *AWSSQSReadArgs) GetReceiveRequestAttemptId() string

func (*AWSSQSReadArgs) GetRemoteAccountId added in v0.0.47 

func (m *AWSSQSReadArgs) GetRemoteAccountId() string

func (*AWSSQSReadArgs) GetWaitTimeSeconds added in v0.0.47 

func (m *AWSSQSReadArgs) GetWaitTimeSeconds() int64

func (*AWSSQSReadArgs) ProtoMessage added in v0.0.47 

func (*AWSSQSReadArgs) ProtoMessage()

func (*AWSSQSReadArgs) Reset added in v0.0.47 

func (m *AWSSQSReadArgs) Reset()

func (*AWSSQSReadArgs) String added in v0.0.47 

func (m *AWSSQSReadArgs) String() string

func (*AWSSQSReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *AWSSQSReadArgs) XXX_DiscardUnknown()

func (*AWSSQSReadArgs) XXX_Marshal added in v0.0.47 

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

func (*AWSSQSReadArgs) XXX_Merge added in v0.0.47 

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

func (*AWSSQSReadArgs) XXX_Size added in v0.0.47 

func (m *AWSSQSReadArgs) XXX_Size() int

func (*AWSSQSReadArgs) XXX_Unmarshal added in v0.0.47 

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

type AWSSQSRelayArgs added in v0.0.47 

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

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

func (*AWSSQSRelayArgs) Descriptor added in v0.0.47 

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

func (*AWSSQSRelayArgs) GetAutoDelete added in v0.0.47 

func (m *AWSSQSRelayArgs) GetAutoDelete() bool

func (*AWSSQSRelayArgs) GetMaxNumMessages added in v0.0.47 

func (m *AWSSQSRelayArgs) GetMaxNumMessages() int64

func (*AWSSQSRelayArgs) GetQueueName added in v0.0.47 

func (m *AWSSQSRelayArgs) GetQueueName() string

func (*AWSSQSRelayArgs) GetReceiveRequestAttemptId added in v0.0.47 

func (m *AWSSQSRelayArgs) GetReceiveRequestAttemptId() string

func (*AWSSQSRelayArgs) GetRemoteAccountId added in v0.0.47 

func (m *AWSSQSRelayArgs) GetRemoteAccountId() string

func (*AWSSQSRelayArgs) GetWaitTimeSeconds added in v0.0.47 

func (m *AWSSQSRelayArgs) GetWaitTimeSeconds() int64

func (*AWSSQSRelayArgs) ProtoMessage added in v0.0.47 

func (*AWSSQSRelayArgs) ProtoMessage()

func (*AWSSQSRelayArgs) Reset added in v0.0.47 

func (m *AWSSQSRelayArgs) Reset()

func (*AWSSQSRelayArgs) String added in v0.0.47 

func (m *AWSSQSRelayArgs) String() string

func (*AWSSQSRelayArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *AWSSQSRelayArgs) XXX_DiscardUnknown()

func (*AWSSQSRelayArgs) XXX_Marshal added in v0.0.47 

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

func (*AWSSQSRelayArgs) XXX_Merge added in v0.0.47 

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

func (*AWSSQSRelayArgs) XXX_Size added in v0.0.47 

func (m *AWSSQSRelayArgs) XXX_Size() int

func (*AWSSQSRelayArgs) XXX_Unmarshal added in v0.0.47 

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

type AWSSQSWriteArgs added in v0.0.47 

type AWSSQSWriteArgs struct {
	// @gotags: kong:"help='Queue name'"
	QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty" kong:"help='Queue name'"`
	// @gotags: kong:"help='Remote AWS account ID',optional"
	RemoteAccountId string `` /* 153-byte string literal not displayed */
	// @gotags: kong:"help='How many seconds to delay message delivery by',default=0"
	DelaySeconds int64 `` /* 168-byte string literal not displayed */
	// @gotags: kong:"help='Add optional attributes to outgoing message (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 (*AWSSQSWriteArgs) Descriptor added in v0.0.47 

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

func (*AWSSQSWriteArgs) GetAttributes added in v0.0.47 

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

func (*AWSSQSWriteArgs) GetDelaySeconds added in v0.0.47 

func (m *AWSSQSWriteArgs) GetDelaySeconds() int64

func (*AWSSQSWriteArgs) GetMessageDeduplicationId added in v0.0.47 

func (m *AWSSQSWriteArgs) GetMessageDeduplicationId() string

func (*AWSSQSWriteArgs) GetMessageGroupId added in v0.0.47 

func (m *AWSSQSWriteArgs) GetMessageGroupId() string

func (*AWSSQSWriteArgs) GetQueueName added in v0.0.47 

func (m *AWSSQSWriteArgs) GetQueueName() string

func (*AWSSQSWriteArgs) GetRemoteAccountId added in v0.0.47 

func (m *AWSSQSWriteArgs) GetRemoteAccountId() string

func (*AWSSQSWriteArgs) ProtoMessage added in v0.0.47 

func (*AWSSQSWriteArgs) ProtoMessage()

func (*AWSSQSWriteArgs) Reset added in v0.0.47 

func (m *AWSSQSWriteArgs) Reset()

func (*AWSSQSWriteArgs) String added in v0.0.47 

func (m *AWSSQSWriteArgs) String() string

func (*AWSSQSWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *AWSSQSWriteArgs) XXX_DiscardUnknown()

func (*AWSSQSWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*AWSSQSWriteArgs) XXX_Merge added in v0.0.47 

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

func (*AWSSQSWriteArgs) XXX_Size added in v0.0.47 

func (m *AWSSQSWriteArgs) XXX_Size() int

func (*AWSSQSWriteArgs) XXX_Unmarshal added in v0.0.47 

func (m *AWSSQSWriteArgs) 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 ActiveMQReadArgs added in v0.0.47 

type ActiveMQReadArgs struct {
	// @gotags: kong:"help='Topic to read message(s) from',xor=activemq_read"
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic to read message(s) from',xor=activemq_read"`
	// @gotags: kong:'help='Queue to read message(s) from',xor=activemq_read"
	Queue                string   `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActiveMQReadArgs) Descriptor added in v0.0.47 

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

func (*ActiveMQReadArgs) GetQueue added in v0.0.47 

func (m *ActiveMQReadArgs) GetQueue() string

func (*ActiveMQReadArgs) GetTopic added in v0.0.47 

func (m *ActiveMQReadArgs) GetTopic() string

func (*ActiveMQReadArgs) ProtoMessage added in v0.0.47 

func (*ActiveMQReadArgs) ProtoMessage()

func (*ActiveMQReadArgs) Reset added in v0.0.47 

func (m *ActiveMQReadArgs) Reset()

func (*ActiveMQReadArgs) String added in v0.0.47 

func (m *ActiveMQReadArgs) String() string

func (*ActiveMQReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *ActiveMQReadArgs) XXX_DiscardUnknown()

func (*ActiveMQReadArgs) XXX_Marshal added in v0.0.47 

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

func (*ActiveMQReadArgs) XXX_Merge added in v0.0.47 

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

func (*ActiveMQReadArgs) XXX_Size added in v0.0.47 

func (m *ActiveMQReadArgs) XXX_Size() int

func (*ActiveMQReadArgs) XXX_Unmarshal added in v0.0.47 

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

type ActiveMQWriteArgs added in v0.0.47 

type ActiveMQWriteArgs struct {
	// @gotags: kong:"help='Topic to write message(s) to',xor=activemq_write"
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic to write message(s) to',xor=activemq_write"`
	// @gotags: kong:'help='Queue to write message(s) to',xor=activemq_write"
	Queue                string   `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActiveMQWriteArgs) Descriptor added in v0.0.47 

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

func (*ActiveMQWriteArgs) GetQueue added in v0.0.47 

func (m *ActiveMQWriteArgs) GetQueue() string

func (*ActiveMQWriteArgs) GetTopic added in v0.0.47 

func (m *ActiveMQWriteArgs) GetTopic() string

func (*ActiveMQWriteArgs) ProtoMessage added in v0.0.47 

func (*ActiveMQWriteArgs) ProtoMessage()

func (*ActiveMQWriteArgs) Reset added in v0.0.47 

func (m *ActiveMQWriteArgs) Reset()

func (*ActiveMQWriteArgs) String added in v0.0.47 

func (m *ActiveMQWriteArgs) String() string

func (*ActiveMQWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *ActiveMQWriteArgs) XXX_DiscardUnknown()

func (*ActiveMQWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*ActiveMQWriteArgs) XXX_Merge added in v0.0.47 

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

func (*ActiveMQWriteArgs) XXX_Size added in v0.0.47 

func (m *ActiveMQWriteArgs) XXX_Size() int

func (*ActiveMQWriteArgs) XXX_Unmarshal added in v0.0.47 

func (m *ActiveMQWriteArgs) 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 AzureEventHubReadArgs added in v0.0.47 

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

func (*AzureEventHubReadArgs) Descriptor added in v0.0.47 

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

func (*AzureEventHubReadArgs) ProtoMessage added in v0.0.47 

func (*AzureEventHubReadArgs) ProtoMessage()

func (*AzureEventHubReadArgs) Reset added in v0.0.47 

func (m *AzureEventHubReadArgs) Reset()

func (*AzureEventHubReadArgs) String added in v0.0.47 

func (m *AzureEventHubReadArgs) String() string

func (*AzureEventHubReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *AzureEventHubReadArgs) XXX_DiscardUnknown()

func (*AzureEventHubReadArgs) XXX_Marshal added in v0.0.47 

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

func (*AzureEventHubReadArgs) XXX_Merge added in v0.0.47 

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

func (*AzureEventHubReadArgs) XXX_Size added in v0.0.47 

func (m *AzureEventHubReadArgs) XXX_Size() int

func (*AzureEventHubReadArgs) XXX_Unmarshal added in v0.0.47 

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

type AzureEventHubWriteArgs added in v0.0.47 

type AzureEventHubWriteArgs struct {
	// @gotags: kong:"help='Send message with this ID'"
	MessageId string `` /* 128-byte string literal not displayed */
	// @gotags: kong:"help='Send message with this partition key'"
	PartitionKey         string   `` /* 148-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AzureEventHubWriteArgs) Descriptor added in v0.0.47 

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

func (*AzureEventHubWriteArgs) GetMessageId added in v0.0.47 

func (m *AzureEventHubWriteArgs) GetMessageId() string

func (*AzureEventHubWriteArgs) GetPartitionKey added in v0.0.47 

func (m *AzureEventHubWriteArgs) GetPartitionKey() string

func (*AzureEventHubWriteArgs) ProtoMessage added in v0.0.47 

func (*AzureEventHubWriteArgs) ProtoMessage()

func (*AzureEventHubWriteArgs) Reset added in v0.0.47 

func (m *AzureEventHubWriteArgs) Reset()

func (*AzureEventHubWriteArgs) String added in v0.0.47 

func (m *AzureEventHubWriteArgs) String() string

func (*AzureEventHubWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *AzureEventHubWriteArgs) XXX_DiscardUnknown()

func (*AzureEventHubWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*AzureEventHubWriteArgs) XXX_Merge added in v0.0.47 

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

func (*AzureEventHubWriteArgs) XXX_Size added in v0.0.47 

func (m *AzureEventHubWriteArgs) XXX_Size() int

func (*AzureEventHubWriteArgs) XXX_Unmarshal added in v0.0.47 

func (m *AzureEventHubWriteArgs) 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 AzureServiceBusReadArgs added in v0.0.47 

type AzureServiceBusReadArgs 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 (*AzureServiceBusReadArgs) Descriptor added in v0.0.47 

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

func (*AzureServiceBusReadArgs) GetQueue added in v0.0.47 

func (m *AzureServiceBusReadArgs) GetQueue() string

func (*AzureServiceBusReadArgs) GetSubscriptionName added in v0.0.47 

func (m *AzureServiceBusReadArgs) GetSubscriptionName() string

func (*AzureServiceBusReadArgs) GetTopic added in v0.0.47 

func (m *AzureServiceBusReadArgs) GetTopic() string

func (*AzureServiceBusReadArgs) ProtoMessage added in v0.0.47 

func (*AzureServiceBusReadArgs) ProtoMessage()

func (*AzureServiceBusReadArgs) Reset added in v0.0.47 

func (m *AzureServiceBusReadArgs) Reset()

func (*AzureServiceBusReadArgs) String added in v0.0.47 

func (m *AzureServiceBusReadArgs) String() string

func (*AzureServiceBusReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *AzureServiceBusReadArgs) XXX_DiscardUnknown()

func (*AzureServiceBusReadArgs) XXX_Marshal added in v0.0.47 

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

func (*AzureServiceBusReadArgs) XXX_Merge added in v0.0.47 

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

func (*AzureServiceBusReadArgs) XXX_Size added in v0.0.47 

func (m *AzureServiceBusReadArgs) XXX_Size() int

func (*AzureServiceBusReadArgs) XXX_Unmarshal added in v0.0.47 

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

type AzureServiceBusWriteArgs added in v0.0.47 

type AzureServiceBusWriteArgs 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 (*AzureServiceBusWriteArgs) Descriptor added in v0.0.47 

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

func (*AzureServiceBusWriteArgs) GetQueue added in v0.0.47 

func (m *AzureServiceBusWriteArgs) GetQueue() string

func (*AzureServiceBusWriteArgs) GetTopic added in v0.0.47 

func (m *AzureServiceBusWriteArgs) GetTopic() string

func (*AzureServiceBusWriteArgs) ProtoMessage added in v0.0.47 

func (*AzureServiceBusWriteArgs) ProtoMessage()

func (*AzureServiceBusWriteArgs) Reset added in v0.0.47 

func (m *AzureServiceBusWriteArgs) Reset()

func (*AzureServiceBusWriteArgs) String added in v0.0.47 

func (m *AzureServiceBusWriteArgs) String() string

func (*AzureServiceBusWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *AzureServiceBusWriteArgs) XXX_DiscardUnknown()

func (*AzureServiceBusWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*AzureServiceBusWriteArgs) XXX_Merge added in v0.0.47 

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

func (*AzureServiceBusWriteArgs) XXX_Size added in v0.0.47 

func (m *AzureServiceBusWriteArgs) XXX_Size() int

func (*AzureServiceBusWriteArgs) XXX_Unmarshal added in v0.0.47 

func (m *AzureServiceBusWriteArgs) 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 (options: latest, oldest)',default=latest,required,env='PLUMBER_RELAY_REDIS_STREAMS_START_ID',type=pbenum,pbenum_lowercase"
	OffsetStart          OffsetStart `` /* 292-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() 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 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 GCPPubSubReadArgs added in v0.0.47 

type GCPPubSubReadArgs struct {
	// @gotags: kong:"help='Subscription ID',env='PLUMBER_RELAY_GCP_SUBSCRIPTION_ID',required"
	SubscriptionId string `` /* 182-byte string literal not displayed */
	// @gotags: kong:"help='Whether to acknowledge message receive',env='PLUMBER_RELAY_GCP_ACK_MESSAGE',default=true"
	AckMessages          bool     `` /* 197-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GCPPubSubReadArgs) Descriptor added in v0.0.47 

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

func (*GCPPubSubReadArgs) GetAckMessages added in v0.0.47 

func (m *GCPPubSubReadArgs) GetAckMessages() bool

func (*GCPPubSubReadArgs) GetSubscriptionId added in v0.0.47 

func (m *GCPPubSubReadArgs) GetSubscriptionId() string

func (*GCPPubSubReadArgs) ProtoMessage added in v0.0.47 

func (*GCPPubSubReadArgs) ProtoMessage()

func (*GCPPubSubReadArgs) Reset added in v0.0.47 

func (m *GCPPubSubReadArgs) Reset()

func (*GCPPubSubReadArgs) String added in v0.0.47 

func (m *GCPPubSubReadArgs) String() string

func (*GCPPubSubReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *GCPPubSubReadArgs) XXX_DiscardUnknown()

func (*GCPPubSubReadArgs) XXX_Marshal added in v0.0.47 

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

func (*GCPPubSubReadArgs) XXX_Merge added in v0.0.47 

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

func (*GCPPubSubReadArgs) XXX_Size added in v0.0.47 

func (m *GCPPubSubReadArgs) XXX_Size() int

func (*GCPPubSubReadArgs) XXX_Unmarshal added in v0.0.47 

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

type GCPPubSubWriteArgs added in v0.0.47 

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

func (*GCPPubSubWriteArgs) Descriptor added in v0.0.47 

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

func (*GCPPubSubWriteArgs) GetTopicId added in v0.0.47 

func (m *GCPPubSubWriteArgs) GetTopicId() string

func (*GCPPubSubWriteArgs) ProtoMessage added in v0.0.47 

func (*GCPPubSubWriteArgs) ProtoMessage()

func (*GCPPubSubWriteArgs) Reset added in v0.0.47 

func (m *GCPPubSubWriteArgs) Reset()

func (*GCPPubSubWriteArgs) String added in v0.0.47 

func (m *GCPPubSubWriteArgs) String() string

func (*GCPPubSubWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *GCPPubSubWriteArgs) XXX_DiscardUnknown()

func (*GCPPubSubWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*GCPPubSubWriteArgs) XXX_Merge added in v0.0.47 

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

func (*GCPPubSubWriteArgs) XXX_Size added in v0.0.47 

func (m *GCPPubSubWriteArgs) XXX_Size() int

func (*GCPPubSubWriteArgs) XXX_Unmarshal added in v0.0.47 

func (m *GCPPubSubWriteArgs) 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 (options: none, plain, scram)',env=PLUMBER_RELAY_KAFKA_SASL_TYPE,type=pbenum,pbenum_lowercase,default=none"
	SaslType SASLType `` /* 257-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() 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 KafkaReadArgs added in v0.0.47 

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

func (*KafkaReadArgs) Descriptor added in v0.0.47 

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

func (*KafkaReadArgs) GetCommitIntervalSeconds added in v0.0.47 

func (m *KafkaReadArgs) GetCommitIntervalSeconds() int32

func (*KafkaReadArgs) GetConsumerGroupName added in v0.0.47 

func (m *KafkaReadArgs) GetConsumerGroupName() string

func (*KafkaReadArgs) GetIncludeOffsetInfo added in v0.0.51 

func (m *KafkaReadArgs) GetIncludeOffsetInfo() bool

func (*KafkaReadArgs) GetLag added in v0.0.51 

func (m *KafkaReadArgs) GetLag() bool

func (*KafkaReadArgs) GetLagConsumerGroup added in v0.0.51 

func (m *KafkaReadArgs) GetLagConsumerGroup() string

func (*KafkaReadArgs) GetMaxBytes added in v0.0.47 

func (m *KafkaReadArgs) GetMaxBytes() int32

func (*KafkaReadArgs) GetMaxWaitSeconds added in v0.0.47 

func (m *KafkaReadArgs) GetMaxWaitSeconds() int32

func (*KafkaReadArgs) GetMinBytes added in v0.0.47 

func (m *KafkaReadArgs) GetMinBytes() int32

func (*KafkaReadArgs) GetQueueCapacity added in v0.0.47 

func (m *KafkaReadArgs) GetQueueCapacity() int32

func (*KafkaReadArgs) GetReadOffset added in v0.0.47 

func (m *KafkaReadArgs) GetReadOffset() int64

func (*KafkaReadArgs) GetRebalanceTimeoutSeconds added in v0.0.47 

func (m *KafkaReadArgs) GetRebalanceTimeoutSeconds() int32

func (*KafkaReadArgs) GetTopics added in v0.0.47 

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

func (*KafkaReadArgs) GetUseConsumerGroup added in v0.0.47 

func (m *KafkaReadArgs) GetUseConsumerGroup() bool

func (*KafkaReadArgs) ProtoMessage added in v0.0.47 

func (*KafkaReadArgs) ProtoMessage()

func (*KafkaReadArgs) Reset added in v0.0.47 

func (m *KafkaReadArgs) Reset()

func (*KafkaReadArgs) String added in v0.0.47 

func (m *KafkaReadArgs) String() string

func (*KafkaReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *KafkaReadArgs) XXX_DiscardUnknown()

func (*KafkaReadArgs) XXX_Marshal added in v0.0.47 

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

func (*KafkaReadArgs) XXX_Merge added in v0.0.47 

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

func (*KafkaReadArgs) XXX_Size added in v0.0.47 

func (m *KafkaReadArgs) XXX_Size() int

func (*KafkaReadArgs) XXX_Unmarshal added in v0.0.47 

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

type KafkaRelayArgs added in v0.0.47 

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

func (*KafkaRelayArgs) Descriptor added in v0.0.47 

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

func (*KafkaRelayArgs) GetCommitIntervalSeconds added in v0.0.47 

func (m *KafkaRelayArgs) GetCommitIntervalSeconds() int32

func (*KafkaRelayArgs) GetConsumerGroupName added in v0.0.47 

func (m *KafkaRelayArgs) GetConsumerGroupName() string

func (*KafkaRelayArgs) GetMaxBytes added in v0.0.47 

func (m *KafkaRelayArgs) GetMaxBytes() int32

func (*KafkaRelayArgs) GetMaxWaitSeconds added in v0.0.47 

func (m *KafkaRelayArgs) GetMaxWaitSeconds() int32

func (*KafkaRelayArgs) GetMinBytes added in v0.0.47 

func (m *KafkaRelayArgs) GetMinBytes() int32

func (*KafkaRelayArgs) GetQueueCapacity added in v0.0.47 

func (m *KafkaRelayArgs) GetQueueCapacity() int32

func (*KafkaRelayArgs) GetReadOffset added in v0.0.47 

func (m *KafkaRelayArgs) GetReadOffset() int64

func (*KafkaRelayArgs) GetRebalanceTimeoutSeconds added in v0.0.47 

func (m *KafkaRelayArgs) GetRebalanceTimeoutSeconds() int32

func (*KafkaRelayArgs) GetTopics added in v0.0.47 

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

func (*KafkaRelayArgs) GetUseConsumerGroup added in v0.0.47 

func (m *KafkaRelayArgs) GetUseConsumerGroup() bool

func (*KafkaRelayArgs) ProtoMessage added in v0.0.47 

func (*KafkaRelayArgs) ProtoMessage()

func (*KafkaRelayArgs) Reset added in v0.0.47 

func (m *KafkaRelayArgs) Reset()

func (*KafkaRelayArgs) String added in v0.0.47 

func (m *KafkaRelayArgs) String() string

func (*KafkaRelayArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *KafkaRelayArgs) XXX_DiscardUnknown()

func (*KafkaRelayArgs) XXX_Marshal added in v0.0.47 

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

func (*KafkaRelayArgs) XXX_Merge added in v0.0.47 

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

func (*KafkaRelayArgs) XXX_Size added in v0.0.47 

func (m *KafkaRelayArgs) XXX_Size() int

func (*KafkaRelayArgs) XXX_Unmarshal added in v0.0.47 

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

type KafkaWriteArgs added in v0.0.47 

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

func (*KafkaWriteArgs) Descriptor added in v0.0.47 

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

func (*KafkaWriteArgs) GetHeaders added in v0.0.47 

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

func (*KafkaWriteArgs) GetKey added in v0.0.47 

func (m *KafkaWriteArgs) GetKey() string

func (*KafkaWriteArgs) GetTopics added in v0.0.52 

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

func (*KafkaWriteArgs) ProtoMessage added in v0.0.47 

func (*KafkaWriteArgs) ProtoMessage()

func (*KafkaWriteArgs) Reset added in v0.0.47 

func (m *KafkaWriteArgs) Reset()

func (*KafkaWriteArgs) String added in v0.0.47 

func (m *KafkaWriteArgs) String() string

func (*KafkaWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *KafkaWriteArgs) XXX_DiscardUnknown()

func (*KafkaWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*KafkaWriteArgs) XXX_Merge added in v0.0.47 

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

func (*KafkaWriteArgs) XXX_Size added in v0.0.47 

func (m *KafkaWriteArgs) XXX_Size() int

func (*KafkaWriteArgs) XXX_Unmarshal added in v0.0.47 

func (m *KafkaWriteArgs) 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 KubeMQQueueReadArgs added in v0.0.47 

type KubeMQQueueReadArgs 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 (*KubeMQQueueReadArgs) Descriptor added in v0.0.47 

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

func (*KubeMQQueueReadArgs) GetClientId added in v0.0.47 

func (m *KubeMQQueueReadArgs) GetClientId() string

func (*KubeMQQueueReadArgs) GetQueueName added in v0.0.47 

func (m *KubeMQQueueReadArgs) GetQueueName() string

func (*KubeMQQueueReadArgs) ProtoMessage added in v0.0.47 

func (*KubeMQQueueReadArgs) ProtoMessage()

func (*KubeMQQueueReadArgs) Reset added in v0.0.47 

func (m *KubeMQQueueReadArgs) Reset()

func (*KubeMQQueueReadArgs) String added in v0.0.47 

func (m *KubeMQQueueReadArgs) String() string

func (*KubeMQQueueReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *KubeMQQueueReadArgs) XXX_DiscardUnknown()

func (*KubeMQQueueReadArgs) XXX_Marshal added in v0.0.47 

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

func (*KubeMQQueueReadArgs) XXX_Merge added in v0.0.47 

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

func (*KubeMQQueueReadArgs) XXX_Size added in v0.0.47 

func (m *KubeMQQueueReadArgs) XXX_Size() int

func (*KubeMQQueueReadArgs) XXX_Unmarshal added in v0.0.47 

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

type KubeMQQueueWriteArgs added in v0.0.47 

type KubeMQQueueWriteArgs 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 (*KubeMQQueueWriteArgs) Descriptor added in v0.0.47 

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

func (*KubeMQQueueWriteArgs) GetClientId added in v0.0.47 

func (m *KubeMQQueueWriteArgs) GetClientId() string

func (*KubeMQQueueWriteArgs) GetQueueName added in v0.0.47 

func (m *KubeMQQueueWriteArgs) GetQueueName() string

func (*KubeMQQueueWriteArgs) ProtoMessage added in v0.0.47 

func (*KubeMQQueueWriteArgs) ProtoMessage()

func (*KubeMQQueueWriteArgs) Reset added in v0.0.47 

func (m *KubeMQQueueWriteArgs) Reset()

func (*KubeMQQueueWriteArgs) String added in v0.0.47 

func (m *KubeMQQueueWriteArgs) String() string

func (*KubeMQQueueWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *KubeMQQueueWriteArgs) XXX_DiscardUnknown()

func (*KubeMQQueueWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*KubeMQQueueWriteArgs) XXX_Merge added in v0.0.47 

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

func (*KubeMQQueueWriteArgs) XXX_Size added in v0.0.47 

func (m *KubeMQQueueWriteArgs) XXX_Size() int

func (*KubeMQQueueWriteArgs) XXX_Unmarshal added in v0.0.47 

func (m *KubeMQQueueWriteArgs) 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 (options: at_most_once, at_least_once, exactly_once)',env=PLUMBER_RELAY_MQTT_QOS,type=pbenum,pbenum_strip_prefix=MQTT_QOS_LEVEL_,pbenum_lowercase,default=at_most_once"
	QosLevel MQTTQoSLevel `` /* 325-byte string literal not displayed */
	// @gotags: kong:"embed"
	TlsOptions           *MQTTTLSOptions `protobuf:"bytes,6,opt,name=tls_options,json=tlsOptions,proto3" json:"tls_options,omitempty" kong:"embed"`
	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() MQTTQoSLevel

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
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 MQTTReadArgs added in v0.0.47 

type MQTTReadArgs struct {
	// @gotags: kong:"help='Topic to read message(s) from',env='PLUMBER_RELAY_MQTT_TOPIC',required"
	Topic string `` /* 147-byte string literal not displayed */
	// @gotags: kong:"help='How long to attempt to read message(s)',default=0,env='PLUMBER_RELAY_MQTT_READ_TIMEOUT_SECONDS'"
	ReadTimeoutSeconds   uint32   `` /* 227-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MQTTReadArgs) Descriptor added in v0.0.47 

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

func (*MQTTReadArgs) GetReadTimeoutSeconds added in v0.0.47 

func (m *MQTTReadArgs) GetReadTimeoutSeconds() uint32

func (*MQTTReadArgs) GetTopic added in v0.0.47 

func (m *MQTTReadArgs) GetTopic() string

func (*MQTTReadArgs) ProtoMessage added in v0.0.47 

func (*MQTTReadArgs) ProtoMessage()

func (*MQTTReadArgs) Reset added in v0.0.47 

func (m *MQTTReadArgs) Reset()

func (*MQTTReadArgs) String added in v0.0.47 

func (m *MQTTReadArgs) String() string

func (*MQTTReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *MQTTReadArgs) XXX_DiscardUnknown()

func (*MQTTReadArgs) XXX_Marshal added in v0.0.47 

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

func (*MQTTReadArgs) XXX_Merge added in v0.0.47 

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

func (*MQTTReadArgs) XXX_Size added in v0.0.47 

func (m *MQTTReadArgs) XXX_Size() int

func (*MQTTReadArgs) XXX_Unmarshal added in v0.0.47 

func (m *MQTTReadArgs) 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 MQTTWriteArgs added in v0.0.47 

type MQTTWriteArgs struct {
	// @gotags: kong:"help='Topic to write message(s) to',required"
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic to write message(s) to',required"`
	// @gotags: kong:"help='How long to attempt to publish message(s)',default=5"
	WriteTimeoutSeconds  uint32   `` /* 187-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MQTTWriteArgs) Descriptor added in v0.0.47 

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

func (*MQTTWriteArgs) GetTopic added in v0.0.47 

func (m *MQTTWriteArgs) GetTopic() string

func (*MQTTWriteArgs) GetWriteTimeoutSeconds added in v0.0.47 

func (m *MQTTWriteArgs) GetWriteTimeoutSeconds() uint32

func (*MQTTWriteArgs) ProtoMessage added in v0.0.47 

func (*MQTTWriteArgs) ProtoMessage()

func (*MQTTWriteArgs) Reset added in v0.0.47 

func (m *MQTTWriteArgs) Reset()

func (*MQTTWriteArgs) String added in v0.0.47 

func (m *MQTTWriteArgs) String() string

func (*MQTTWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *MQTTWriteArgs) XXX_DiscardUnknown()

func (*MQTTWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*MQTTWriteArgs) XXX_Merge added in v0.0.47 

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

func (*MQTTWriteArgs) XXX_Size added in v0.0.47 

func (m *MQTTWriteArgs) XXX_Size() int

func (*MQTTWriteArgs) XXX_Unmarshal added in v0.0.47 

func (m *MQTTWriteArgs) 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='PLUMBER_RELAY_CDCMONGO_DSN',default='mongodb://localhost:27017'"
	Dsn                  string   `` /* 203-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 MongoReadArgs added in v0.0.47 

type MongoReadArgs struct {
	// @gotags: kong:"help='Database name',env='PLUMBER_RELAY_CDCMONGO_DATABASE'"
	Database string `` /* 135-byte string literal not displayed */
	// @gotags: kong:"help='Collection name',env='PLUMBER_RELAY_CDCMONGO_COLLECTION'"
	Collection string `` /* 143-byte string literal not displayed */
	// @gotags: kong:"help='Include full document in update in update changes (default - return deltas only)',env='PLUMBER_RELAY_CDCMONGO_INCLUDE_FULL_DOC'"
	IncludeFullDocument  bool     `` /* 262-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MongoReadArgs) Descriptor added in v0.0.47 

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

func (*MongoReadArgs) GetCollection added in v0.0.47 

func (m *MongoReadArgs) GetCollection() string

func (*MongoReadArgs) GetDatabase added in v0.0.47 

func (m *MongoReadArgs) GetDatabase() string

func (*MongoReadArgs) GetIncludeFullDocument added in v0.0.47 

func (m *MongoReadArgs) GetIncludeFullDocument() bool

func (*MongoReadArgs) ProtoMessage added in v0.0.47 

func (*MongoReadArgs) ProtoMessage()

func (*MongoReadArgs) Reset added in v0.0.47 

func (m *MongoReadArgs) Reset()

func (*MongoReadArgs) String added in v0.0.47 

func (m *MongoReadArgs) String() string

func (*MongoReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *MongoReadArgs) XXX_DiscardUnknown()

func (*MongoReadArgs) XXX_Marshal added in v0.0.47 

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

func (*MongoReadArgs) XXX_Merge added in v0.0.47 

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

func (*MongoReadArgs) XXX_Size added in v0.0.47 

func (m *MongoReadArgs) XXX_Size() int

func (*MongoReadArgs) XXX_Unmarshal added in v0.0.47 

func (m *MongoReadArgs) 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 NSQReadArgs added in v0.0.47 

type NSQReadArgs struct {
	// @gotags: kong:"help='NSQ topic to read from',env='PLUMBER_RELAY_NSQ_TOPIC',required"
	Topic string `` /* 139-byte string literal not displayed */
	// @gotags: kong:"help='Output channel',env='PLUMBER_RELAY_NSQ_CHANNEL',required"
	Channel              string   `` /* 137-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NSQReadArgs) Descriptor added in v0.0.47 

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

func (*NSQReadArgs) GetChannel added in v0.0.47 

func (m *NSQReadArgs) GetChannel() string

func (*NSQReadArgs) GetTopic added in v0.0.47 

func (m *NSQReadArgs) GetTopic() string

func (*NSQReadArgs) ProtoMessage added in v0.0.47 

func (*NSQReadArgs) ProtoMessage()

func (*NSQReadArgs) Reset added in v0.0.47 

func (m *NSQReadArgs) Reset()

func (*NSQReadArgs) String added in v0.0.47 

func (m *NSQReadArgs) String() string

func (*NSQReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *NSQReadArgs) XXX_DiscardUnknown()

func (*NSQReadArgs) XXX_Marshal added in v0.0.47 

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

func (*NSQReadArgs) XXX_Merge added in v0.0.47 

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

func (*NSQReadArgs) XXX_Size added in v0.0.47 

func (m *NSQReadArgs) XXX_Size() int

func (*NSQReadArgs) XXX_Unmarshal added in v0.0.47 

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

type NSQWriteArgs added in v0.0.47 

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

func (*NSQWriteArgs) Descriptor added in v0.0.47 

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

func (*NSQWriteArgs) GetTopic added in v0.0.47 

func (m *NSQWriteArgs) GetTopic() string

func (*NSQWriteArgs) ProtoMessage added in v0.0.47 

func (*NSQWriteArgs) ProtoMessage()

func (*NSQWriteArgs) Reset added in v0.0.47 

func (m *NSQWriteArgs) Reset()

func (*NSQWriteArgs) String added in v0.0.47 

func (m *NSQWriteArgs) String() string

func (*NSQWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *NSQWriteArgs) XXX_DiscardUnknown()

func (*NSQWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*NSQWriteArgs) XXX_Merge added in v0.0.47 

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

func (*NSQWriteArgs) XXX_Size added in v0.0.47 

func (m *NSQWriteArgs) XXX_Size() int

func (*NSQWriteArgs) XXX_Unmarshal added in v0.0.47 

func (m *NSQWriteArgs) 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 NatsReadArgs added in v0.0.47 

type NatsReadArgs 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 (*NatsReadArgs) Descriptor added in v0.0.47 

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

func (*NatsReadArgs) GetSubject added in v0.0.47 

func (m *NatsReadArgs) GetSubject() string

func (*NatsReadArgs) ProtoMessage added in v0.0.47 

func (*NatsReadArgs) ProtoMessage()

func (*NatsReadArgs) Reset added in v0.0.47 

func (m *NatsReadArgs) Reset()

func (*NatsReadArgs) String added in v0.0.47 

func (m *NatsReadArgs) String() string

func (*NatsReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *NatsReadArgs) XXX_DiscardUnknown()

func (*NatsReadArgs) XXX_Marshal added in v0.0.47 

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

func (*NatsReadArgs) XXX_Merge added in v0.0.47 

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

func (*NatsReadArgs) XXX_Size added in v0.0.47 

func (m *NatsReadArgs) XXX_Size() int

func (*NatsReadArgs) XXX_Unmarshal added in v0.0.47 

func (m *NatsReadArgs) 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 NatsStreamingReadArgs added in v0.0.47 

type NatsStreamingReadArgs 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 (*NatsStreamingReadArgs) Descriptor added in v0.0.47 

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

func (*NatsStreamingReadArgs) GetChannel added in v0.0.47 

func (m *NatsStreamingReadArgs) GetChannel() string

func (*NatsStreamingReadArgs) GetDurableName added in v0.0.47 

func (m *NatsStreamingReadArgs) GetDurableName() string

func (*NatsStreamingReadArgs) GetReadAll added in v0.0.47 

func (m *NatsStreamingReadArgs) GetReadAll() bool

func (*NatsStreamingReadArgs) GetReadLastAvailable added in v0.0.47 

func (m *NatsStreamingReadArgs) GetReadLastAvailable() bool

func (*NatsStreamingReadArgs) GetReadSequenceNumber added in v0.0.47 

func (m *NatsStreamingReadArgs) GetReadSequenceNumber() uint32

func (*NatsStreamingReadArgs) GetReadSince added in v0.0.47 

func (m *NatsStreamingReadArgs) GetReadSince() string

func (*NatsStreamingReadArgs) ProtoMessage added in v0.0.47 

func (*NatsStreamingReadArgs) ProtoMessage()

func (*NatsStreamingReadArgs) Reset added in v0.0.47 

func (m *NatsStreamingReadArgs) Reset()

func (*NatsStreamingReadArgs) String added in v0.0.47 

func (m *NatsStreamingReadArgs) String() string

func (*NatsStreamingReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *NatsStreamingReadArgs) XXX_DiscardUnknown()

func (*NatsStreamingReadArgs) XXX_Marshal added in v0.0.47 

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

func (*NatsStreamingReadArgs) XXX_Merge added in v0.0.47 

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

func (*NatsStreamingReadArgs) XXX_Size added in v0.0.47 

func (m *NatsStreamingReadArgs) XXX_Size() int

func (*NatsStreamingReadArgs) XXX_Unmarshal added in v0.0.47 

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

type NatsStreamingWriteArgs added in v0.0.47 

type NatsStreamingWriteArgs struct {
	// @gotags: kong:"help='NATS stream channel. Ex: orders'"
	Channel              string   `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty" kong:"help='NATS stream channel. Ex: orders'"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NatsStreamingWriteArgs) Descriptor added in v0.0.47 

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

func (*NatsStreamingWriteArgs) GetChannel added in v0.0.47 

func (m *NatsStreamingWriteArgs) GetChannel() string

func (*NatsStreamingWriteArgs) ProtoMessage added in v0.0.47 

func (*NatsStreamingWriteArgs) ProtoMessage()

func (*NatsStreamingWriteArgs) Reset added in v0.0.47 

func (m *NatsStreamingWriteArgs) Reset()

func (*NatsStreamingWriteArgs) String added in v0.0.47 

func (m *NatsStreamingWriteArgs) String() string

func (*NatsStreamingWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *NatsStreamingWriteArgs) XXX_DiscardUnknown()

func (*NatsStreamingWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*NatsStreamingWriteArgs) XXX_Merge added in v0.0.47 

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

func (*NatsStreamingWriteArgs) XXX_Size added in v0.0.47 

func (m *NatsStreamingWriteArgs) XXX_Size() int

func (*NatsStreamingWriteArgs) XXX_Unmarshal added in v0.0.47 

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

type NatsWriteArgs added in v0.0.47 

type NatsWriteArgs struct {
	// @gotags: kong:"help='NATS Subject. Ex: foo.bar.*'"
	Subject              string   `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty" kong:"help='NATS Subject. Ex: foo.bar.*'"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NatsWriteArgs) Descriptor added in v0.0.47 

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

func (*NatsWriteArgs) GetSubject added in v0.0.47 

func (m *NatsWriteArgs) GetSubject() string

func (*NatsWriteArgs) ProtoMessage added in v0.0.47 

func (*NatsWriteArgs) ProtoMessage()

func (*NatsWriteArgs) Reset added in v0.0.47 

func (m *NatsWriteArgs) Reset()

func (*NatsWriteArgs) String added in v0.0.47 

func (m *NatsWriteArgs) String() string

func (*NatsWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *NatsWriteArgs) XXX_DiscardUnknown()

func (*NatsWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*NatsWriteArgs) XXX_Merge added in v0.0.47 

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

func (*NatsWriteArgs) XXX_Size added in v0.0.47 

func (m *NatsWriteArgs) XXX_Size() int

func (*NatsWriteArgs) XXX_Unmarshal added in v0.0.47 

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

type OffsetStart added in v0.0.69 

type OffsetStart int32
const (
	OffsetStart_Latest OffsetStart = 0
	OffsetStart_Oldest OffsetStart = 1
)

func (OffsetStart) EnumDescriptor added in v0.0.69 

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

func (OffsetStart) String added in v0.0.69 

func (x OffsetStart) String() string

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 PostgresReadArgs added in v0.0.47 

type PostgresReadArgs struct {
	// @gotags: kong:"help='CDC replication slot name',env='PLUMBER_RELAY_CDCPOSTGRES_SLOT',required"
	ReplicationSlotName string `` /* 206-byte string literal not displayed */
	// @gotags: kong:"help='CDC publisher name',env='PLUMBER_RELAY_CDCPOSTGRES_PUBLISHER',required"
	PublisherName        string   `` /* 184-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostgresReadArgs) Descriptor added in v0.0.47 

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

func (*PostgresReadArgs) GetPublisherName added in v0.0.47 

func (m *PostgresReadArgs) GetPublisherName() string

func (*PostgresReadArgs) GetReplicationSlotName added in v0.0.47 

func (m *PostgresReadArgs) GetReplicationSlotName() string

func (*PostgresReadArgs) ProtoMessage added in v0.0.47 

func (*PostgresReadArgs) ProtoMessage()

func (*PostgresReadArgs) Reset added in v0.0.47 

func (m *PostgresReadArgs) Reset()

func (*PostgresReadArgs) String added in v0.0.47 

func (m *PostgresReadArgs) String() string

func (*PostgresReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *PostgresReadArgs) XXX_DiscardUnknown()

func (*PostgresReadArgs) XXX_Marshal added in v0.0.47 

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

func (*PostgresReadArgs) XXX_Merge added in v0.0.47 

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

func (*PostgresReadArgs) XXX_Size added in v0.0.47 

func (m *PostgresReadArgs) XXX_Size() int

func (*PostgresReadArgs) XXX_Unmarshal added in v0.0.47 

func (m *PostgresReadArgs) 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 PulsarReadArgs added in v0.0.47 

type PulsarReadArgs struct {
	// @gotags: kong:"help='Topic to read messages from',required"
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic to read messages from',required"`
	// @gotags: kong:"help='Subscription name',required"
	SubscriptionName string `` /* 150-byte string literal not displayed */
	// @gotags: kong:"help='Subscription type (options: shared, exclusive, failover, keyshared)',default=shared,type=pbenum,pbenum_lowercase"
	SubscriptionType     SubscriptionType `` /* 270-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*PulsarReadArgs) Descriptor added in v0.0.47 

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

func (*PulsarReadArgs) GetSubscriptionName added in v0.0.47 

func (m *PulsarReadArgs) GetSubscriptionName() string

func (*PulsarReadArgs) GetSubscriptionType added in v0.0.47 

func (m *PulsarReadArgs) GetSubscriptionType() SubscriptionType

func (*PulsarReadArgs) GetTopic added in v0.0.47 

func (m *PulsarReadArgs) GetTopic() string

func (*PulsarReadArgs) ProtoMessage added in v0.0.47 

func (*PulsarReadArgs) ProtoMessage()

func (*PulsarReadArgs) Reset added in v0.0.47 

func (m *PulsarReadArgs) Reset()

func (*PulsarReadArgs) String added in v0.0.47 

func (m *PulsarReadArgs) String() string

func (*PulsarReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *PulsarReadArgs) XXX_DiscardUnknown()

func (*PulsarReadArgs) XXX_Marshal added in v0.0.47 

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

func (*PulsarReadArgs) XXX_Merge added in v0.0.47 

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

func (*PulsarReadArgs) XXX_Size added in v0.0.47 

func (m *PulsarReadArgs) XXX_Size() int

func (*PulsarReadArgs) XXX_Unmarshal added in v0.0.47 

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

type PulsarWriteArgs added in v0.0.47 

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

func (*PulsarWriteArgs) Descriptor added in v0.0.47 

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

func (*PulsarWriteArgs) GetTopic added in v0.0.47 

func (m *PulsarWriteArgs) GetTopic() string

func (*PulsarWriteArgs) ProtoMessage added in v0.0.47 

func (*PulsarWriteArgs) ProtoMessage()

func (*PulsarWriteArgs) Reset added in v0.0.47 

func (m *PulsarWriteArgs) Reset()

func (*PulsarWriteArgs) String added in v0.0.47 

func (m *PulsarWriteArgs) String() string

func (*PulsarWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *PulsarWriteArgs) XXX_DiscardUnknown()

func (*PulsarWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*PulsarWriteArgs) XXX_Merge added in v0.0.47 

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

func (*PulsarWriteArgs) XXX_Size added in v0.0.47 

func (m *PulsarWriteArgs) XXX_Size() int

func (*PulsarWriteArgs) XXX_Unmarshal added in v0.0.47 

func (m *PulsarWriteArgs) 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 RabbitReadArgs added in v0.0.47 

type RabbitReadArgs struct {
	// @gotags: kong:"help='Name of the exchange',env='PLUMBER_RELAY_RABBIT_EXCHANGE',required"
	ExchangeName string `` /* 177-byte string literal not displayed */
	// @gotags: kong:"help='Name of the queue where messages will be routed to',env='PLUMBER_RELAY_RABBIT_QUEUE',required"
	QueueName string `` /* 195-byte string literal not displayed */
	// @gotags: kong:"help='Binding key for topic based exchanges',env='PLUMBER_RELAY_RABBIT_ROUTING_KEY',required"
	BindingKey string `` /* 191-byte string literal not displayed */
	// @gotags: kong:"help='Whether plumber should be the only one using the queue',env='PLUMBER_RELAY_RABBIT_QUEUE_EXCLUSIVE'"
	QueueExclusive bool `` /* 216-byte string literal not displayed */
	// @gotags: kong:"help='Whether to create/declare the queue (if it does not exist)',env='PLUMBER_RELAY_RABBIT_QUEUE_DECLARE',default=true"
	QueueDeclare bool `` /* 225-byte string literal not displayed */
	// @gotags: kong:"help='Whether the queue should survive after disconnect',env='PLUMBER_RELAY_RABBIT_QUEUE_DURABLE'"
	QueueDurable bool `` /* 203-byte string literal not displayed */
	// @gotags: kong:"help='Automatically acknowledge receipt of read/received messages',env='PLUMBER_RELAY_RABBIT_AUTOACK',default=true"
	AutoAck bool `` /* 205-byte string literal not displayed */
	// @gotags: kong:"help='How to identify the consumer to RabbitMQ',env='PLUMBER_RELAY_CONSUMER_TAG',default=plumber"
	ConsumerTag string `` /* 198-byte string literal not displayed */
	// @gotags: kong:"help='Whether to auto-delete the queue after plumber has disconnected',env='PLUMBER_RELAY_RABBIT_QUEUE_AUTO_DELETE',default=true"
	QueueDelete          bool     `` /* 231-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RabbitReadArgs) Descriptor added in v0.0.47 

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

func (*RabbitReadArgs) GetAutoAck added in v0.0.47 

func (m *RabbitReadArgs) GetAutoAck() bool

func (*RabbitReadArgs) GetBindingKey added in v0.0.47 

func (m *RabbitReadArgs) GetBindingKey() string

func (*RabbitReadArgs) GetConsumerTag added in v0.0.47 

func (m *RabbitReadArgs) GetConsumerTag() string

func (*RabbitReadArgs) GetExchangeName added in v0.0.47 

func (m *RabbitReadArgs) GetExchangeName() string

func (*RabbitReadArgs) GetQueueDeclare added in v0.0.47 

func (m *RabbitReadArgs) GetQueueDeclare() bool

func (*RabbitReadArgs) GetQueueDelete added in v0.0.47 

func (m *RabbitReadArgs) GetQueueDelete() bool

func (*RabbitReadArgs) GetQueueDurable added in v0.0.47 

func (m *RabbitReadArgs) GetQueueDurable() bool

func (*RabbitReadArgs) GetQueueExclusive added in v0.0.47 

func (m *RabbitReadArgs) GetQueueExclusive() bool

func (*RabbitReadArgs) GetQueueName added in v0.0.47 

func (m *RabbitReadArgs) GetQueueName() string

func (*RabbitReadArgs) ProtoMessage added in v0.0.47 

func (*RabbitReadArgs) ProtoMessage()

func (*RabbitReadArgs) Reset added in v0.0.47 

func (m *RabbitReadArgs) Reset()

func (*RabbitReadArgs) String added in v0.0.47 

func (m *RabbitReadArgs) String() string

func (*RabbitReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *RabbitReadArgs) XXX_DiscardUnknown()

func (*RabbitReadArgs) XXX_Marshal added in v0.0.47 

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

func (*RabbitReadArgs) XXX_Merge added in v0.0.47 

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

func (*RabbitReadArgs) XXX_Size added in v0.0.47 

func (m *RabbitReadArgs) XXX_Size() int

func (*RabbitReadArgs) XXX_Unmarshal added in v0.0.47 

func (m *RabbitReadArgs) 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 RabbitStreamsReadArgs added in v0.0.47 

type RabbitStreamsReadArgs struct {
	// @gotags: kong:"help='Stream name',required"
	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty" kong:"help='Stream name',required"`
	// @gotags: kong:"help='Declare the stream if it does not exist'"
	DeclareStream bool `` /* 155-byte string literal not displayed */
	// @gotags: kong:"help='Stream capacity to declare (required if declare_stream is true; ex: 1024k, 10mb, 3gb'"
	DeclareStreamSize string `` /* 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 (*RabbitStreamsReadArgs) Descriptor added in v0.0.47 

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

func (*RabbitStreamsReadArgs) GetDeclareStream added in v0.0.47 

func (m *RabbitStreamsReadArgs) GetDeclareStream() bool

func (*RabbitStreamsReadArgs) GetDeclareStreamSize added in v0.0.47 

func (m *RabbitStreamsReadArgs) GetDeclareStreamSize() string

func (*RabbitStreamsReadArgs) GetOffsetOptions added in v0.0.47 

func (m *RabbitStreamsReadArgs) GetOffsetOptions() *RabbitStreamsOffsetOptions

func (*RabbitStreamsReadArgs) GetStream added in v0.0.47 

func (m *RabbitStreamsReadArgs) GetStream() string

func (*RabbitStreamsReadArgs) ProtoMessage added in v0.0.47 

func (*RabbitStreamsReadArgs) ProtoMessage()

func (*RabbitStreamsReadArgs) Reset added in v0.0.47 

func (m *RabbitStreamsReadArgs) Reset()

func (*RabbitStreamsReadArgs) String added in v0.0.47 

func (m *RabbitStreamsReadArgs) String() string

func (*RabbitStreamsReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *RabbitStreamsReadArgs) XXX_DiscardUnknown()

func (*RabbitStreamsReadArgs) XXX_Marshal added in v0.0.47 

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

func (*RabbitStreamsReadArgs) XXX_Merge added in v0.0.47 

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

func (*RabbitStreamsReadArgs) XXX_Size added in v0.0.47 

func (m *RabbitStreamsReadArgs) XXX_Size() int

func (*RabbitStreamsReadArgs) XXX_Unmarshal added in v0.0.47 

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

type RabbitStreamsWriteArgs added in v0.0.47 

type RabbitStreamsWriteArgs 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 (*RabbitStreamsWriteArgs) Descriptor added in v0.0.47 

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

func (*RabbitStreamsWriteArgs) GetDeclareStream added in v0.0.47 

func (m *RabbitStreamsWriteArgs) GetDeclareStream() bool

func (*RabbitStreamsWriteArgs) GetDeclareStreamSize added in v0.0.47 

func (m *RabbitStreamsWriteArgs) GetDeclareStreamSize() string

func (*RabbitStreamsWriteArgs) GetStream added in v0.0.47 

func (m *RabbitStreamsWriteArgs) GetStream() string

func (*RabbitStreamsWriteArgs) ProtoMessage added in v0.0.47 

func (*RabbitStreamsWriteArgs) ProtoMessage()

func (*RabbitStreamsWriteArgs) Reset added in v0.0.47 

func (m *RabbitStreamsWriteArgs) Reset()

func (*RabbitStreamsWriteArgs) String added in v0.0.47 

func (m *RabbitStreamsWriteArgs) String() string

func (*RabbitStreamsWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *RabbitStreamsWriteArgs) XXX_DiscardUnknown()

func (*RabbitStreamsWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*RabbitStreamsWriteArgs) XXX_Merge added in v0.0.47 

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

func (*RabbitStreamsWriteArgs) XXX_Size added in v0.0.47 

func (m *RabbitStreamsWriteArgs) XXX_Size() int

func (*RabbitStreamsWriteArgs) XXX_Unmarshal added in v0.0.47 

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

type RabbitWriteArgs added in v0.0.47 

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

func (*RabbitWriteArgs) Descriptor added in v0.0.47 

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

func (*RabbitWriteArgs) GetAppId added in v0.0.47 

func (m *RabbitWriteArgs) GetAppId() string

func (*RabbitWriteArgs) GetExchangeAutoDelete added in v0.0.54 

func (m *RabbitWriteArgs) GetExchangeAutoDelete() bool

func (*RabbitWriteArgs) GetExchangeDeclare added in v0.0.54 

func (m *RabbitWriteArgs) GetExchangeDeclare() bool

func (*RabbitWriteArgs) GetExchangeDurable added in v0.0.54 

func (m *RabbitWriteArgs) GetExchangeDurable() bool

func (*RabbitWriteArgs) GetExchangeName added in v0.0.47 

func (m *RabbitWriteArgs) GetExchangeName() string

func (*RabbitWriteArgs) GetExchangeType added in v0.0.54 

func (m *RabbitWriteArgs) GetExchangeType() string

func (*RabbitWriteArgs) GetRoutingKey added in v0.0.47 

func (m *RabbitWriteArgs) GetRoutingKey() string

func (*RabbitWriteArgs) ProtoMessage added in v0.0.47 

func (*RabbitWriteArgs) ProtoMessage()

func (*RabbitWriteArgs) Reset added in v0.0.47 

func (m *RabbitWriteArgs) Reset()

func (*RabbitWriteArgs) String added in v0.0.47 

func (m *RabbitWriteArgs) String() string

func (*RabbitWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *RabbitWriteArgs) XXX_DiscardUnknown()

func (*RabbitWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*RabbitWriteArgs) XXX_Merge added in v0.0.47 

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

func (*RabbitWriteArgs) XXX_Size added in v0.0.47 

func (m *RabbitWriteArgs) XXX_Size() int

func (*RabbitWriteArgs) XXX_Unmarshal added in v0.0.47 

func (m *RabbitWriteArgs) 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 RedisPubSubReadArgs added in v0.0.47 

type RedisPubSubReadArgs 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 (*RedisPubSubReadArgs) Descriptor added in v0.0.47 

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

func (*RedisPubSubReadArgs) GetChannel added in v0.0.47 

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

func (*RedisPubSubReadArgs) GetDatabase added in v0.0.47 

func (m *RedisPubSubReadArgs) GetDatabase() uint32

func (*RedisPubSubReadArgs) ProtoMessage added in v0.0.47 

func (*RedisPubSubReadArgs) ProtoMessage()

func (*RedisPubSubReadArgs) Reset added in v0.0.47 

func (m *RedisPubSubReadArgs) Reset()

func (*RedisPubSubReadArgs) String added in v0.0.47 

func (m *RedisPubSubReadArgs) String() string

func (*RedisPubSubReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *RedisPubSubReadArgs) XXX_DiscardUnknown()

func (*RedisPubSubReadArgs) XXX_Marshal added in v0.0.47 

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

func (*RedisPubSubReadArgs) XXX_Merge added in v0.0.47 

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

func (*RedisPubSubReadArgs) XXX_Size added in v0.0.47 

func (m *RedisPubSubReadArgs) XXX_Size() int

func (*RedisPubSubReadArgs) XXX_Unmarshal added in v0.0.47 

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

type RedisPubSubWriteArgs added in v0.0.47 

type RedisPubSubWriteArgs 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 (*RedisPubSubWriteArgs) Descriptor added in v0.0.47 

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

func (*RedisPubSubWriteArgs) GetChannel added in v0.0.47 

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

func (*RedisPubSubWriteArgs) GetDatabase added in v0.0.47 

func (m *RedisPubSubWriteArgs) GetDatabase() uint32

func (*RedisPubSubWriteArgs) ProtoMessage added in v0.0.47 

func (*RedisPubSubWriteArgs) ProtoMessage()

func (*RedisPubSubWriteArgs) Reset added in v0.0.47 

func (m *RedisPubSubWriteArgs) Reset()

func (*RedisPubSubWriteArgs) String added in v0.0.47 

func (m *RedisPubSubWriteArgs) String() string

func (*RedisPubSubWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *RedisPubSubWriteArgs) XXX_DiscardUnknown()

func (*RedisPubSubWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*RedisPubSubWriteArgs) XXX_Merge added in v0.0.47 

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

func (*RedisPubSubWriteArgs) XXX_Size added in v0.0.47 

func (m *RedisPubSubWriteArgs) XXX_Size() int

func (*RedisPubSubWriteArgs) XXX_Unmarshal added in v0.0.47 

func (m *RedisPubSubWriteArgs) 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 RedisStreamsReadArgs added in v0.0.47 

type RedisStreamsReadArgs 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 (*RedisStreamsReadArgs) Descriptor added in v0.0.47 

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

func (*RedisStreamsReadArgs) GetConsumerGroup added in v0.0.47 

func (m *RedisStreamsReadArgs) GetConsumerGroup() string

func (*RedisStreamsReadArgs) GetConsumerName added in v0.0.47 

func (m *RedisStreamsReadArgs) GetConsumerName() string

func (*RedisStreamsReadArgs) GetCount added in v0.0.47 

func (m *RedisStreamsReadArgs) GetCount() uint32

func (*RedisStreamsReadArgs) GetCreateConsumerConfig added in v0.0.47 

func (m *RedisStreamsReadArgs) GetCreateConsumerConfig() *CreateConsumerConfig

func (*RedisStreamsReadArgs) GetDatabase added in v0.0.47 

func (m *RedisStreamsReadArgs) GetDatabase() uint32

func (*RedisStreamsReadArgs) GetStream added in v0.0.47 

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

func (*RedisStreamsReadArgs) ProtoMessage added in v0.0.47 

func (*RedisStreamsReadArgs) ProtoMessage()

func (*RedisStreamsReadArgs) Reset added in v0.0.47 

func (m *RedisStreamsReadArgs) Reset()

func (*RedisStreamsReadArgs) String added in v0.0.47 

func (m *RedisStreamsReadArgs) String() string

func (*RedisStreamsReadArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *RedisStreamsReadArgs) XXX_DiscardUnknown()

func (*RedisStreamsReadArgs) XXX_Marshal added in v0.0.47 

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

func (*RedisStreamsReadArgs) XXX_Merge added in v0.0.47 

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

func (*RedisStreamsReadArgs) XXX_Size added in v0.0.47 

func (m *RedisStreamsReadArgs) XXX_Size() int

func (*RedisStreamsReadArgs) XXX_Unmarshal added in v0.0.47 

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

type RedisStreamsWriteArgs added in v0.0.47 

type RedisStreamsWriteArgs struct {
	// @gotags: kong:"help='What redis ID to use for input data (* = auto-generate)',default='*'"
	WriteId string `` /* 164-byte string literal not displayed */
	// @gotags: kong:"help='Streams to write to'"
	Streams []string `protobuf:"bytes,2,rep,name=streams,proto3" json:"streams,omitempty" kong:"help='Streams to write to'"`
	// @gotags: kong:"help='Key name to write input data to'"
	Key                  string   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty" kong:"help='Key name to write input data to'"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RedisStreamsWriteArgs) Descriptor added in v0.0.47 

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

func (*RedisStreamsWriteArgs) GetKey added in v0.0.47 

func (m *RedisStreamsWriteArgs) GetKey() string

func (*RedisStreamsWriteArgs) GetStreams added in v0.0.47 

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

func (*RedisStreamsWriteArgs) GetWriteId added in v0.0.47 

func (m *RedisStreamsWriteArgs) GetWriteId() string

func (*RedisStreamsWriteArgs) ProtoMessage added in v0.0.47 

func (*RedisStreamsWriteArgs) ProtoMessage()

func (*RedisStreamsWriteArgs) Reset added in v0.0.47 

func (m *RedisStreamsWriteArgs) Reset()

func (*RedisStreamsWriteArgs) String added in v0.0.47 

func (m *RedisStreamsWriteArgs) String() string

func (*RedisStreamsWriteArgs) XXX_DiscardUnknown added in v0.0.47 

func (m *RedisStreamsWriteArgs) XXX_DiscardUnknown()

func (*RedisStreamsWriteArgs) XXX_Marshal added in v0.0.47 

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

func (*RedisStreamsWriteArgs) XXX_Merge added in v0.0.47 

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

func (*RedisStreamsWriteArgs) XXX_Size added in v0.0.47 

func (m *RedisStreamsWriteArgs) XXX_Size() int

func (*RedisStreamsWriteArgs) XXX_Unmarshal added in v0.0.47 

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

type SASLType added in v0.0.69 

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

func (SASLType) EnumDescriptor added in v0.0.69 

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

func (SASLType) String added in v0.0.69 

func (x SASLType) String() string

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.