Documentation ¶
Index ¶
- Variables
- type AWSSNSConn
- func (*AWSSNSConn) Descriptor() ([]byte, []int)
- func (m *AWSSNSConn) GetAwsAccessKeyId() string
- func (m *AWSSNSConn) GetAwsRegion() string
- func (m *AWSSNSConn) GetAwsSecretAccessKey() string
- func (*AWSSNSConn) ProtoMessage()
- func (m *AWSSNSConn) Reset()
- func (m *AWSSNSConn) String() string
- func (m *AWSSNSConn) XXX_DiscardUnknown()
- func (m *AWSSNSConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AWSSNSConn) XXX_Merge(src proto.Message)
- func (m *AWSSNSConn) XXX_Size() int
- func (m *AWSSNSConn) XXX_Unmarshal(b []byte) error
- type AWSSNSWriteArgs
- func (*AWSSNSWriteArgs) Descriptor() ([]byte, []int)
- func (m *AWSSNSWriteArgs) GetTopic() string
- func (*AWSSNSWriteArgs) ProtoMessage()
- func (m *AWSSNSWriteArgs) Reset()
- func (m *AWSSNSWriteArgs) String() string
- func (m *AWSSNSWriteArgs) XXX_DiscardUnknown()
- func (m *AWSSNSWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AWSSNSWriteArgs) XXX_Merge(src proto.Message)
- func (m *AWSSNSWriteArgs) XXX_Size() int
- func (m *AWSSNSWriteArgs) XXX_Unmarshal(b []byte) error
- type AWSSQSConn
- func (*AWSSQSConn) Descriptor() ([]byte, []int)
- func (m *AWSSQSConn) GetAwsAccessKeyId() string
- func (m *AWSSQSConn) GetAwsRegion() string
- func (m *AWSSQSConn) GetAwsSecretAccessKey() string
- func (*AWSSQSConn) ProtoMessage()
- func (m *AWSSQSConn) Reset()
- func (m *AWSSQSConn) String() string
- func (m *AWSSQSConn) XXX_DiscardUnknown()
- func (m *AWSSQSConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AWSSQSConn) XXX_Merge(src proto.Message)
- func (m *AWSSQSConn) XXX_Size() int
- func (m *AWSSQSConn) XXX_Unmarshal(b []byte) error
- type AWSSQSReadArgs
- func (*AWSSQSReadArgs) Descriptor() ([]byte, []int)
- func (m *AWSSQSReadArgs) GetAutoDelete() bool
- func (m *AWSSQSReadArgs) GetMaxNumMessages() int64
- func (m *AWSSQSReadArgs) GetQueueName() string
- func (m *AWSSQSReadArgs) GetReceiveRequestAttemptId() string
- func (m *AWSSQSReadArgs) GetRemoteAccountId() string
- func (m *AWSSQSReadArgs) GetWaitTimeSeconds() int64
- func (*AWSSQSReadArgs) ProtoMessage()
- func (m *AWSSQSReadArgs) Reset()
- func (m *AWSSQSReadArgs) String() string
- func (m *AWSSQSReadArgs) XXX_DiscardUnknown()
- func (m *AWSSQSReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AWSSQSReadArgs) XXX_Merge(src proto.Message)
- func (m *AWSSQSReadArgs) XXX_Size() int
- func (m *AWSSQSReadArgs) XXX_Unmarshal(b []byte) error
- type AWSSQSRelayArgs
- func (*AWSSQSRelayArgs) Descriptor() ([]byte, []int)
- func (m *AWSSQSRelayArgs) GetAutoDelete() bool
- func (m *AWSSQSRelayArgs) GetMaxNumMessages() int64
- func (m *AWSSQSRelayArgs) GetQueueName() string
- func (m *AWSSQSRelayArgs) GetReceiveRequestAttemptId() string
- func (m *AWSSQSRelayArgs) GetRemoteAccountId() string
- func (m *AWSSQSRelayArgs) GetWaitTimeSeconds() int64
- func (*AWSSQSRelayArgs) ProtoMessage()
- func (m *AWSSQSRelayArgs) Reset()
- func (m *AWSSQSRelayArgs) String() string
- func (m *AWSSQSRelayArgs) XXX_DiscardUnknown()
- func (m *AWSSQSRelayArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AWSSQSRelayArgs) XXX_Merge(src proto.Message)
- func (m *AWSSQSRelayArgs) XXX_Size() int
- func (m *AWSSQSRelayArgs) XXX_Unmarshal(b []byte) error
- type AWSSQSWriteArgs
- func (*AWSSQSWriteArgs) Descriptor() ([]byte, []int)
- func (m *AWSSQSWriteArgs) GetAttributes() map[string]string
- func (m *AWSSQSWriteArgs) GetDelaySeconds() int64
- func (m *AWSSQSWriteArgs) GetMessageDeduplicationId() string
- func (m *AWSSQSWriteArgs) GetMessageGroupId() string
- func (m *AWSSQSWriteArgs) GetQueueName() string
- func (m *AWSSQSWriteArgs) GetRemoteAccountId() string
- func (*AWSSQSWriteArgs) ProtoMessage()
- func (m *AWSSQSWriteArgs) Reset()
- func (m *AWSSQSWriteArgs) String() string
- func (m *AWSSQSWriteArgs) XXX_DiscardUnknown()
- func (m *AWSSQSWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AWSSQSWriteArgs) XXX_Merge(src proto.Message)
- func (m *AWSSQSWriteArgs) XXX_Size() int
- func (m *AWSSQSWriteArgs) XXX_Unmarshal(b []byte) error
- type ActiveMQConn
- func (*ActiveMQConn) Descriptor() ([]byte, []int)
- func (m *ActiveMQConn) GetAddress() string
- func (*ActiveMQConn) ProtoMessage()
- func (m *ActiveMQConn) Reset()
- func (m *ActiveMQConn) String() string
- func (m *ActiveMQConn) XXX_DiscardUnknown()
- func (m *ActiveMQConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActiveMQConn) XXX_Merge(src proto.Message)
- func (m *ActiveMQConn) XXX_Size() int
- func (m *ActiveMQConn) XXX_Unmarshal(b []byte) error
- type ActiveMQReadArgs
- func (*ActiveMQReadArgs) Descriptor() ([]byte, []int)
- func (m *ActiveMQReadArgs) GetQueue() string
- func (m *ActiveMQReadArgs) GetTopic() string
- func (*ActiveMQReadArgs) ProtoMessage()
- func (m *ActiveMQReadArgs) Reset()
- func (m *ActiveMQReadArgs) String() string
- func (m *ActiveMQReadArgs) XXX_DiscardUnknown()
- func (m *ActiveMQReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActiveMQReadArgs) XXX_Merge(src proto.Message)
- func (m *ActiveMQReadArgs) XXX_Size() int
- func (m *ActiveMQReadArgs) XXX_Unmarshal(b []byte) error
- type ActiveMQWriteArgs
- func (*ActiveMQWriteArgs) Descriptor() ([]byte, []int)
- func (m *ActiveMQWriteArgs) GetQueue() string
- func (m *ActiveMQWriteArgs) GetTopic() string
- func (*ActiveMQWriteArgs) ProtoMessage()
- func (m *ActiveMQWriteArgs) Reset()
- func (m *ActiveMQWriteArgs) String() string
- func (m *ActiveMQWriteArgs) XXX_DiscardUnknown()
- func (m *ActiveMQWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActiveMQWriteArgs) XXX_Merge(src proto.Message)
- func (m *ActiveMQWriteArgs) XXX_Size() int
- func (m *ActiveMQWriteArgs) XXX_Unmarshal(b []byte) error
- type AzureEventHubConn
- func (*AzureEventHubConn) Descriptor() ([]byte, []int)
- func (m *AzureEventHubConn) GetConnectionString() string
- func (*AzureEventHubConn) ProtoMessage()
- func (m *AzureEventHubConn) Reset()
- func (m *AzureEventHubConn) String() string
- func (m *AzureEventHubConn) XXX_DiscardUnknown()
- func (m *AzureEventHubConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AzureEventHubConn) XXX_Merge(src proto.Message)
- func (m *AzureEventHubConn) XXX_Size() int
- func (m *AzureEventHubConn) XXX_Unmarshal(b []byte) error
- type AzureEventHubReadArgs
- func (*AzureEventHubReadArgs) Descriptor() ([]byte, []int)
- func (*AzureEventHubReadArgs) ProtoMessage()
- func (m *AzureEventHubReadArgs) Reset()
- func (m *AzureEventHubReadArgs) String() string
- func (m *AzureEventHubReadArgs) XXX_DiscardUnknown()
- func (m *AzureEventHubReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AzureEventHubReadArgs) XXX_Merge(src proto.Message)
- func (m *AzureEventHubReadArgs) XXX_Size() int
- func (m *AzureEventHubReadArgs) XXX_Unmarshal(b []byte) error
- type AzureEventHubWriteArgs
- func (*AzureEventHubWriteArgs) Descriptor() ([]byte, []int)
- func (m *AzureEventHubWriteArgs) GetMessageId() string
- func (m *AzureEventHubWriteArgs) GetPartitionKey() string
- func (*AzureEventHubWriteArgs) ProtoMessage()
- func (m *AzureEventHubWriteArgs) Reset()
- func (m *AzureEventHubWriteArgs) String() string
- func (m *AzureEventHubWriteArgs) XXX_DiscardUnknown()
- func (m *AzureEventHubWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AzureEventHubWriteArgs) XXX_Merge(src proto.Message)
- func (m *AzureEventHubWriteArgs) XXX_Size() int
- func (m *AzureEventHubWriteArgs) XXX_Unmarshal(b []byte) error
- type AzureServiceBusConn
- func (*AzureServiceBusConn) Descriptor() ([]byte, []int)
- func (m *AzureServiceBusConn) GetConnectionString() string
- func (*AzureServiceBusConn) ProtoMessage()
- func (m *AzureServiceBusConn) Reset()
- func (m *AzureServiceBusConn) String() string
- func (m *AzureServiceBusConn) XXX_DiscardUnknown()
- func (m *AzureServiceBusConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AzureServiceBusConn) XXX_Merge(src proto.Message)
- func (m *AzureServiceBusConn) XXX_Size() int
- func (m *AzureServiceBusConn) XXX_Unmarshal(b []byte) error
- type AzureServiceBusReadArgs
- func (*AzureServiceBusReadArgs) Descriptor() ([]byte, []int)
- func (m *AzureServiceBusReadArgs) GetQueue() string
- func (m *AzureServiceBusReadArgs) GetSubscriptionName() string
- func (m *AzureServiceBusReadArgs) GetTopic() string
- func (*AzureServiceBusReadArgs) ProtoMessage()
- func (m *AzureServiceBusReadArgs) Reset()
- func (m *AzureServiceBusReadArgs) String() string
- func (m *AzureServiceBusReadArgs) XXX_DiscardUnknown()
- func (m *AzureServiceBusReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AzureServiceBusReadArgs) XXX_Merge(src proto.Message)
- func (m *AzureServiceBusReadArgs) XXX_Size() int
- func (m *AzureServiceBusReadArgs) XXX_Unmarshal(b []byte) error
- type AzureServiceBusWriteArgs
- func (*AzureServiceBusWriteArgs) Descriptor() ([]byte, []int)
- func (m *AzureServiceBusWriteArgs) GetQueue() string
- func (m *AzureServiceBusWriteArgs) GetTopic() string
- func (*AzureServiceBusWriteArgs) ProtoMessage()
- func (m *AzureServiceBusWriteArgs) Reset()
- func (m *AzureServiceBusWriteArgs) String() string
- func (m *AzureServiceBusWriteArgs) XXX_DiscardUnknown()
- func (m *AzureServiceBusWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AzureServiceBusWriteArgs) XXX_Merge(src proto.Message)
- func (m *AzureServiceBusWriteArgs) XXX_Size() int
- func (m *AzureServiceBusWriteArgs) XXX_Unmarshal(b []byte) error
- type CreateConsumerConfig
- func (*CreateConsumerConfig) Descriptor() ([]byte, []int)
- func (m *CreateConsumerConfig) GetCreateStreams() bool
- func (m *CreateConsumerConfig) GetOffsetStart() OffsetStart
- func (m *CreateConsumerConfig) GetRecreateConsumerGroup() bool
- func (*CreateConsumerConfig) ProtoMessage()
- func (m *CreateConsumerConfig) Reset()
- func (m *CreateConsumerConfig) String() string
- func (m *CreateConsumerConfig) XXX_DiscardUnknown()
- func (m *CreateConsumerConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateConsumerConfig) XXX_Merge(src proto.Message)
- func (m *CreateConsumerConfig) XXX_Size() int
- func (m *CreateConsumerConfig) XXX_Unmarshal(b []byte) error
- type GCPPubSubConn
- func (*GCPPubSubConn) Descriptor() ([]byte, []int)
- func (m *GCPPubSubConn) GetCredentialsFile() string
- func (m *GCPPubSubConn) GetCredentialsJson() string
- func (m *GCPPubSubConn) GetProjectId() string
- func (*GCPPubSubConn) ProtoMessage()
- func (m *GCPPubSubConn) Reset()
- func (m *GCPPubSubConn) String() string
- func (m *GCPPubSubConn) XXX_DiscardUnknown()
- func (m *GCPPubSubConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GCPPubSubConn) XXX_Merge(src proto.Message)
- func (m *GCPPubSubConn) XXX_Size() int
- func (m *GCPPubSubConn) XXX_Unmarshal(b []byte) error
- type GCPPubSubReadArgs
- func (*GCPPubSubReadArgs) Descriptor() ([]byte, []int)
- func (m *GCPPubSubReadArgs) GetAckMessages() bool
- func (m *GCPPubSubReadArgs) GetSubscriptionId() string
- func (*GCPPubSubReadArgs) ProtoMessage()
- func (m *GCPPubSubReadArgs) Reset()
- func (m *GCPPubSubReadArgs) String() string
- func (m *GCPPubSubReadArgs) XXX_DiscardUnknown()
- func (m *GCPPubSubReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GCPPubSubReadArgs) XXX_Merge(src proto.Message)
- func (m *GCPPubSubReadArgs) XXX_Size() int
- func (m *GCPPubSubReadArgs) XXX_Unmarshal(b []byte) error
- type GCPPubSubWriteArgs
- func (*GCPPubSubWriteArgs) Descriptor() ([]byte, []int)
- func (m *GCPPubSubWriteArgs) GetTopicId() string
- func (*GCPPubSubWriteArgs) ProtoMessage()
- func (m *GCPPubSubWriteArgs) Reset()
- func (m *GCPPubSubWriteArgs) String() string
- func (m *GCPPubSubWriteArgs) XXX_DiscardUnknown()
- func (m *GCPPubSubWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GCPPubSubWriteArgs) XXX_Merge(src proto.Message)
- func (m *GCPPubSubWriteArgs) XXX_Size() int
- func (m *GCPPubSubWriteArgs) XXX_Unmarshal(b []byte) error
- type KafkaConn
- func (*KafkaConn) Descriptor() ([]byte, []int)
- func (m *KafkaConn) GetAddress() []string
- func (m *KafkaConn) GetInsecureTls() bool
- func (m *KafkaConn) GetSaslPassword() string
- func (m *KafkaConn) GetSaslType() SASLType
- func (m *KafkaConn) GetSaslUsername() string
- func (m *KafkaConn) GetTimeoutSeconds() int32
- func (m *KafkaConn) GetUseTls() bool
- func (*KafkaConn) ProtoMessage()
- func (m *KafkaConn) Reset()
- func (m *KafkaConn) String() string
- func (m *KafkaConn) XXX_DiscardUnknown()
- func (m *KafkaConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KafkaConn) XXX_Merge(src proto.Message)
- func (m *KafkaConn) XXX_Size() int
- func (m *KafkaConn) XXX_Unmarshal(b []byte) error
- type KafkaReadArgs
- func (*KafkaReadArgs) Descriptor() ([]byte, []int)
- func (m *KafkaReadArgs) GetCommitIntervalSeconds() int32
- func (m *KafkaReadArgs) GetConsumerGroupName() string
- func (m *KafkaReadArgs) GetIncludeOffsetInfo() bool
- func (m *KafkaReadArgs) GetLag() bool
- func (m *KafkaReadArgs) GetLagConsumerGroup() string
- func (m *KafkaReadArgs) GetMaxBytes() int32
- func (m *KafkaReadArgs) GetMaxWaitSeconds() int32
- func (m *KafkaReadArgs) GetMinBytes() int32
- func (m *KafkaReadArgs) GetQueueCapacity() int32
- func (m *KafkaReadArgs) GetReadOffset() int64
- func (m *KafkaReadArgs) GetRebalanceTimeoutSeconds() int32
- func (m *KafkaReadArgs) GetTopics() []string
- func (m *KafkaReadArgs) GetUseConsumerGroup() bool
- func (*KafkaReadArgs) ProtoMessage()
- func (m *KafkaReadArgs) Reset()
- func (m *KafkaReadArgs) String() string
- func (m *KafkaReadArgs) XXX_DiscardUnknown()
- func (m *KafkaReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KafkaReadArgs) XXX_Merge(src proto.Message)
- func (m *KafkaReadArgs) XXX_Size() int
- func (m *KafkaReadArgs) XXX_Unmarshal(b []byte) error
- type KafkaRelayArgs
- func (*KafkaRelayArgs) Descriptor() ([]byte, []int)
- func (m *KafkaRelayArgs) GetCommitIntervalSeconds() int32
- func (m *KafkaRelayArgs) GetConsumerGroupName() string
- func (m *KafkaRelayArgs) GetMaxBytes() int32
- func (m *KafkaRelayArgs) GetMaxWaitSeconds() int32
- func (m *KafkaRelayArgs) GetMinBytes() int32
- func (m *KafkaRelayArgs) GetQueueCapacity() int32
- func (m *KafkaRelayArgs) GetReadOffset() int64
- func (m *KafkaRelayArgs) GetRebalanceTimeoutSeconds() int32
- func (m *KafkaRelayArgs) GetTopics() []string
- func (m *KafkaRelayArgs) GetUseConsumerGroup() bool
- func (*KafkaRelayArgs) ProtoMessage()
- func (m *KafkaRelayArgs) Reset()
- func (m *KafkaRelayArgs) String() string
- func (m *KafkaRelayArgs) XXX_DiscardUnknown()
- func (m *KafkaRelayArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KafkaRelayArgs) XXX_Merge(src proto.Message)
- func (m *KafkaRelayArgs) XXX_Size() int
- func (m *KafkaRelayArgs) XXX_Unmarshal(b []byte) error
- type KafkaWriteArgs
- func (*KafkaWriteArgs) Descriptor() ([]byte, []int)
- func (m *KafkaWriteArgs) GetHeaders() map[string]string
- func (m *KafkaWriteArgs) GetKey() string
- func (m *KafkaWriteArgs) GetTopics() []string
- func (*KafkaWriteArgs) ProtoMessage()
- func (m *KafkaWriteArgs) Reset()
- func (m *KafkaWriteArgs) String() string
- func (m *KafkaWriteArgs) XXX_DiscardUnknown()
- func (m *KafkaWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KafkaWriteArgs) XXX_Merge(src proto.Message)
- func (m *KafkaWriteArgs) XXX_Size() int
- func (m *KafkaWriteArgs) XXX_Unmarshal(b []byte) error
- type KubeMQQueueConn
- func (*KubeMQQueueConn) Descriptor() ([]byte, []int)
- func (m *KubeMQQueueConn) GetAddress() string
- func (m *KubeMQQueueConn) GetAuthToken() string
- func (m *KubeMQQueueConn) GetClientId() string
- func (m *KubeMQQueueConn) GetTlsCertFile() string
- func (*KubeMQQueueConn) ProtoMessage()
- func (m *KubeMQQueueConn) Reset()
- func (m *KubeMQQueueConn) String() string
- func (m *KubeMQQueueConn) XXX_DiscardUnknown()
- func (m *KubeMQQueueConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KubeMQQueueConn) XXX_Merge(src proto.Message)
- func (m *KubeMQQueueConn) XXX_Size() int
- func (m *KubeMQQueueConn) XXX_Unmarshal(b []byte) error
- type KubeMQQueueReadArgs
- func (*KubeMQQueueReadArgs) Descriptor() ([]byte, []int)
- func (m *KubeMQQueueReadArgs) GetQueueName() string
- func (*KubeMQQueueReadArgs) ProtoMessage()
- func (m *KubeMQQueueReadArgs) Reset()
- func (m *KubeMQQueueReadArgs) String() string
- func (m *KubeMQQueueReadArgs) XXX_DiscardUnknown()
- func (m *KubeMQQueueReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KubeMQQueueReadArgs) XXX_Merge(src proto.Message)
- func (m *KubeMQQueueReadArgs) XXX_Size() int
- func (m *KubeMQQueueReadArgs) XXX_Unmarshal(b []byte) error
- type KubeMQQueueWriteArgs
- func (*KubeMQQueueWriteArgs) Descriptor() ([]byte, []int)
- func (m *KubeMQQueueWriteArgs) GetQueueName() string
- func (*KubeMQQueueWriteArgs) ProtoMessage()
- func (m *KubeMQQueueWriteArgs) Reset()
- func (m *KubeMQQueueWriteArgs) String() string
- func (m *KubeMQQueueWriteArgs) XXX_DiscardUnknown()
- func (m *KubeMQQueueWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KubeMQQueueWriteArgs) XXX_Merge(src proto.Message)
- func (m *KubeMQQueueWriteArgs) XXX_Size() int
- func (m *KubeMQQueueWriteArgs) XXX_Unmarshal(b []byte) error
- type MQTTConn
- func (*MQTTConn) Descriptor() ([]byte, []int)
- func (m *MQTTConn) GetAddress() string
- func (m *MQTTConn) GetClientId() string
- func (m *MQTTConn) GetConnTimeoutSeconds() uint32
- func (m *MQTTConn) GetQosLevel() MQTTQoSLevel
- func (m *MQTTConn) GetTlsOptions() *MQTTTLSOptions
- func (*MQTTConn) ProtoMessage()
- func (m *MQTTConn) Reset()
- func (m *MQTTConn) String() string
- func (m *MQTTConn) XXX_DiscardUnknown()
- func (m *MQTTConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MQTTConn) XXX_Merge(src proto.Message)
- func (m *MQTTConn) XXX_Size() int
- func (m *MQTTConn) XXX_Unmarshal(b []byte) error
- type MQTTQoSLevel
- type MQTTReadArgs
- func (*MQTTReadArgs) Descriptor() ([]byte, []int)
- func (m *MQTTReadArgs) GetReadTimeoutSeconds() uint32
- func (m *MQTTReadArgs) GetTopic() string
- func (*MQTTReadArgs) ProtoMessage()
- func (m *MQTTReadArgs) Reset()
- func (m *MQTTReadArgs) String() string
- func (m *MQTTReadArgs) XXX_DiscardUnknown()
- func (m *MQTTReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MQTTReadArgs) XXX_Merge(src proto.Message)
- func (m *MQTTReadArgs) XXX_Size() int
- func (m *MQTTReadArgs) XXX_Unmarshal(b []byte) error
- type MQTTTLSOptions
- func (*MQTTTLSOptions) Descriptor() ([]byte, []int)
- func (m *MQTTTLSOptions) GetCaFile() string
- func (m *MQTTTLSOptions) GetCertFile() string
- func (m *MQTTTLSOptions) GetKeyFile() string
- func (m *MQTTTLSOptions) GetSkipVerify() bool
- func (*MQTTTLSOptions) ProtoMessage()
- func (m *MQTTTLSOptions) Reset()
- func (m *MQTTTLSOptions) String() string
- func (m *MQTTTLSOptions) XXX_DiscardUnknown()
- func (m *MQTTTLSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MQTTTLSOptions) XXX_Merge(src proto.Message)
- func (m *MQTTTLSOptions) XXX_Size() int
- func (m *MQTTTLSOptions) XXX_Unmarshal(b []byte) error
- type MQTTWriteArgs
- func (*MQTTWriteArgs) Descriptor() ([]byte, []int)
- func (m *MQTTWriteArgs) GetTopic() string
- func (m *MQTTWriteArgs) GetWriteTimeoutSeconds() uint32
- func (*MQTTWriteArgs) ProtoMessage()
- func (m *MQTTWriteArgs) Reset()
- func (m *MQTTWriteArgs) String() string
- func (m *MQTTWriteArgs) XXX_DiscardUnknown()
- func (m *MQTTWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MQTTWriteArgs) XXX_Merge(src proto.Message)
- func (m *MQTTWriteArgs) XXX_Size() int
- func (m *MQTTWriteArgs) XXX_Unmarshal(b []byte) error
- type MongoConn
- func (*MongoConn) Descriptor() ([]byte, []int)
- func (m *MongoConn) GetDsn() string
- func (*MongoConn) ProtoMessage()
- func (m *MongoConn) Reset()
- func (m *MongoConn) String() string
- func (m *MongoConn) XXX_DiscardUnknown()
- func (m *MongoConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MongoConn) XXX_Merge(src proto.Message)
- func (m *MongoConn) XXX_Size() int
- func (m *MongoConn) XXX_Unmarshal(b []byte) error
- type MongoReadArgs
- func (*MongoReadArgs) Descriptor() ([]byte, []int)
- func (m *MongoReadArgs) GetCollection() string
- func (m *MongoReadArgs) GetDatabase() string
- func (m *MongoReadArgs) GetIncludeFullDocument() bool
- func (*MongoReadArgs) ProtoMessage()
- func (m *MongoReadArgs) Reset()
- func (m *MongoReadArgs) String() string
- func (m *MongoReadArgs) XXX_DiscardUnknown()
- func (m *MongoReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MongoReadArgs) XXX_Merge(src proto.Message)
- func (m *MongoReadArgs) XXX_Size() int
- func (m *MongoReadArgs) XXX_Unmarshal(b []byte) error
- type NSQConn
- func (*NSQConn) Descriptor() ([]byte, []int)
- func (m *NSQConn) GetAuthSecret() string
- func (m *NSQConn) GetClientId() string
- func (m *NSQConn) GetInsecureTls() bool
- func (m *NSQConn) GetLookupdAddress() string
- func (m *NSQConn) GetNsqdAddress() string
- func (m *NSQConn) GetTlsCaCert() []byte
- func (m *NSQConn) GetTlsClientCert() []byte
- func (m *NSQConn) GetTlsClientKey() []byte
- func (m *NSQConn) GetUseTls() bool
- func (*NSQConn) ProtoMessage()
- func (m *NSQConn) Reset()
- func (m *NSQConn) String() string
- func (m *NSQConn) XXX_DiscardUnknown()
- func (m *NSQConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NSQConn) XXX_Merge(src proto.Message)
- func (m *NSQConn) XXX_Size() int
- func (m *NSQConn) XXX_Unmarshal(b []byte) error
- type NSQReadArgs
- func (*NSQReadArgs) Descriptor() ([]byte, []int)
- func (m *NSQReadArgs) GetChannel() string
- func (m *NSQReadArgs) GetTopic() string
- func (*NSQReadArgs) ProtoMessage()
- func (m *NSQReadArgs) Reset()
- func (m *NSQReadArgs) String() string
- func (m *NSQReadArgs) XXX_DiscardUnknown()
- func (m *NSQReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NSQReadArgs) XXX_Merge(src proto.Message)
- func (m *NSQReadArgs) XXX_Size() int
- func (m *NSQReadArgs) XXX_Unmarshal(b []byte) error
- type NSQWriteArgs
- func (*NSQWriteArgs) Descriptor() ([]byte, []int)
- func (m *NSQWriteArgs) GetTopic() string
- func (*NSQWriteArgs) ProtoMessage()
- func (m *NSQWriteArgs) Reset()
- func (m *NSQWriteArgs) String() string
- func (m *NSQWriteArgs) XXX_DiscardUnknown()
- func (m *NSQWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NSQWriteArgs) XXX_Merge(src proto.Message)
- func (m *NSQWriteArgs) XXX_Size() int
- func (m *NSQWriteArgs) XXX_Unmarshal(b []byte) error
- type NatsConn
- func (*NatsConn) Descriptor() ([]byte, []int)
- func (m *NatsConn) GetDsn() string
- func (m *NatsConn) GetInsecureTls() bool
- func (m *NatsConn) GetTlsCaCert() []byte
- func (m *NatsConn) GetTlsClientCert() []byte
- func (m *NatsConn) GetTlsClientKey() []byte
- func (m *NatsConn) GetUserCredentials() []byte
- func (*NatsConn) ProtoMessage()
- func (m *NatsConn) Reset()
- func (m *NatsConn) String() string
- func (m *NatsConn) XXX_DiscardUnknown()
- func (m *NatsConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsConn) XXX_Merge(src proto.Message)
- func (m *NatsConn) XXX_Size() int
- func (m *NatsConn) XXX_Unmarshal(b []byte) error
- type NatsReadArgs
- func (*NatsReadArgs) Descriptor() ([]byte, []int)
- func (m *NatsReadArgs) GetSubject() string
- func (*NatsReadArgs) ProtoMessage()
- func (m *NatsReadArgs) Reset()
- func (m *NatsReadArgs) String() string
- func (m *NatsReadArgs) XXX_DiscardUnknown()
- func (m *NatsReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsReadArgs) XXX_Merge(src proto.Message)
- func (m *NatsReadArgs) XXX_Size() int
- func (m *NatsReadArgs) XXX_Unmarshal(b []byte) error
- type NatsStreamingConn
- func (*NatsStreamingConn) Descriptor() ([]byte, []int)
- func (m *NatsStreamingConn) GetClientId() string
- func (m *NatsStreamingConn) GetClusterId() string
- func (m *NatsStreamingConn) GetDsn() string
- func (m *NatsStreamingConn) GetInsecureTls() bool
- func (m *NatsStreamingConn) GetTlsCaCert() []byte
- func (m *NatsStreamingConn) GetTlsClientCert() []byte
- func (m *NatsStreamingConn) GetTlsClientKey() []byte
- func (m *NatsStreamingConn) GetUserCredentials() []byte
- func (*NatsStreamingConn) ProtoMessage()
- func (m *NatsStreamingConn) Reset()
- func (m *NatsStreamingConn) String() string
- func (m *NatsStreamingConn) XXX_DiscardUnknown()
- func (m *NatsStreamingConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsStreamingConn) XXX_Merge(src proto.Message)
- func (m *NatsStreamingConn) XXX_Size() int
- func (m *NatsStreamingConn) XXX_Unmarshal(b []byte) error
- type NatsStreamingReadArgs
- func (*NatsStreamingReadArgs) Descriptor() ([]byte, []int)
- func (m *NatsStreamingReadArgs) GetChannel() string
- func (m *NatsStreamingReadArgs) GetDurableName() string
- func (m *NatsStreamingReadArgs) GetReadAll() bool
- func (m *NatsStreamingReadArgs) GetReadLastAvailable() bool
- func (m *NatsStreamingReadArgs) GetReadSequenceNumber() uint32
- func (m *NatsStreamingReadArgs) GetReadSince() string
- func (*NatsStreamingReadArgs) ProtoMessage()
- func (m *NatsStreamingReadArgs) Reset()
- func (m *NatsStreamingReadArgs) String() string
- func (m *NatsStreamingReadArgs) XXX_DiscardUnknown()
- func (m *NatsStreamingReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsStreamingReadArgs) XXX_Merge(src proto.Message)
- func (m *NatsStreamingReadArgs) XXX_Size() int
- func (m *NatsStreamingReadArgs) XXX_Unmarshal(b []byte) error
- type NatsStreamingWriteArgs
- func (*NatsStreamingWriteArgs) Descriptor() ([]byte, []int)
- func (m *NatsStreamingWriteArgs) GetChannel() string
- func (*NatsStreamingWriteArgs) ProtoMessage()
- func (m *NatsStreamingWriteArgs) Reset()
- func (m *NatsStreamingWriteArgs) String() string
- func (m *NatsStreamingWriteArgs) XXX_DiscardUnknown()
- func (m *NatsStreamingWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsStreamingWriteArgs) XXX_Merge(src proto.Message)
- func (m *NatsStreamingWriteArgs) XXX_Size() int
- func (m *NatsStreamingWriteArgs) XXX_Unmarshal(b []byte) error
- type NatsWriteArgs
- func (*NatsWriteArgs) Descriptor() ([]byte, []int)
- func (m *NatsWriteArgs) GetSubject() string
- func (*NatsWriteArgs) ProtoMessage()
- func (m *NatsWriteArgs) Reset()
- func (m *NatsWriteArgs) String() string
- func (m *NatsWriteArgs) XXX_DiscardUnknown()
- func (m *NatsWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsWriteArgs) XXX_Merge(src proto.Message)
- func (m *NatsWriteArgs) XXX_Size() int
- func (m *NatsWriteArgs) XXX_Unmarshal(b []byte) error
- type OffsetStart
- type PostgresConn
- func (*PostgresConn) Descriptor() ([]byte, []int)
- func (m *PostgresConn) GetAddress() string
- func (m *PostgresConn) GetDatabase() string
- func (m *PostgresConn) GetInsecureTls() bool
- func (m *PostgresConn) GetPassword() string
- func (m *PostgresConn) GetPort() uint32
- func (m *PostgresConn) GetUseTls() bool
- func (m *PostgresConn) GetUsername() string
- func (*PostgresConn) ProtoMessage()
- func (m *PostgresConn) Reset()
- func (m *PostgresConn) String() string
- func (m *PostgresConn) XXX_DiscardUnknown()
- func (m *PostgresConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PostgresConn) XXX_Merge(src proto.Message)
- func (m *PostgresConn) XXX_Size() int
- func (m *PostgresConn) XXX_Unmarshal(b []byte) error
- type PostgresReadArgs
- func (*PostgresReadArgs) Descriptor() ([]byte, []int)
- func (m *PostgresReadArgs) GetPublisherName() string
- func (m *PostgresReadArgs) GetReplicationSlotName() string
- func (*PostgresReadArgs) ProtoMessage()
- func (m *PostgresReadArgs) Reset()
- func (m *PostgresReadArgs) String() string
- func (m *PostgresReadArgs) XXX_DiscardUnknown()
- func (m *PostgresReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PostgresReadArgs) XXX_Merge(src proto.Message)
- func (m *PostgresReadArgs) XXX_Size() int
- func (m *PostgresReadArgs) XXX_Unmarshal(b []byte) error
- type PulsarConn
- func (*PulsarConn) Descriptor() ([]byte, []int)
- func (m *PulsarConn) GetConnectTimeoutSeconds() uint32
- func (m *PulsarConn) GetDsn() string
- func (m *PulsarConn) GetInsecureTls() bool
- func (m *PulsarConn) GetTlsClientCert() []byte
- func (m *PulsarConn) GetTlsClientKey() []byte
- func (*PulsarConn) ProtoMessage()
- func (m *PulsarConn) Reset()
- func (m *PulsarConn) String() string
- func (m *PulsarConn) XXX_DiscardUnknown()
- func (m *PulsarConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PulsarConn) XXX_Merge(src proto.Message)
- func (m *PulsarConn) XXX_Size() int
- func (m *PulsarConn) XXX_Unmarshal(b []byte) error
- type PulsarReadArgs
- func (*PulsarReadArgs) Descriptor() ([]byte, []int)
- func (m *PulsarReadArgs) GetSubscriptionName() string
- func (m *PulsarReadArgs) GetSubscriptionType() SubscriptionType
- func (m *PulsarReadArgs) GetTopic() string
- func (*PulsarReadArgs) ProtoMessage()
- func (m *PulsarReadArgs) Reset()
- func (m *PulsarReadArgs) String() string
- func (m *PulsarReadArgs) XXX_DiscardUnknown()
- func (m *PulsarReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PulsarReadArgs) XXX_Merge(src proto.Message)
- func (m *PulsarReadArgs) XXX_Size() int
- func (m *PulsarReadArgs) XXX_Unmarshal(b []byte) error
- type PulsarWriteArgs
- func (*PulsarWriteArgs) Descriptor() ([]byte, []int)
- func (m *PulsarWriteArgs) GetTopic() string
- func (*PulsarWriteArgs) ProtoMessage()
- func (m *PulsarWriteArgs) Reset()
- func (m *PulsarWriteArgs) String() string
- func (m *PulsarWriteArgs) XXX_DiscardUnknown()
- func (m *PulsarWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PulsarWriteArgs) XXX_Merge(src proto.Message)
- func (m *PulsarWriteArgs) XXX_Size() int
- func (m *PulsarWriteArgs) XXX_Unmarshal(b []byte) error
- type RabbitConn
- func (*RabbitConn) Descriptor() ([]byte, []int)
- func (m *RabbitConn) GetAddress() string
- func (m *RabbitConn) GetInsecureTls() bool
- func (m *RabbitConn) GetUseTls() bool
- func (*RabbitConn) ProtoMessage()
- func (m *RabbitConn) Reset()
- func (m *RabbitConn) String() string
- func (m *RabbitConn) XXX_DiscardUnknown()
- func (m *RabbitConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RabbitConn) XXX_Merge(src proto.Message)
- func (m *RabbitConn) XXX_Size() int
- func (m *RabbitConn) XXX_Unmarshal(b []byte) error
- type RabbitReadArgs
- func (*RabbitReadArgs) Descriptor() ([]byte, []int)
- func (m *RabbitReadArgs) GetAutoAck() bool
- func (m *RabbitReadArgs) GetBindingKey() string
- func (m *RabbitReadArgs) GetConsumerTag() string
- func (m *RabbitReadArgs) GetExchangeName() string
- func (m *RabbitReadArgs) GetQueueDeclare() bool
- func (m *RabbitReadArgs) GetQueueDelete() bool
- func (m *RabbitReadArgs) GetQueueDurable() bool
- func (m *RabbitReadArgs) GetQueueExclusive() bool
- func (m *RabbitReadArgs) GetQueueName() string
- func (*RabbitReadArgs) ProtoMessage()
- func (m *RabbitReadArgs) Reset()
- func (m *RabbitReadArgs) String() string
- func (m *RabbitReadArgs) XXX_DiscardUnknown()
- func (m *RabbitReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RabbitReadArgs) XXX_Merge(src proto.Message)
- func (m *RabbitReadArgs) XXX_Size() int
- func (m *RabbitReadArgs) XXX_Unmarshal(b []byte) error
- type RabbitStreamsConn
- func (*RabbitStreamsConn) Descriptor() ([]byte, []int)
- func (m *RabbitStreamsConn) GetClientName() string
- func (m *RabbitStreamsConn) GetDsn() string
- func (m *RabbitStreamsConn) GetInsecureTls() bool
- func (m *RabbitStreamsConn) GetPassword() string
- func (m *RabbitStreamsConn) GetUseTls() bool
- func (m *RabbitStreamsConn) GetUsername() string
- func (*RabbitStreamsConn) ProtoMessage()
- func (m *RabbitStreamsConn) Reset()
- func (m *RabbitStreamsConn) String() string
- func (m *RabbitStreamsConn) XXX_DiscardUnknown()
- func (m *RabbitStreamsConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RabbitStreamsConn) XXX_Merge(src proto.Message)
- func (m *RabbitStreamsConn) XXX_Size() int
- func (m *RabbitStreamsConn) XXX_Unmarshal(b []byte) error
- type RabbitStreamsOffsetOptions
- func (*RabbitStreamsOffsetOptions) Descriptor() ([]byte, []int)
- func (m *RabbitStreamsOffsetOptions) GetFirstOffset() bool
- func (m *RabbitStreamsOffsetOptions) GetLastConsumed() bool
- func (m *RabbitStreamsOffsetOptions) GetLastOffset() bool
- func (m *RabbitStreamsOffsetOptions) GetNextOffset() bool
- func (m *RabbitStreamsOffsetOptions) GetSpecificOffset() int64
- func (*RabbitStreamsOffsetOptions) ProtoMessage()
- func (m *RabbitStreamsOffsetOptions) Reset()
- func (m *RabbitStreamsOffsetOptions) String() string
- func (m *RabbitStreamsOffsetOptions) XXX_DiscardUnknown()
- func (m *RabbitStreamsOffsetOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RabbitStreamsOffsetOptions) XXX_Merge(src proto.Message)
- func (m *RabbitStreamsOffsetOptions) XXX_Size() int
- func (m *RabbitStreamsOffsetOptions) XXX_Unmarshal(b []byte) error
- type RabbitStreamsReadArgs
- func (*RabbitStreamsReadArgs) Descriptor() ([]byte, []int)
- func (m *RabbitStreamsReadArgs) GetDeclareStream() bool
- func (m *RabbitStreamsReadArgs) GetDeclareStreamSize() string
- func (m *RabbitStreamsReadArgs) GetOffsetOptions() *RabbitStreamsOffsetOptions
- func (m *RabbitStreamsReadArgs) GetStream() string
- func (*RabbitStreamsReadArgs) ProtoMessage()
- func (m *RabbitStreamsReadArgs) Reset()
- func (m *RabbitStreamsReadArgs) String() string
- func (m *RabbitStreamsReadArgs) XXX_DiscardUnknown()
- func (m *RabbitStreamsReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RabbitStreamsReadArgs) XXX_Merge(src proto.Message)
- func (m *RabbitStreamsReadArgs) XXX_Size() int
- func (m *RabbitStreamsReadArgs) XXX_Unmarshal(b []byte) error
- type RabbitStreamsWriteArgs
- func (*RabbitStreamsWriteArgs) Descriptor() ([]byte, []int)
- func (m *RabbitStreamsWriteArgs) GetDeclareStream() bool
- func (m *RabbitStreamsWriteArgs) GetDeclareStreamSize() string
- func (m *RabbitStreamsWriteArgs) GetStream() string
- func (*RabbitStreamsWriteArgs) ProtoMessage()
- func (m *RabbitStreamsWriteArgs) Reset()
- func (m *RabbitStreamsWriteArgs) String() string
- func (m *RabbitStreamsWriteArgs) XXX_DiscardUnknown()
- func (m *RabbitStreamsWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RabbitStreamsWriteArgs) XXX_Merge(src proto.Message)
- func (m *RabbitStreamsWriteArgs) XXX_Size() int
- func (m *RabbitStreamsWriteArgs) XXX_Unmarshal(b []byte) error
- type RabbitWriteArgs
- func (*RabbitWriteArgs) Descriptor() ([]byte, []int)
- func (m *RabbitWriteArgs) GetAppId() string
- func (m *RabbitWriteArgs) GetExchangeAutoDelete() bool
- func (m *RabbitWriteArgs) GetExchangeDeclare() bool
- func (m *RabbitWriteArgs) GetExchangeDurable() bool
- func (m *RabbitWriteArgs) GetExchangeName() string
- func (m *RabbitWriteArgs) GetExchangeType() string
- func (m *RabbitWriteArgs) GetRoutingKey() string
- func (*RabbitWriteArgs) ProtoMessage()
- func (m *RabbitWriteArgs) Reset()
- func (m *RabbitWriteArgs) String() string
- func (m *RabbitWriteArgs) XXX_DiscardUnknown()
- func (m *RabbitWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RabbitWriteArgs) XXX_Merge(src proto.Message)
- func (m *RabbitWriteArgs) XXX_Size() int
- func (m *RabbitWriteArgs) XXX_Unmarshal(b []byte) error
- type RedisPubSubConn
- func (*RedisPubSubConn) Descriptor() ([]byte, []int)
- func (m *RedisPubSubConn) GetAddress() string
- func (m *RedisPubSubConn) GetDatabase() uint32
- func (m *RedisPubSubConn) GetPassword() string
- func (m *RedisPubSubConn) GetUsername() string
- func (*RedisPubSubConn) ProtoMessage()
- func (m *RedisPubSubConn) Reset()
- func (m *RedisPubSubConn) String() string
- func (m *RedisPubSubConn) XXX_DiscardUnknown()
- func (m *RedisPubSubConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RedisPubSubConn) XXX_Merge(src proto.Message)
- func (m *RedisPubSubConn) XXX_Size() int
- func (m *RedisPubSubConn) XXX_Unmarshal(b []byte) error
- type RedisPubSubReadArgs
- func (*RedisPubSubReadArgs) Descriptor() ([]byte, []int)
- func (m *RedisPubSubReadArgs) GetChannel() []string
- func (*RedisPubSubReadArgs) ProtoMessage()
- func (m *RedisPubSubReadArgs) Reset()
- func (m *RedisPubSubReadArgs) String() string
- func (m *RedisPubSubReadArgs) XXX_DiscardUnknown()
- func (m *RedisPubSubReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RedisPubSubReadArgs) XXX_Merge(src proto.Message)
- func (m *RedisPubSubReadArgs) XXX_Size() int
- func (m *RedisPubSubReadArgs) XXX_Unmarshal(b []byte) error
- type RedisPubSubWriteArgs
- func (*RedisPubSubWriteArgs) Descriptor() ([]byte, []int)
- func (m *RedisPubSubWriteArgs) GetChannel() []string
- func (*RedisPubSubWriteArgs) ProtoMessage()
- func (m *RedisPubSubWriteArgs) Reset()
- func (m *RedisPubSubWriteArgs) String() string
- func (m *RedisPubSubWriteArgs) XXX_DiscardUnknown()
- func (m *RedisPubSubWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RedisPubSubWriteArgs) XXX_Merge(src proto.Message)
- func (m *RedisPubSubWriteArgs) XXX_Size() int
- func (m *RedisPubSubWriteArgs) XXX_Unmarshal(b []byte) error
- type RedisStreamsConn
- func (*RedisStreamsConn) Descriptor() ([]byte, []int)
- func (m *RedisStreamsConn) GetAddress() string
- func (m *RedisStreamsConn) GetDatabase() uint32
- func (m *RedisStreamsConn) GetPassword() string
- func (m *RedisStreamsConn) GetUsername() string
- func (*RedisStreamsConn) ProtoMessage()
- func (m *RedisStreamsConn) Reset()
- func (m *RedisStreamsConn) String() string
- func (m *RedisStreamsConn) XXX_DiscardUnknown()
- func (m *RedisStreamsConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RedisStreamsConn) XXX_Merge(src proto.Message)
- func (m *RedisStreamsConn) XXX_Size() int
- func (m *RedisStreamsConn) XXX_Unmarshal(b []byte) error
- type RedisStreamsReadArgs
- func (*RedisStreamsReadArgs) Descriptor() ([]byte, []int)
- func (m *RedisStreamsReadArgs) GetConsumerGroup() string
- func (m *RedisStreamsReadArgs) GetConsumerName() string
- func (m *RedisStreamsReadArgs) GetCount() uint32
- func (m *RedisStreamsReadArgs) GetCreateConsumerConfig() *CreateConsumerConfig
- func (m *RedisStreamsReadArgs) GetStream() []string
- func (*RedisStreamsReadArgs) ProtoMessage()
- func (m *RedisStreamsReadArgs) Reset()
- func (m *RedisStreamsReadArgs) String() string
- func (m *RedisStreamsReadArgs) XXX_DiscardUnknown()
- func (m *RedisStreamsReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RedisStreamsReadArgs) XXX_Merge(src proto.Message)
- func (m *RedisStreamsReadArgs) XXX_Size() int
- func (m *RedisStreamsReadArgs) XXX_Unmarshal(b []byte) error
- type RedisStreamsWriteArgs
- func (*RedisStreamsWriteArgs) Descriptor() ([]byte, []int)
- func (m *RedisStreamsWriteArgs) GetKey() string
- func (m *RedisStreamsWriteArgs) GetStreams() []string
- func (m *RedisStreamsWriteArgs) GetWriteId() string
- func (*RedisStreamsWriteArgs) ProtoMessage()
- func (m *RedisStreamsWriteArgs) Reset()
- func (m *RedisStreamsWriteArgs) String() string
- func (m *RedisStreamsWriteArgs) XXX_DiscardUnknown()
- func (m *RedisStreamsWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RedisStreamsWriteArgs) XXX_Merge(src proto.Message)
- func (m *RedisStreamsWriteArgs) XXX_Size() int
- func (m *RedisStreamsWriteArgs) XXX_Unmarshal(b []byte) error
- type SASLType
- type SubscriptionType
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 */ // @gotags: kong:"help='GCP Credentials in JSON format',env='PLUMBER_RELAY_GCP_CREDENTIALS'" CredentialsJson string `` /* 187-byte string literal not displayed */ // @gotags: kong:"help='Path to GCP credentials JSON file',env='GOOGLE_APPLICATION_CREDENTIALS'" CredentialsFile string `` /* 191-byte string literal not displayed */ 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) GetCredentialsFile ¶ added in v0.0.97
func (m *GCPPubSubConn) GetCredentialsFile() string
func (*GCPPubSubConn) GetCredentialsJson ¶ added in v0.0.97
func (m *GCPPubSubConn) GetCredentialsJson() string
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) GetAddress ¶ added in v0.0.46
func (*KafkaConn) GetInsecureTls ¶ added in v0.0.46
func (*KafkaConn) GetSaslPassword ¶ added in v0.0.46
func (*KafkaConn) GetSaslType ¶ added in v0.0.46
func (*KafkaConn) GetSaslUsername ¶ added in v0.0.46
func (*KafkaConn) GetTimeoutSeconds ¶ added in v0.0.46
func (*KafkaConn) ProtoMessage ¶ added in v0.0.46
func (*KafkaConn) ProtoMessage()
func (*KafkaConn) XXX_DiscardUnknown ¶ added in v0.0.46
func (m *KafkaConn) XXX_DiscardUnknown()
func (*KafkaConn) XXX_Marshal ¶ added in v0.0.46
func (*KafkaConn) XXX_Unmarshal ¶ added in v0.0.46
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 */ // @gotags: kong:"help='KubeMQ client ID',env='PLUMBER_RELAY_KUBEMQ_QUEUE_CLIENT_ID',default=plumber" ClientId string `` /* 175-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) GetClientId ¶ added in v0.0.101
func (m *KubeMQQueueConn) GetClientId() 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 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) 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 queue name'" QueueName string `protobuf:"bytes,1,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) 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) GetAddress ¶ added in v0.0.46
func (*MQTTConn) GetClientId ¶ added in v0.0.46
func (*MQTTConn) GetConnTimeoutSeconds ¶ added in v0.0.46
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) XXX_DiscardUnknown ¶ added in v0.0.46
func (m *MQTTConn) XXX_DiscardUnknown()
func (*MQTTConn) XXX_Marshal ¶ added in v0.0.46
func (*MQTTConn) XXX_Unmarshal ¶ added in v0.0.46
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) ProtoMessage ¶ added in v0.0.46
func (*MongoConn) ProtoMessage()
func (*MongoConn) XXX_DiscardUnknown ¶ added in v0.0.46
func (m *MongoConn) XXX_DiscardUnknown()
func (*MongoConn) XXX_Marshal ¶ added in v0.0.46
func (*MongoConn) XXX_Unmarshal ¶ added in v0.0.46
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) GetAuthSecret ¶ added in v0.0.46
func (*NSQConn) GetClientId ¶ added in v0.0.46
func (*NSQConn) GetInsecureTls ¶ added in v0.0.46
func (*NSQConn) GetLookupdAddress ¶ added in v0.0.46
func (*NSQConn) GetNsqdAddress ¶ added in v0.0.46
func (*NSQConn) GetTlsCaCert ¶ added in v0.0.46
func (*NSQConn) GetTlsClientCert ¶ added in v0.0.46
func (*NSQConn) GetTlsClientKey ¶ added in v0.0.46
func (*NSQConn) ProtoMessage ¶ added in v0.0.46
func (*NSQConn) ProtoMessage()
func (*NSQConn) XXX_DiscardUnknown ¶ added in v0.0.46
func (m *NSQConn) XXX_DiscardUnknown()
func (*NSQConn) XXX_Marshal ¶ added in v0.0.46
func (*NSQConn) XXX_Unmarshal ¶ added in v0.0.46
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) GetInsecureTls ¶ added in v0.0.46
func (*NatsConn) GetTlsCaCert ¶ added in v0.0.46
func (*NatsConn) GetTlsClientCert ¶ added in v0.0.46
func (*NatsConn) GetTlsClientKey ¶ added in v0.0.46
func (*NatsConn) GetUserCredentials ¶ added in v0.0.46
func (*NatsConn) ProtoMessage ¶ added in v0.0.46
func (*NatsConn) ProtoMessage()
func (*NatsConn) XXX_DiscardUnknown ¶ added in v0.0.46
func (m *NatsConn) XXX_DiscardUnknown()
func (*NatsConn) XXX_Marshal ¶ added in v0.0.46
func (*NatsConn) XXX_Unmarshal ¶ added in v0.0.46
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 int64 `` /* 135-byte string literal not displayed */ // @gotags: kong:"group=offset,xor=offset" LastOffset bool `protobuf:"varint,2,opt,name=last_offset,json=lastOffset,proto3" json:"last_offset,omitempty" kong:"group=offset,xor=offset"` // @gotags: kong:"group=offset,xor=offset" LastConsumed bool `` /* 129-byte string literal not displayed */ // @gotags: kong:"group=offset,xor=offset" FirstOffset bool `` /* 126-byte string literal not displayed */ // @gotags: kong:"group=offset,xor=offset" NextOffset bool `protobuf:"varint,5,opt,name=next_offset,json=nextOffset,proto3" json:"next_offset,omitempty" kong:"group=offset,xor=offset"` 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() bool
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() int64
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='Stream name',required" Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty" kong:"help='Stream name',required"` // @gotags: kong:"help='Declare the stream if it does not exist'" DeclareStream bool `` /* 155-byte string literal not displayed */ // @gotags: kong:"help='Stream capacity to declare (required if declare_stream is true; ex: 1024k, 10mb, 3gb',default=10mb" DeclareStreamSize string `` /* 226-byte string literal not displayed */ 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 */ // @gotags: kong:"help='Database (0-16)',env='PLUMBER_RELAY_REDIS_PUBSUB_DATABASE'" Database uint32 `` /* 142-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) GetDatabase ¶ added in v0.0.96
func (m *RedisPubSubConn) GetDatabase() uint32
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='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) 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='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) 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 */ // @gotags: kong:"help='Database (0-16)',env='PLUMBER_RELAY_REDIS_PUBSUB_DATABASE'" Database uint32 `` /* 142-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) GetDatabase ¶ added in v0.0.96
func (m *RedisStreamsConn) GetDatabase() uint32
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='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) 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
func (SASLType) EnumDescriptor ¶ added in v0.0.69
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 ¶
- ps_args_activemq.pb.go
- ps_args_aws_sns.pb.go
- ps_args_aws_sqs.pb.go
- ps_args_azure_event_hub.pb.go
- ps_args_azure_service_bus.pb.go
- ps_args_gcp_pubsub.pb.go
- ps_args_kafka.pb.go
- ps_args_kubemq_queue.pb.go
- ps_args_mongo.pb.go
- ps_args_mqtt.pb.go
- ps_args_nats.pb.go
- ps_args_nats_streaming.pb.go
- ps_args_nsq.pb.go
- ps_args_postgres.pb.go
- ps_args_pulsar.pb.go
- ps_args_rabbit.pb.go
- ps_args_rabbit_streams.pb.go
- ps_args_redis_pubsub.pb.go
- ps_args_redis_streams.pb.go
Click to show internal directories.
Click to hide internal directories.