Documentation ¶
Index ¶
- Variables
- type AWSKinesisConn
- func (*AWSKinesisConn) Descriptor() ([]byte, []int)
- func (m *AWSKinesisConn) GetAwsAccessKeyId() string
- func (m *AWSKinesisConn) GetAwsProfile() string
- func (m *AWSKinesisConn) GetAwsRegion() string
- func (m *AWSKinesisConn) GetAwsSecretAccessKey() string
- func (*AWSKinesisConn) ProtoMessage()
- func (m *AWSKinesisConn) Reset()
- func (m *AWSKinesisConn) String() string
- func (m *AWSKinesisConn) XXX_DiscardUnknown()
- func (m *AWSKinesisConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AWSKinesisConn) XXX_Merge(src proto.Message)
- func (m *AWSKinesisConn) XXX_Size() int
- func (m *AWSKinesisConn) XXX_Unmarshal(b []byte) error
- type AWSKinesisReadArgs
- func (*AWSKinesisReadArgs) Descriptor() ([]byte, []int)
- func (m *AWSKinesisReadArgs) GetMaxRecords() int64
- func (m *AWSKinesisReadArgs) GetReadAfterSequenceNumber() string
- func (m *AWSKinesisReadArgs) GetReadFromTimestamp() int64
- func (m *AWSKinesisReadArgs) GetReadLatest() bool
- func (m *AWSKinesisReadArgs) GetReadSequenceNumber() string
- func (m *AWSKinesisReadArgs) GetReadTrimHorizon() bool
- func (m *AWSKinesisReadArgs) GetShard() string
- func (m *AWSKinesisReadArgs) GetStream() string
- func (*AWSKinesisReadArgs) ProtoMessage()
- func (m *AWSKinesisReadArgs) Reset()
- func (m *AWSKinesisReadArgs) String() string
- func (m *AWSKinesisReadArgs) XXX_DiscardUnknown()
- func (m *AWSKinesisReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AWSKinesisReadArgs) XXX_Merge(src proto.Message)
- func (m *AWSKinesisReadArgs) XXX_Size() int
- func (m *AWSKinesisReadArgs) XXX_Unmarshal(b []byte) error
- type AWSKinesisWriteArgs
- func (*AWSKinesisWriteArgs) Descriptor() ([]byte, []int)
- func (m *AWSKinesisWriteArgs) GetPartitionKey() string
- func (m *AWSKinesisWriteArgs) GetSequenceNumber() string
- func (m *AWSKinesisWriteArgs) GetStream() string
- func (*AWSKinesisWriteArgs) ProtoMessage()
- func (m *AWSKinesisWriteArgs) Reset()
- func (m *AWSKinesisWriteArgs) String() string
- func (m *AWSKinesisWriteArgs) XXX_DiscardUnknown()
- func (m *AWSKinesisWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AWSKinesisWriteArgs) XXX_Merge(src proto.Message)
- func (m *AWSKinesisWriteArgs) XXX_Size() int
- func (m *AWSKinesisWriteArgs) XXX_Unmarshal(b []byte) error
- type AWSSNSConn
- func (*AWSSNSConn) Descriptor() ([]byte, []int)
- func (m *AWSSNSConn) GetAwsAccessKeyId() string
- func (m *AWSSNSConn) GetAwsProfile() 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) GetAwsProfile() 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) GetSaslPassword() string
- func (m *KafkaConn) GetSaslType() SASLType
- func (m *KafkaConn) GetSaslUsername() string
- func (m *KafkaConn) GetTimeoutSeconds() int32
- func (m *KafkaConn) GetTlsSkipVerify() bool
- 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) GetTlsClientCert() 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) GetTlsCaCert() string
- func (m *MQTTTLSOptions) GetTlsClientCert() string
- func (m *MQTTTLSOptions) GetTlsClientKey() string
- func (m *MQTTTLSOptions) GetTlsSkipVerify() 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 MemphisConn
- func (*MemphisConn) Descriptor() ([]byte, []int)
- func (m *MemphisConn) GetAddress() string
- func (m *MemphisConn) GetBrokerToken() string
- func (m *MemphisConn) GetUsername() string
- func (*MemphisConn) ProtoMessage()
- func (m *MemphisConn) Reset()
- func (m *MemphisConn) String() string
- func (m *MemphisConn) XXX_DiscardUnknown()
- func (m *MemphisConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MemphisConn) XXX_Merge(src proto.Message)
- func (m *MemphisConn) XXX_Size() int
- func (m *MemphisConn) XXX_Unmarshal(b []byte) error
- type MemphisReadArgs
- func (*MemphisReadArgs) Descriptor() ([]byte, []int)
- func (m *MemphisReadArgs) GetConsumerGroup() string
- func (m *MemphisReadArgs) GetConsumerName() string
- func (m *MemphisReadArgs) GetStation() string
- func (*MemphisReadArgs) ProtoMessage()
- func (m *MemphisReadArgs) Reset()
- func (m *MemphisReadArgs) String() string
- func (m *MemphisReadArgs) XXX_DiscardUnknown()
- func (m *MemphisReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MemphisReadArgs) XXX_Merge(src proto.Message)
- func (m *MemphisReadArgs) XXX_Size() int
- func (m *MemphisReadArgs) XXX_Unmarshal(b []byte) error
- type MemphisWriteArgs
- func (*MemphisWriteArgs) Descriptor() ([]byte, []int)
- func (m *MemphisWriteArgs) GetHeaders() map[string]string
- func (m *MemphisWriteArgs) GetMessageId() string
- func (m *MemphisWriteArgs) GetProducerName() string
- func (m *MemphisWriteArgs) GetStation() string
- func (*MemphisWriteArgs) ProtoMessage()
- func (m *MemphisWriteArgs) Reset()
- func (m *MemphisWriteArgs) String() string
- func (m *MemphisWriteArgs) XXX_DiscardUnknown()
- func (m *MemphisWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MemphisWriteArgs) XXX_Merge(src proto.Message)
- func (m *MemphisWriteArgs) XXX_Size() int
- func (m *MemphisWriteArgs) 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) GetLookupdAddress() string
- func (m *NSQConn) GetNsqdAddress() string
- func (m *NSQConn) GetTlsCaCert() string
- func (m *NSQConn) GetTlsClientCert() string
- func (m *NSQConn) GetTlsClientKey() string
- func (m *NSQConn) GetTlsSkipVerify() bool
- 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) GetNkey() string
- func (m *NatsConn) GetTlsOptions() *NatsTLSOptions
- func (m *NatsConn) GetUserCredentials() string
- 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 NatsJetstreamConn
- func (*NatsJetstreamConn) Descriptor() ([]byte, []int)
- func (m *NatsJetstreamConn) GetClientId() string
- func (m *NatsJetstreamConn) GetDsn() string
- func (m *NatsJetstreamConn) GetNkey() string
- func (m *NatsJetstreamConn) GetTlsOptions() *NatsJetstreamTLSOptions
- func (m *NatsJetstreamConn) GetUserCredentials() string
- func (*NatsJetstreamConn) ProtoMessage()
- func (m *NatsJetstreamConn) Reset()
- func (m *NatsJetstreamConn) String() string
- func (m *NatsJetstreamConn) XXX_DiscardUnknown()
- func (m *NatsJetstreamConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsJetstreamConn) XXX_Merge(src proto.Message)
- func (m *NatsJetstreamConn) XXX_Size() int
- func (m *NatsJetstreamConn) XXX_Unmarshal(b []byte) error
- type NatsJetstreamReadArgs
- func (*NatsJetstreamReadArgs) Descriptor() ([]byte, []int)
- func (m *NatsJetstreamReadArgs) GetConsumerFilterSubject() string
- func (m *NatsJetstreamReadArgs) GetConsumerName() string
- func (m *NatsJetstreamReadArgs) GetConsumerStartSequence() int64
- func (m *NatsJetstreamReadArgs) GetConsumerStartTime() string
- func (m *NatsJetstreamReadArgs) GetCreateDurableConsumer() bool
- func (m *NatsJetstreamReadArgs) GetExistingDurableConsumer() bool
- func (m *NatsJetstreamReadArgs) GetKeepConsumer() bool
- func (m *NatsJetstreamReadArgs) GetStream() string
- func (*NatsJetstreamReadArgs) ProtoMessage()
- func (m *NatsJetstreamReadArgs) Reset()
- func (m *NatsJetstreamReadArgs) String() string
- func (m *NatsJetstreamReadArgs) XXX_DiscardUnknown()
- func (m *NatsJetstreamReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsJetstreamReadArgs) XXX_Merge(src proto.Message)
- func (m *NatsJetstreamReadArgs) XXX_Size() int
- func (m *NatsJetstreamReadArgs) XXX_Unmarshal(b []byte) error
- type NatsJetstreamTLSOptions
- func (*NatsJetstreamTLSOptions) Descriptor() ([]byte, []int)
- func (m *NatsJetstreamTLSOptions) GetTlsCaCert() string
- func (m *NatsJetstreamTLSOptions) GetTlsClientCert() string
- func (m *NatsJetstreamTLSOptions) GetTlsClientKey() string
- func (m *NatsJetstreamTLSOptions) GetTlsSkipVerify() bool
- func (m *NatsJetstreamTLSOptions) GetUseTls() bool
- func (*NatsJetstreamTLSOptions) ProtoMessage()
- func (m *NatsJetstreamTLSOptions) Reset()
- func (m *NatsJetstreamTLSOptions) String() string
- func (m *NatsJetstreamTLSOptions) XXX_DiscardUnknown()
- func (m *NatsJetstreamTLSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsJetstreamTLSOptions) XXX_Merge(src proto.Message)
- func (m *NatsJetstreamTLSOptions) XXX_Size() int
- func (m *NatsJetstreamTLSOptions) XXX_Unmarshal(b []byte) error
- type NatsJetstreamWriteArgs
- func (*NatsJetstreamWriteArgs) Descriptor() ([]byte, []int)
- func (m *NatsJetstreamWriteArgs) GetSubject() string
- func (*NatsJetstreamWriteArgs) ProtoMessage()
- func (m *NatsJetstreamWriteArgs) Reset()
- func (m *NatsJetstreamWriteArgs) String() string
- func (m *NatsJetstreamWriteArgs) XXX_DiscardUnknown()
- func (m *NatsJetstreamWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsJetstreamWriteArgs) XXX_Merge(src proto.Message)
- func (m *NatsJetstreamWriteArgs) XXX_Size() int
- func (m *NatsJetstreamWriteArgs) 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) GetTlsOptions() *NatsStreamingTLSOptions
- func (m *NatsStreamingConn) GetUserCredentials() string
- 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 NatsStreamingTLSOptions
- func (*NatsStreamingTLSOptions) Descriptor() ([]byte, []int)
- func (m *NatsStreamingTLSOptions) GetTlsCaCert() string
- func (m *NatsStreamingTLSOptions) GetTlsClientCert() string
- func (m *NatsStreamingTLSOptions) GetTlsClientKey() string
- func (m *NatsStreamingTLSOptions) GetTlsSkipVerify() bool
- func (m *NatsStreamingTLSOptions) GetUseTls() bool
- func (*NatsStreamingTLSOptions) ProtoMessage()
- func (m *NatsStreamingTLSOptions) Reset()
- func (m *NatsStreamingTLSOptions) String() string
- func (m *NatsStreamingTLSOptions) XXX_DiscardUnknown()
- func (m *NatsStreamingTLSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsStreamingTLSOptions) XXX_Merge(src proto.Message)
- func (m *NatsStreamingTLSOptions) XXX_Size() int
- func (m *NatsStreamingTLSOptions) 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 NatsTLSOptions
- func (*NatsTLSOptions) Descriptor() ([]byte, []int)
- func (m *NatsTLSOptions) GetTlsCaCert() string
- func (m *NatsTLSOptions) GetTlsClientCert() string
- func (m *NatsTLSOptions) GetTlsClientKey() string
- func (m *NatsTLSOptions) GetTlsSkipVerify() bool
- func (m *NatsTLSOptions) GetUseTls() bool
- func (*NatsTLSOptions) ProtoMessage()
- func (m *NatsTLSOptions) Reset()
- func (m *NatsTLSOptions) String() string
- func (m *NatsTLSOptions) XXX_DiscardUnknown()
- func (m *NatsTLSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NatsTLSOptions) XXX_Merge(src proto.Message)
- func (m *NatsTLSOptions) XXX_Size() int
- func (m *NatsTLSOptions) 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) GetPassword() string
- func (m *PostgresConn) GetPort() uint32
- func (m *PostgresConn) GetTlsSkipVerify() bool
- 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) GetListenerName() string
- func (m *PulsarConn) GetTlsClientCert() string
- func (m *PulsarConn) GetTlsClientKey() string
- func (m *PulsarConn) GetTlsSkipVerify() bool
- func (m *PulsarConn) GetToken() string
- 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) GetInitialPosition() SubscriptionInitialPosition
- 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) GetTlsSkipVerify() 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) GetExcludeBindingKeyRegex() string
- func (m *RabbitReadArgs) GetQueueArg() map[string]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) GetPassword() string
- func (m *RabbitStreamsConn) GetTlsSkipVerify() bool
- 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) GetChannels() []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) GetChannels() []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) GetStreams() []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 SubscriptionInitialPosition
- 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 SubscriptionInitialPosition_name = map[int32]string{
0: "PULSAR_LATEST",
1: "PULSAR_EARLIEST",
}
View Source
var SubscriptionInitialPosition_value = map[string]int32{
"PULSAR_LATEST": 0,
"PULSAR_EARLIEST": 1,
}
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 AWSKinesisConn ¶ added in v0.0.121
type AWSKinesisConn struct { // @gotags: kong:"env=AWS_DEFAULT_REGION,hidden" AwsRegion string `protobuf:"bytes,1,opt,name=aws_region,json=awsRegion,proto3" json:"aws_region,omitempty" kong:"env=AWS_DEFAULT_REGION,hidden"` // @gotags: kong:"env=AWS_ACCESS_KEY_ID,hidden" AwsAccessKeyId string `` /* 143-byte string literal not displayed */ // @gotags: kong:"env=AWS_SECRET_ACCESS_KEY,hidden" AwsSecretAccessKey string `` /* 159-byte string literal not displayed */ // @gotags: kong:"env=AWS_PROFILE,hidden" AwsProfile string `protobuf:"bytes,4,opt,name=aws_profile,json=awsProfile,proto3" json:"aws_profile,omitempty" kong:"env=AWS_PROFILE,hidden"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AWSKinesisConn) Descriptor ¶ added in v0.0.121
func (*AWSKinesisConn) Descriptor() ([]byte, []int)
func (*AWSKinesisConn) GetAwsAccessKeyId ¶ added in v0.0.121
func (m *AWSKinesisConn) GetAwsAccessKeyId() string
func (*AWSKinesisConn) GetAwsProfile ¶ added in v0.0.123
func (m *AWSKinesisConn) GetAwsProfile() string
func (*AWSKinesisConn) GetAwsRegion ¶ added in v0.0.121
func (m *AWSKinesisConn) GetAwsRegion() string
func (*AWSKinesisConn) GetAwsSecretAccessKey ¶ added in v0.0.121
func (m *AWSKinesisConn) GetAwsSecretAccessKey() string
func (*AWSKinesisConn) ProtoMessage ¶ added in v0.0.121
func (*AWSKinesisConn) ProtoMessage()
func (*AWSKinesisConn) Reset ¶ added in v0.0.121
func (m *AWSKinesisConn) Reset()
func (*AWSKinesisConn) String ¶ added in v0.0.121
func (m *AWSKinesisConn) String() string
func (*AWSKinesisConn) XXX_DiscardUnknown ¶ added in v0.0.121
func (m *AWSKinesisConn) XXX_DiscardUnknown()
func (*AWSKinesisConn) XXX_Marshal ¶ added in v0.0.121
func (m *AWSKinesisConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AWSKinesisConn) XXX_Merge ¶ added in v0.0.121
func (m *AWSKinesisConn) XXX_Merge(src proto.Message)
func (*AWSKinesisConn) XXX_Size ¶ added in v0.0.121
func (m *AWSKinesisConn) XXX_Size() int
func (*AWSKinesisConn) XXX_Unmarshal ¶ added in v0.0.121
func (m *AWSKinesisConn) XXX_Unmarshal(b []byte) error
type AWSKinesisReadArgs ¶ added in v0.0.121
type AWSKinesisReadArgs struct { // @gotags: kong:"help='Stream Name',required" Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty" kong:"help='Stream Name',required"` // @gotags: kong:"help='Shard ID. If empty, will read from all shards'" Shard string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty" kong:"help='Shard ID. If empty, will read from all shards'"` // @gotags: kong:"help='Maximum number of records to read from kinesis',default=1" MaxRecords int64 `` /* 163-byte string literal not displayed */ // @gotags: kong:"help='Deliver starting at this timestamp',xor=kinesis_delivery_option" ReadFromTimestamp int64 `` /* 192-byte string literal not displayed */ // @gotags: kong:"help='Deliver messages starting at sequence number',xor=kinesis_delivery_option" ReadSequenceNumber string `` /* 204-byte string literal not displayed */ // @gotags: kong:"help='Deliver messages starting after this sequence number',xor=kinesis_delivery_option" ReadAfterSequenceNumber string `` /* 229-byte string literal not displayed */ // @gotags: kong:"help='Deliver messages starting at the last untrimmed record in the shard in the system, which is the oldest data record in the shard.',xor=kinesis_delivery_option" ReadTrimHorizon bool `` /* 280-byte string literal not displayed */ // @gotags: kong:"help='Deliver messages after the most recent record',xor=kinesis_delivery_option" ReadLatest bool `` /* 180-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AWSKinesisReadArgs) Descriptor ¶ added in v0.0.121
func (*AWSKinesisReadArgs) Descriptor() ([]byte, []int)
func (*AWSKinesisReadArgs) GetMaxRecords ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) GetMaxRecords() int64
func (*AWSKinesisReadArgs) GetReadAfterSequenceNumber ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) GetReadAfterSequenceNumber() string
func (*AWSKinesisReadArgs) GetReadFromTimestamp ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) GetReadFromTimestamp() int64
func (*AWSKinesisReadArgs) GetReadLatest ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) GetReadLatest() bool
func (*AWSKinesisReadArgs) GetReadSequenceNumber ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) GetReadSequenceNumber() string
func (*AWSKinesisReadArgs) GetReadTrimHorizon ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) GetReadTrimHorizon() bool
func (*AWSKinesisReadArgs) GetShard ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) GetShard() string
func (*AWSKinesisReadArgs) GetStream ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) GetStream() string
func (*AWSKinesisReadArgs) ProtoMessage ¶ added in v0.0.121
func (*AWSKinesisReadArgs) ProtoMessage()
func (*AWSKinesisReadArgs) Reset ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) Reset()
func (*AWSKinesisReadArgs) String ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) String() string
func (*AWSKinesisReadArgs) XXX_DiscardUnknown ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) XXX_DiscardUnknown()
func (*AWSKinesisReadArgs) XXX_Marshal ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AWSKinesisReadArgs) XXX_Merge ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) XXX_Merge(src proto.Message)
func (*AWSKinesisReadArgs) XXX_Size ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) XXX_Size() int
func (*AWSKinesisReadArgs) XXX_Unmarshal ¶ added in v0.0.121
func (m *AWSKinesisReadArgs) XXX_Unmarshal(b []byte) error
type AWSKinesisWriteArgs ¶ added in v0.0.121
type AWSKinesisWriteArgs struct { // @gotags: kong:"help='Stream Name',required" Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty" kong:"help='Stream Name',required"` // @gotags: kong:"help='Partition Key',required" PartitionKey string `` /* 134-byte string literal not displayed */ // @gotags: kong:"help='Sequence number for ordering'" SequenceNumber string `` /* 146-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AWSKinesisWriteArgs) Descriptor ¶ added in v0.0.121
func (*AWSKinesisWriteArgs) Descriptor() ([]byte, []int)
func (*AWSKinesisWriteArgs) GetPartitionKey ¶ added in v0.0.121
func (m *AWSKinesisWriteArgs) GetPartitionKey() string
func (*AWSKinesisWriteArgs) GetSequenceNumber ¶ added in v0.0.121
func (m *AWSKinesisWriteArgs) GetSequenceNumber() string
func (*AWSKinesisWriteArgs) GetStream ¶ added in v0.0.121
func (m *AWSKinesisWriteArgs) GetStream() string
func (*AWSKinesisWriteArgs) ProtoMessage ¶ added in v0.0.121
func (*AWSKinesisWriteArgs) ProtoMessage()
func (*AWSKinesisWriteArgs) Reset ¶ added in v0.0.121
func (m *AWSKinesisWriteArgs) Reset()
func (*AWSKinesisWriteArgs) String ¶ added in v0.0.121
func (m *AWSKinesisWriteArgs) String() string
func (*AWSKinesisWriteArgs) XXX_DiscardUnknown ¶ added in v0.0.121
func (m *AWSKinesisWriteArgs) XXX_DiscardUnknown()
func (*AWSKinesisWriteArgs) XXX_Marshal ¶ added in v0.0.121
func (m *AWSKinesisWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AWSKinesisWriteArgs) XXX_Merge ¶ added in v0.0.121
func (m *AWSKinesisWriteArgs) XXX_Merge(src proto.Message)
func (*AWSKinesisWriteArgs) XXX_Size ¶ added in v0.0.121
func (m *AWSKinesisWriteArgs) XXX_Size() int
func (*AWSKinesisWriteArgs) XXX_Unmarshal ¶ added in v0.0.121
func (m *AWSKinesisWriteArgs) XXX_Unmarshal(b []byte) error
type AWSSNSConn ¶ added in v0.0.46
type AWSSNSConn struct { // @gotags: kong:"env=AWS_DEFAULT_REGION,hidden" AwsRegion string `protobuf:"bytes,1,opt,name=aws_region,json=awsRegion,proto3" json:"aws_region,omitempty" kong:"env=AWS_DEFAULT_REGION,hidden"` // @gotags: kong:"env=AWS_ACCESS_KEY_ID,hidden" AwsAccessKeyId string `` /* 143-byte string literal not displayed */ // @gotags: kong:"env=AWS_SECRET_ACCESS_KEY,hidden" AwsSecretAccessKey string `` /* 159-byte string literal not displayed */ // @gotags: kong:"env=AWS_PROFILE,hidden" AwsProfile string `protobuf:"bytes,4,opt,name=aws_profile,json=awsProfile,proto3" json:"aws_profile,omitempty" kong:"env=AWS_PROFILE,hidden"` 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) GetAwsProfile ¶ added in v0.0.123
func (m *AWSSNSConn) GetAwsProfile() 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:"env=AWS_DEFAULT_REGION,hidden" AwsRegion string `protobuf:"bytes,1,opt,name=aws_region,json=awsRegion,proto3" json:"aws_region,omitempty" kong:"env=AWS_DEFAULT_REGION,hidden"` // @gotags: kong:"env=AWS_ACCESS_KEY_ID,hidden" AwsAccessKeyId string `` /* 143-byte string literal not displayed */ // @gotags: kong:"env=AWS_SECRET_ACCESS_KEY,hidden" AwsSecretAccessKey string `` /* 159-byte string literal not displayed */ // @gotags: kong:"env=AWS_PROFILE,hidden" AwsProfile string `protobuf:"bytes,4,opt,name=aws_profile,json=awsProfile,proto3" json:"aws_profile,omitempty" kong:"env=AWS_PROFILE,hidden"` 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) GetAwsProfile ¶ added in v0.0.123
func (m *AWSSQSConn) GetAwsProfile() 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 (assign: k=v delimit: ;)'" Attributes map[string]string `` /* 244-byte string literal not displayed */ // @gotags: kong:"help='Message Group ID. For FIFO queues only'" MessageGroupId string `` /* 158-byte string literal not displayed */ // @gotags: kong:"help='Required when publishing to a FIFO queue that does not have content based deduplication enabled'" MessageDeduplicationId string `` /* 239-byte string literal not displayed */ 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 `` /* 291-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 `` /* 211-byte string literal not displayed */ // @gotags: kong:"help='Connect timeout',env=PLUMBER_RELAY_TIMEOUT_SECONDS,default=10" TimeoutSeconds int32 `` /* 179-byte string literal not displayed */ // @gotags: kong:"help='Enable TLS usage',env=PLUMBER_RELAY_USE_TLS" UseTls bool `` /* 137-byte string literal not displayed */ // @gotags: kong:"help='Allow insecure TLS usage',env=PLUMBER_RELAY_KAFKA_INSECURE_TLS" TlsSkipVerify bool `` /* 179-byte string literal not displayed */ // @gotags: kong:"help='SASL authentication type (options: none plain scram)',env=PLUMBER_RELAY_KAFKA_SASL_TYPE,type=pbenum,pbenum_lowercase,default=none" SaslType SASLType `` /* 255-byte string literal not displayed */ // @gotags: kong:"help='SASL Username',env=PLUMBER_RELAY_KAFKA_USERNAME" SaslUsername string `` /* 158-byte string literal not displayed */ // Required if sasl_type is not NONE // @gotags: kong:"help='SASL Password. You will be prompted for the password if omitted',env=PLUMBER_RELAY_KAFKA_PASSWORD" SaslPassword string `` /* 208-byte string literal not displayed */ 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) 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) GetTlsSkipVerify ¶ added in v0.0.114
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_CLIENT_CERT'" TlsClientCert string `` /* 189-byte string literal not displayed */ // @gotags: kong:"help='KubeMQ client ID',env='PLUMBER_RELAY_KUBEMQ_QUEUE_CLIENT_ID',default=plumber" ClientId string `` /* 175-byte string literal not displayed */ 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) GetTlsClientCert ¶ added in v0.0.114
func (m *KubeMQQueueConn) GetTlsClientCert() 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 cert (only needed if addr is ssl://)',env=PLUMBER_RELAY_MQTT_TLS_CA_CERT" TlsCaCert string `` /* 179-byte string literal not displayed */ // @gotags: kong:"help='Client cert file (only needed if addr is ssl://)',env=PLUMBER_RELAY_MQTT_TLS_CLIENT_CERT" TlsClientCert string `` /* 204-byte string literal not displayed */ // @gotags: kong:"help='Client key file (only needed if addr is ssl://)',env=PLUMBER_RELAY_MQTT_TLS_CLIENT_KEY" TlsClientKey string `` /* 199-byte string literal not displayed */ // @gotags: kong:"help='Whether to verify server certificate',env=PLUMBER_RELAY_MQTT_SKIP_VERIFY_TLS" TlsSkipVerify bool `` /* 193-byte string literal not displayed */ 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) GetTlsCaCert ¶ added in v0.0.114
func (m *MQTTTLSOptions) GetTlsCaCert() string
func (*MQTTTLSOptions) GetTlsClientCert ¶ added in v0.0.114
func (m *MQTTTLSOptions) GetTlsClientCert() string
func (*MQTTTLSOptions) GetTlsClientKey ¶ added in v0.0.114
func (m *MQTTTLSOptions) GetTlsClientKey() string
func (*MQTTTLSOptions) GetTlsSkipVerify ¶ added in v0.0.114
func (m *MQTTTLSOptions) GetTlsSkipVerify() 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 MemphisConn ¶ added in v0.0.177
type MemphisConn struct { // @gotags: kong:"help='Address of Memphis broker (Ex: localhost:6666)',default='localhost:6666'" Address string `` /* 153-byte string literal not displayed */ // @gotags: kong:"help='Broker username',default='plumber'" Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty" kong:"help='Broker username',default='plumber'"` // @gotags: kong:"help='Broker access token',default='memphis'" BrokerToken string `` /* 146-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MemphisConn) Descriptor ¶ added in v0.0.177
func (*MemphisConn) Descriptor() ([]byte, []int)
func (*MemphisConn) GetAddress ¶ added in v0.0.177
func (m *MemphisConn) GetAddress() string
func (*MemphisConn) GetBrokerToken ¶ added in v0.0.177
func (m *MemphisConn) GetBrokerToken() string
func (*MemphisConn) GetUsername ¶ added in v0.0.177
func (m *MemphisConn) GetUsername() string
func (*MemphisConn) ProtoMessage ¶ added in v0.0.177
func (*MemphisConn) ProtoMessage()
func (*MemphisConn) Reset ¶ added in v0.0.177
func (m *MemphisConn) Reset()
func (*MemphisConn) String ¶ added in v0.0.177
func (m *MemphisConn) String() string
func (*MemphisConn) XXX_DiscardUnknown ¶ added in v0.0.177
func (m *MemphisConn) XXX_DiscardUnknown()
func (*MemphisConn) XXX_Marshal ¶ added in v0.0.177
func (m *MemphisConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MemphisConn) XXX_Merge ¶ added in v0.0.177
func (m *MemphisConn) XXX_Merge(src proto.Message)
func (*MemphisConn) XXX_Size ¶ added in v0.0.177
func (m *MemphisConn) XXX_Size() int
func (*MemphisConn) XXX_Unmarshal ¶ added in v0.0.177
func (m *MemphisConn) XXX_Unmarshal(b []byte) error
type MemphisReadArgs ¶ added in v0.0.177
type MemphisReadArgs struct { // @gotags: kong:"help='Station name to consume from',required" Station string `protobuf:"bytes,1,opt,name=station,proto3" json:"station,omitempty" kong:"help='Station name to consume from',required"` // @gotags: kong:"help='Consumer Name',default='plumber'" ConsumerName string `` /* 143-byte string literal not displayed */ // @gotags: kong:"help='Consumer Group, defaults to consumer-name if not specified',env='PLUMBER_RELAY_MEMPHIS_CONSUMER_GROUP'" ConsumerGroup string `` /* 216-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MemphisReadArgs) Descriptor ¶ added in v0.0.177
func (*MemphisReadArgs) Descriptor() ([]byte, []int)
func (*MemphisReadArgs) GetConsumerGroup ¶ added in v0.0.177
func (m *MemphisReadArgs) GetConsumerGroup() string
func (*MemphisReadArgs) GetConsumerName ¶ added in v0.0.177
func (m *MemphisReadArgs) GetConsumerName() string
func (*MemphisReadArgs) GetStation ¶ added in v0.0.177
func (m *MemphisReadArgs) GetStation() string
func (*MemphisReadArgs) ProtoMessage ¶ added in v0.0.177
func (*MemphisReadArgs) ProtoMessage()
func (*MemphisReadArgs) Reset ¶ added in v0.0.177
func (m *MemphisReadArgs) Reset()
func (*MemphisReadArgs) String ¶ added in v0.0.177
func (m *MemphisReadArgs) String() string
func (*MemphisReadArgs) XXX_DiscardUnknown ¶ added in v0.0.177
func (m *MemphisReadArgs) XXX_DiscardUnknown()
func (*MemphisReadArgs) XXX_Marshal ¶ added in v0.0.177
func (m *MemphisReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MemphisReadArgs) XXX_Merge ¶ added in v0.0.177
func (m *MemphisReadArgs) XXX_Merge(src proto.Message)
func (*MemphisReadArgs) XXX_Size ¶ added in v0.0.177
func (m *MemphisReadArgs) XXX_Size() int
func (*MemphisReadArgs) XXX_Unmarshal ¶ added in v0.0.177
func (m *MemphisReadArgs) XXX_Unmarshal(b []byte) error
type MemphisWriteArgs ¶ added in v0.0.177
type MemphisWriteArgs struct { // @gotags: kong:"help='Station name to write to',required" Station string `protobuf:"bytes,1,opt,name=station,proto3" json:"station,omitempty" kong:"help='Station name to write to',required"` // @gotags: kong:"help='Producer name',default='plumber'" ProducerName string `` /* 143-byte string literal not displayed */ // @gotags: kong:"help='Add one or more headers (optional; repeat flags to specify multiple)'" Headers map[string]string `` /* 238-byte string literal not displayed */ // @gotags: kong:"help='ID to give message'" MessageId string `protobuf:"bytes,4,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty" kong:"help='ID to give message'"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MemphisWriteArgs) Descriptor ¶ added in v0.0.177
func (*MemphisWriteArgs) Descriptor() ([]byte, []int)
func (*MemphisWriteArgs) GetHeaders ¶ added in v0.0.177
func (m *MemphisWriteArgs) GetHeaders() map[string]string
func (*MemphisWriteArgs) GetMessageId ¶ added in v0.0.177
func (m *MemphisWriteArgs) GetMessageId() string
func (*MemphisWriteArgs) GetProducerName ¶ added in v0.0.177
func (m *MemphisWriteArgs) GetProducerName() string
func (*MemphisWriteArgs) GetStation ¶ added in v0.0.177
func (m *MemphisWriteArgs) GetStation() string
func (*MemphisWriteArgs) ProtoMessage ¶ added in v0.0.177
func (*MemphisWriteArgs) ProtoMessage()
func (*MemphisWriteArgs) Reset ¶ added in v0.0.177
func (m *MemphisWriteArgs) Reset()
func (*MemphisWriteArgs) String ¶ added in v0.0.177
func (m *MemphisWriteArgs) String() string
func (*MemphisWriteArgs) XXX_DiscardUnknown ¶ added in v0.0.177
func (m *MemphisWriteArgs) XXX_DiscardUnknown()
func (*MemphisWriteArgs) XXX_Marshal ¶ added in v0.0.177
func (m *MemphisWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MemphisWriteArgs) XXX_Merge ¶ added in v0.0.177
func (m *MemphisWriteArgs) XXX_Merge(src proto.Message)
func (*MemphisWriteArgs) XXX_Size ¶ added in v0.0.177
func (m *MemphisWriteArgs) XXX_Size() int
func (*MemphisWriteArgs) XXX_Unmarshal ¶ added in v0.0.177
func (m *MemphisWriteArgs) 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'" TlsSkipVerify bool `` /* 194-byte string literal not displayed */ // @gotags: kong:"help='CA file',env='PLUMBER_RELAY_NSQ_TLS_CA_CERT'" TlsCaCert string `` /* 148-byte string literal not displayed */ // @gotags: kong:"help='Client cert file',env='PLUMBER_RELAY_NSQ_TLS_CLIENT_CERT'" TlsClientCert string `` /* 173-byte string literal not displayed */ // @gotags: kong:"help='Client key file',env='PLUMBER_RELAY_NSQ_TLS_CLIENT_KEY'" TlsClientKey string `` /* 168-byte string literal not displayed */ // @gotags: kong:"help='Authentication secret',env='PLUMBER_RELAY_NSQ_AUTH_SECRET'" AuthSecret string `` /* 163-byte string literal not displayed */ // @gotags: kong:"help='Client ID to identify as',env='PLUMBER_RELAY_NSQ_CLIENT_ID',default=plumber" ClientId string `` /* 174-byte string literal not displayed */ 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) 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) GetTlsSkipVerify ¶ added in v0.0.114
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='nats://localhost:4222',env='PLUMBER_RELAY_NATS_DSN'" Dsn string `` /* 189-byte string literal not displayed */ // @gotags: kong:"help='NATS .creds file containing authentication credentials',env='PLUMBER_RELAY_NATS_CREDENTIALS'" UserCredentials string `` /* 212-byte string literal not displayed */ // @gotags: kong:"embed" TlsOptions *NatsTLSOptions `protobuf:"bytes,3,opt,name=tls_options,json=tlsOptions,proto3" json:"tls_options,omitempty" kong:"embed"` // @gotags: kong:"help='File containing NATS NKey',env='PLUMBER_RELAY_NATS_NKEY'" Nkey string `` /* 131-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NatsConn) Descriptor ¶ added in v0.0.46
func (*NatsConn) GetTlsOptions ¶ added in v0.0.125
func (m *NatsConn) GetTlsOptions() *NatsTLSOptions
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 NatsJetstreamConn ¶ added in v0.0.119
type NatsJetstreamConn struct { // @gotags: kong:"help='Dial string for NATS server. Ex: nats://localhost:4222',default='nats://localhost:4222',env='PLUMBER_RELAY_NATS_JETSTREAM_DSN'" Dsn string `` /* 199-byte string literal not displayed */ // @gotags: kong:"help='NATS .creds file containing authentication credentials',env='PLUMBER_RELAY_NATS_JETSTREAM_CREDENTIALS'" UserCredentials string `` /* 222-byte string literal not displayed */ // @gotags: kong:"help='User specified client ID to connect with',default=plumber,env='PLUMBER_RELAY_NATS_JETSTREAM_CLIENT_ID'" ClientId string `` /* 201-byte string literal not displayed */ // @gotags: kong:"embed" TlsOptions *NatsJetstreamTLSOptions `protobuf:"bytes,4,opt,name=tls_options,json=tlsOptions,proto3" json:"tls_options,omitempty" kong:"embed"` // @gotags: kong:"help='File containing NATS NKey',env='PLUMBER_RELAY_NATS_JETSTREAM_NKEY'" Nkey string `` /* 141-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NatsJetstreamConn) Descriptor ¶ added in v0.0.119
func (*NatsJetstreamConn) Descriptor() ([]byte, []int)
func (*NatsJetstreamConn) GetClientId ¶ added in v0.0.119
func (m *NatsJetstreamConn) GetClientId() string
func (*NatsJetstreamConn) GetDsn ¶ added in v0.0.119
func (m *NatsJetstreamConn) GetDsn() string
func (*NatsJetstreamConn) GetNkey ¶ added in v0.0.166
func (m *NatsJetstreamConn) GetNkey() string
func (*NatsJetstreamConn) GetTlsOptions ¶ added in v0.0.119
func (m *NatsJetstreamConn) GetTlsOptions() *NatsJetstreamTLSOptions
func (*NatsJetstreamConn) GetUserCredentials ¶ added in v0.0.119
func (m *NatsJetstreamConn) GetUserCredentials() string
func (*NatsJetstreamConn) ProtoMessage ¶ added in v0.0.119
func (*NatsJetstreamConn) ProtoMessage()
func (*NatsJetstreamConn) Reset ¶ added in v0.0.119
func (m *NatsJetstreamConn) Reset()
func (*NatsJetstreamConn) String ¶ added in v0.0.119
func (m *NatsJetstreamConn) String() string
func (*NatsJetstreamConn) XXX_DiscardUnknown ¶ added in v0.0.119
func (m *NatsJetstreamConn) XXX_DiscardUnknown()
func (*NatsJetstreamConn) XXX_Marshal ¶ added in v0.0.119
func (m *NatsJetstreamConn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NatsJetstreamConn) XXX_Merge ¶ added in v0.0.119
func (m *NatsJetstreamConn) XXX_Merge(src proto.Message)
func (*NatsJetstreamConn) XXX_Size ¶ added in v0.0.119
func (m *NatsJetstreamConn) XXX_Size() int
func (*NatsJetstreamConn) XXX_Unmarshal ¶ added in v0.0.119
func (m *NatsJetstreamConn) XXX_Unmarshal(b []byte) error
type NatsJetstreamReadArgs ¶ added in v0.0.119
type NatsJetstreamReadArgs struct { // @gotags: kong:"help='NATS JetStream stream name. Ex: orders.>',env='PLUMBER_RELAY_NATS_JETSTREAM_STREAM'" Stream string `` /* 162-byte string literal not displayed */ // @gotags: kong:"help='Consumer name (default: random consumer name; has no effect if create_durable_consumer or existing_durable_consumer is not set)',env='PLUMBER_RELAY_NATS_JETSTREAM_CONSUMER_NAME'" ConsumerName string `` /* 288-byte string literal not displayed */ // @gotags: kong:"help='Create a new durable consumer (default: use ephemeral consumer)',env='PLUMBER_RELAY_NATS_JETSTREAM_CREATE_DURABLE_CONSUMER'" CreateDurableConsumer bool `` /* 264-byte string literal not displayed */ // @gotags: kong:"help='Use an existing durable consumer (default: use ephemeral consumer)',env='PLUMBER_RELAY_NATS_JETSTREAM_EXISTING_DURABLE_CONSUMER'" ExistingDurableConsumer bool `` /* 275-byte string literal not displayed */ // @gotags: kong:"help='Do not delete consumer after operation is done (default: delete on exit)',env='PLUMBER_RELAY_NATS_JETSTREAM_KEEP_CONSUMER'" KeepConsumer bool `` /* 234-byte string literal not displayed */ // @gotags: kong:"help='Where to start read in stream (default: from start)',env='PLUMBER_RELAY_NATS_JETSTREAM_CONSUMER_START_SEQUENCE'" ConsumerStartSequence int64 `` /* 252-byte string literal not displayed */ // @gotags: kong:"help='At what time to start stream (RFC3339 format, Ex: 2016-06-20T12:41:45.14Z)',env='PLUMBER_RELAY_NATS_JETSTREAM_CONSUMER_START_TIME'" ConsumerStartTime string `` /* 258-byte string literal not displayed */ // @gotags: kong:"help='Only receive a subset of messages from the Stream based on the subject',env='PLUMBER_RELAY_NATS_JETSTREAM_CONSUMER_FILTER_SUBJECT'" ConsumerFilterSubject string `` /* 270-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NatsJetstreamReadArgs) Descriptor ¶ added in v0.0.119
func (*NatsJetstreamReadArgs) Descriptor() ([]byte, []int)
func (*NatsJetstreamReadArgs) GetConsumerFilterSubject ¶ added in v0.0.161
func (m *NatsJetstreamReadArgs) GetConsumerFilterSubject() string
func (*NatsJetstreamReadArgs) GetConsumerName ¶ added in v0.0.161
func (m *NatsJetstreamReadArgs) GetConsumerName() string
func (*NatsJetstreamReadArgs) GetConsumerStartSequence ¶ added in v0.0.161
func (m *NatsJetstreamReadArgs) GetConsumerStartSequence() int64
func (*NatsJetstreamReadArgs) GetConsumerStartTime ¶ added in v0.0.161
func (m *NatsJetstreamReadArgs) GetConsumerStartTime() string
func (*NatsJetstreamReadArgs) GetCreateDurableConsumer ¶ added in v0.0.162
func (m *NatsJetstreamReadArgs) GetCreateDurableConsumer() bool
func (*NatsJetstreamReadArgs) GetExistingDurableConsumer ¶ added in v0.0.162
func (m *NatsJetstreamReadArgs) GetExistingDurableConsumer() bool
func (*NatsJetstreamReadArgs) GetKeepConsumer ¶ added in v0.0.161
func (m *NatsJetstreamReadArgs) GetKeepConsumer() bool
func (*NatsJetstreamReadArgs) GetStream ¶ added in v0.0.119
func (m *NatsJetstreamReadArgs) GetStream() string
func (*NatsJetstreamReadArgs) ProtoMessage ¶ added in v0.0.119
func (*NatsJetstreamReadArgs) ProtoMessage()
func (*NatsJetstreamReadArgs) Reset ¶ added in v0.0.119
func (m *NatsJetstreamReadArgs) Reset()
func (*NatsJetstreamReadArgs) String ¶ added in v0.0.119
func (m *NatsJetstreamReadArgs) String() string
func (*NatsJetstreamReadArgs) XXX_DiscardUnknown ¶ added in v0.0.119
func (m *NatsJetstreamReadArgs) XXX_DiscardUnknown()
func (*NatsJetstreamReadArgs) XXX_Marshal ¶ added in v0.0.119
func (m *NatsJetstreamReadArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NatsJetstreamReadArgs) XXX_Merge ¶ added in v0.0.119
func (m *NatsJetstreamReadArgs) XXX_Merge(src proto.Message)
func (*NatsJetstreamReadArgs) XXX_Size ¶ added in v0.0.119
func (m *NatsJetstreamReadArgs) XXX_Size() int
func (*NatsJetstreamReadArgs) XXX_Unmarshal ¶ added in v0.0.119
func (m *NatsJetstreamReadArgs) XXX_Unmarshal(b []byte) error
type NatsJetstreamTLSOptions ¶ added in v0.0.119
type NatsJetstreamTLSOptions struct { // @gotags: kong:"help='CA file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_JETSTREAM_TLS_CA_CERT'" TlsCaCert string `` /* 192-byte string literal not displayed */ // @gotags: kong:"help='Client cert file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_JETSTREAM_TLS_CLIENT_CERT'" TlsClientCert string `` /* 217-byte string literal not displayed */ // @gotags: kong:"help='Client key file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_JETSTREAM_TLS_CLIENT_KEY'" TlsClientKey string `` /* 212-byte string literal not displayed */ // @gotags: kong:"help='Whether to verify server certificate',env='PLUMBER_RELAY_NATS_JETSTREAM_SKIP_VERIFY_TLS'" TlsSkipVerify bool `` /* 205-byte string literal not displayed */ // @gotags: kong:"help='Enable TLS',env='PLUMBER_RELAY_NATS_JETSTREAM_USE_TLS'" UseTls bool `` /* 148-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NatsJetstreamTLSOptions) Descriptor ¶ added in v0.0.119
func (*NatsJetstreamTLSOptions) Descriptor() ([]byte, []int)
func (*NatsJetstreamTLSOptions) GetTlsCaCert ¶ added in v0.0.119
func (m *NatsJetstreamTLSOptions) GetTlsCaCert() string
func (*NatsJetstreamTLSOptions) GetTlsClientCert ¶ added in v0.0.119
func (m *NatsJetstreamTLSOptions) GetTlsClientCert() string
func (*NatsJetstreamTLSOptions) GetTlsClientKey ¶ added in v0.0.119
func (m *NatsJetstreamTLSOptions) GetTlsClientKey() string
func (*NatsJetstreamTLSOptions) GetTlsSkipVerify ¶ added in v0.0.119
func (m *NatsJetstreamTLSOptions) GetTlsSkipVerify() bool
func (*NatsJetstreamTLSOptions) GetUseTls ¶ added in v0.0.144
func (m *NatsJetstreamTLSOptions) GetUseTls() bool
func (*NatsJetstreamTLSOptions) ProtoMessage ¶ added in v0.0.119
func (*NatsJetstreamTLSOptions) ProtoMessage()
func (*NatsJetstreamTLSOptions) Reset ¶ added in v0.0.119
func (m *NatsJetstreamTLSOptions) Reset()
func (*NatsJetstreamTLSOptions) String ¶ added in v0.0.119
func (m *NatsJetstreamTLSOptions) String() string
func (*NatsJetstreamTLSOptions) XXX_DiscardUnknown ¶ added in v0.0.119
func (m *NatsJetstreamTLSOptions) XXX_DiscardUnknown()
func (*NatsJetstreamTLSOptions) XXX_Marshal ¶ added in v0.0.119
func (m *NatsJetstreamTLSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NatsJetstreamTLSOptions) XXX_Merge ¶ added in v0.0.119
func (m *NatsJetstreamTLSOptions) XXX_Merge(src proto.Message)
func (*NatsJetstreamTLSOptions) XXX_Size ¶ added in v0.0.119
func (m *NatsJetstreamTLSOptions) XXX_Size() int
func (*NatsJetstreamTLSOptions) XXX_Unmarshal ¶ added in v0.0.119
func (m *NatsJetstreamTLSOptions) XXX_Unmarshal(b []byte) error
type NatsJetstreamWriteArgs ¶ added in v0.0.119
type NatsJetstreamWriteArgs struct { // @gotags: kong:"help='NATS JetStream subject name to write to. Ex: orders.>'" Subject string `` /* 135-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NatsJetstreamWriteArgs) Descriptor ¶ added in v0.0.119
func (*NatsJetstreamWriteArgs) Descriptor() ([]byte, []int)
func (*NatsJetstreamWriteArgs) GetSubject ¶ added in v0.0.164
func (m *NatsJetstreamWriteArgs) GetSubject() string
func (*NatsJetstreamWriteArgs) ProtoMessage ¶ added in v0.0.119
func (*NatsJetstreamWriteArgs) ProtoMessage()
func (*NatsJetstreamWriteArgs) Reset ¶ added in v0.0.119
func (m *NatsJetstreamWriteArgs) Reset()
func (*NatsJetstreamWriteArgs) String ¶ added in v0.0.119
func (m *NatsJetstreamWriteArgs) String() string
func (*NatsJetstreamWriteArgs) XXX_DiscardUnknown ¶ added in v0.0.119
func (m *NatsJetstreamWriteArgs) XXX_DiscardUnknown()
func (*NatsJetstreamWriteArgs) XXX_Marshal ¶ added in v0.0.119
func (m *NatsJetstreamWriteArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NatsJetstreamWriteArgs) XXX_Merge ¶ added in v0.0.119
func (m *NatsJetstreamWriteArgs) XXX_Merge(src proto.Message)
func (*NatsJetstreamWriteArgs) XXX_Size ¶ added in v0.0.119
func (m *NatsJetstreamWriteArgs) XXX_Size() int
func (*NatsJetstreamWriteArgs) XXX_Unmarshal ¶ added in v0.0.119
func (m *NatsJetstreamWriteArgs) XXX_Unmarshal(b []byte) error
type NatsReadArgs ¶ added in v0.0.47
type NatsReadArgs struct { // @gotags: kong:"help='NATS Subject. Ex: foo.bar.*',env='PLUMBER_RELAY_NATS_SUBJECT'" Subject string `` /* 142-byte string literal not displayed */ 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',env='PLUMBER_RELAY_NATS_STREAMING_DSN'" Dsn string `` /* 199-byte string literal not displayed */ // @gotags: kong:"help='NATS .creds file containing authentication credentials',env='PLUMBER_RELAY_NATS_STREAMING_CREDENTIALS'" UserCredentials string `` /* 222-byte string literal not displayed */ // @gotags: kong:"help='Cluster ID of the Nats server',required,env='PLUMBER_RELAY_NATS_STREAMING_CLUSTER_ID'" ClusterId string `` /* 187-byte string literal not displayed */ // @gotags: kong:"help='User specified client ID to connect with',default='plumber',env='PLUMBER_RELAY_NATS_STREAMING_CLIENT_ID'" ClientId string `` /* 203-byte string literal not displayed */ // @gotags: kong:"embed" TlsOptions *NatsStreamingTLSOptions `protobuf:"bytes,5,opt,name=tls_options,json=tlsOptions,proto3" json:"tls_options,omitempty" kong:"embed"` 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) GetTlsOptions ¶ added in v0.0.106
func (m *NatsStreamingConn) GetTlsOptions() *NatsStreamingTLSOptions
func (*NatsStreamingConn) GetUserCredentials ¶ added in v0.0.46
func (m *NatsStreamingConn) GetUserCredentials() string
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',env='PLUMBER_RELAY_NATS_STREAMING_CHANNEL'" Channel string `` /* 156-byte string literal not displayed */ // @gotags: kong:"help='Create a durable subscription with this name for the given channel',env='PLUMBER_RELAY_NATS_STREAMING_DURABLE_SUBSCRIPTION_NAME'" DurableName string `` /* 236-byte string literal not displayed */ // @gotags: kong:"help='Deliver starting with last published message',xor=nats_delivery_option,env='PLUMBER_RELAY_NATS_STREAMING_READ_LAST'" ReadLastAvailable bool `` /* 244-byte string literal not displayed */ // @gotags: kong:"help='Deliver messages starting at sequence number',xor=nats_delivery_option,env='PLUMBER_RELAY_NATS_STREAMING_READ_SEQUENCE'" ReadSequenceNumber uint32 `` /* 251-byte string literal not displayed */ // @gotags: kong:"help='Deliver messages in last interval (e.g. 1s, 1h)',xor=nats_delivery_option,env='PLUMBER_RELAY_NATS_STREAMING_READ_SINCE'" ReadSince string `` /* 221-byte string literal not displayed */ // @gotags: kong:"help='Deliver all available messages',xor=nats_delivery_option,env='PLUMBER_RELAY_NATS_STREAMING_READ_ALL'" ReadAll bool `` /* 197-byte string literal not displayed */ 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 NatsStreamingTLSOptions ¶ added in v0.0.106
type NatsStreamingTLSOptions struct { // @gotags: kong:"help='CA file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_STREAMING_TLS_CA_CERT'" TlsCaCert string `` /* 192-byte string literal not displayed */ // @gotags: kong:"help='Client cert file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_STREAMING_TLS_CLIENT_CERT'" TlsClientCert string `` /* 217-byte string literal not displayed */ // @gotags: kong:"help='Client key file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_STREAMING_TLS_CLIENT_KEY'" TlsClientKey string `` /* 212-byte string literal not displayed */ // @gotags: kong:"help='Whether to verify server certificate',env='PLUMBER_RELAY_NATS_STREAMING_SKIP_VERIFY_TLS'" TlsSkipVerify bool `` /* 205-byte string literal not displayed */ // @gotags: kong:"help='Enable TLS',env='PLUMBER_RELAY_NATS_STREAMING_USE_TLS'" UseTls bool `` /* 148-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NatsStreamingTLSOptions) Descriptor ¶ added in v0.0.106
func (*NatsStreamingTLSOptions) Descriptor() ([]byte, []int)
func (*NatsStreamingTLSOptions) GetTlsCaCert ¶ added in v0.0.114
func (m *NatsStreamingTLSOptions) GetTlsCaCert() string
func (*NatsStreamingTLSOptions) GetTlsClientCert ¶ added in v0.0.114
func (m *NatsStreamingTLSOptions) GetTlsClientCert() string
func (*NatsStreamingTLSOptions) GetTlsClientKey ¶ added in v0.0.114
func (m *NatsStreamingTLSOptions) GetTlsClientKey() string
func (*NatsStreamingTLSOptions) GetTlsSkipVerify ¶ added in v0.0.114
func (m *NatsStreamingTLSOptions) GetTlsSkipVerify() bool
func (*NatsStreamingTLSOptions) GetUseTls ¶ added in v0.0.144
func (m *NatsStreamingTLSOptions) GetUseTls() bool
func (*NatsStreamingTLSOptions) ProtoMessage ¶ added in v0.0.106
func (*NatsStreamingTLSOptions) ProtoMessage()
func (*NatsStreamingTLSOptions) Reset ¶ added in v0.0.106
func (m *NatsStreamingTLSOptions) Reset()
func (*NatsStreamingTLSOptions) String ¶ added in v0.0.106
func (m *NatsStreamingTLSOptions) String() string
func (*NatsStreamingTLSOptions) XXX_DiscardUnknown ¶ added in v0.0.106
func (m *NatsStreamingTLSOptions) XXX_DiscardUnknown()
func (*NatsStreamingTLSOptions) XXX_Marshal ¶ added in v0.0.106
func (m *NatsStreamingTLSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NatsStreamingTLSOptions) XXX_Merge ¶ added in v0.0.106
func (m *NatsStreamingTLSOptions) XXX_Merge(src proto.Message)
func (*NatsStreamingTLSOptions) XXX_Size ¶ added in v0.0.106
func (m *NatsStreamingTLSOptions) XXX_Size() int
func (*NatsStreamingTLSOptions) XXX_Unmarshal ¶ added in v0.0.106
func (m *NatsStreamingTLSOptions) 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 NatsTLSOptions ¶ added in v0.0.125
type NatsTLSOptions struct { // @gotags: kong:"help='Whether to verify server certificate',env='PLUMBER_RELAY_NATS_SKIP_VERIFY_TLS'" TlsSkipVerify bool `` /* 195-byte string literal not displayed */ // @gotags: kong:"help='CA file (only needed if addr is tls://)',env='PLUMBER_RELAY_NATS_TLS_CA_CERT'" TlsCaCert string `` /* 181-byte string literal not displayed */ // @gotags: kong:"help='Client cert file (only needed if addr is tls://)',env='PLUMBER_RELAY_NATS_TLS_CLIENT_CERT'" TlsClientCert string `` /* 206-byte string literal not displayed */ // @gotags: kong:"help='client key file (only needed if addr is tls://)',env='PLUMBER_RELAY_NATS_TLS_CLIENT_KEY'" TlsClientKey string `` /* 201-byte string literal not displayed */ // @gotags: kong:"help='Enable TLS',env='PLUMBER_RELAY_NATS_USE_TLS'" UseTls bool `` /* 138-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NatsTLSOptions) Descriptor ¶ added in v0.0.125
func (*NatsTLSOptions) Descriptor() ([]byte, []int)
func (*NatsTLSOptions) GetTlsCaCert ¶ added in v0.0.125
func (m *NatsTLSOptions) GetTlsCaCert() string
func (*NatsTLSOptions) GetTlsClientCert ¶ added in v0.0.125
func (m *NatsTLSOptions) GetTlsClientCert() string
func (*NatsTLSOptions) GetTlsClientKey ¶ added in v0.0.125
func (m *NatsTLSOptions) GetTlsClientKey() string
func (*NatsTLSOptions) GetTlsSkipVerify ¶ added in v0.0.125
func (m *NatsTLSOptions) GetTlsSkipVerify() bool
func (*NatsTLSOptions) GetUseTls ¶ added in v0.0.144
func (m *NatsTLSOptions) GetUseTls() bool
func (*NatsTLSOptions) ProtoMessage ¶ added in v0.0.125
func (*NatsTLSOptions) ProtoMessage()
func (*NatsTLSOptions) Reset ¶ added in v0.0.125
func (m *NatsTLSOptions) Reset()
func (*NatsTLSOptions) String ¶ added in v0.0.125
func (m *NatsTLSOptions) String() string
func (*NatsTLSOptions) XXX_DiscardUnknown ¶ added in v0.0.125
func (m *NatsTLSOptions) XXX_DiscardUnknown()
func (*NatsTLSOptions) XXX_Marshal ¶ added in v0.0.125
func (m *NatsTLSOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NatsTLSOptions) XXX_Merge ¶ added in v0.0.125
func (m *NatsTLSOptions) XXX_Merge(src proto.Message)
func (*NatsTLSOptions) XXX_Size ¶ added in v0.0.125
func (m *NatsTLSOptions) XXX_Size() int
func (*NatsTLSOptions) XXX_Unmarshal ¶ added in v0.0.125
func (m *NatsTLSOptions) 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_PORT',default=5432,required" Port uint32 `` /* 149-byte string literal not displayed */ // @gotags: kong:"help='Postgres username',env='PLUMBER_RELAY_CDCPOSTGRES_USERNAME',required" Username string `` /* 151-byte string literal not displayed */ // @gotags: kong:"help='Postgres server password',env='PLUMBER_RELAY_CDCPOSTGRES_PASSWORD'" Password string `` /* 149-byte string literal not displayed */ // @gotags: kong:"help='Postgres server database name',env='PLUMBER_RELAY_CDCPOSTGRES_DATABASE',required" Database string `` /* 163-byte string literal not displayed */ // @gotags: kong:"help='Enable TLS usage',env='PLUMBER_RELAY_CDCPOSTGRES_USE_TLS'" UseTls bool `` /* 151-byte string literal not displayed */ // @gotags: kong:"help='Whether to verify server certificate',env='PLUMBER_RELAY_CDCPOSTGRES_SKIP_VERIFY_TLS'" TlsSkipVerify bool `` /* 202-byte string literal not displayed */ 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) 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) GetTlsSkipVerify ¶ added in v0.0.114
func (m *PostgresConn) GetTlsSkipVerify() bool
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'" TlsSkipVerify bool `` /* 154-byte string literal not displayed */ // @gotags: kong:"help='TLS client certificate file'" TlsClientCert string `` /* 144-byte string literal not displayed */ // @gotags: kong:"help='TLS client key file'" TlsClientKey string `` /* 133-byte string literal not displayed */ // @gotags: kong:"help='Authentication token file'" Token string `protobuf:"bytes,6,opt,name=token,proto3" json:"token,omitempty" kong:"help='Authentication token file'"` // @gotags: kong:"help='Listener name'" ListenerName string `protobuf:"bytes,7,opt,name=listener_name,json=listenerName,proto3" json:"listener_name,omitempty" kong:"help='Listener name'"` 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) GetListenerName ¶ added in v0.0.176
func (m *PulsarConn) GetListenerName() string
func (*PulsarConn) GetTlsClientCert ¶ added in v0.0.46
func (m *PulsarConn) GetTlsClientCert() string
func (*PulsarConn) GetTlsClientKey ¶ added in v0.0.46
func (m *PulsarConn) GetTlsClientKey() string
func (*PulsarConn) GetTlsSkipVerify ¶ added in v0.0.114
func (m *PulsarConn) GetTlsSkipVerify() bool
func (*PulsarConn) GetToken ¶ added in v0.0.176
func (m *PulsarConn) GetToken() string
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 `` /* 267-byte string literal not displayed */ // @gotags: kong:"help='Subscription initial position (options: latest earliest)',default=latest,type=pbenum,pbenum_lowercase,pbenum_strip_prefix=PULSAR_" InitialPosition SubscriptionInitialPosition `` /* 295-byte string literal not displayed */ 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) GetInitialPosition ¶ added in v0.0.176
func (m *PulsarReadArgs) GetInitialPosition() SubscriptionInitialPosition
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'" TlsSkipVerify bool `` /* 201-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) GetTlsSkipVerify ¶ added in v0.0.114
func (m *RabbitConn) GetTlsSkipVerify() 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 */ // @gotags: kong:"help='Key=Value pair for sending additional queue argument to RabbitMQ. Example: --queue-arg x-dead-letter-exchange=mydlexchange --queue-arg x-queue-mode=lazy',env='PLUMBER_RELAY_RABBIT_QUEUE_ARGS'" QueueArg map[string]string `` /* 379-byte string literal not displayed */ // @gotags: kong:"help='Exclude messages with routing key matching regex',env='PLUMBER_RELAY_RABBIT_BINDING_KEY_EXCLUDE_REGEX'" ExcludeBindingKeyRegex string `` /* 248-byte string literal not displayed */ 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) GetExcludeBindingKeyRegex ¶ added in v0.0.172
func (m *RabbitReadArgs) GetExcludeBindingKeyRegex() string
func (*RabbitReadArgs) GetQueueArg ¶ added in v0.0.118
func (m *RabbitReadArgs) GetQueueArg() map[string]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'" TlsSkipVerify bool `` /* 154-byte string literal not displayed */ // @gotags: kong:"help='Username to authenticate to server with',default=guest" Username string `` /* 137-byte string literal not displayed */ // @gotags: kong:"help='Password used to authenticate to server with',default=guest" Password string `` /* 142-byte string literal not displayed */ // @gotags: kong:"help='Consumer or producer name to identify as to RabbitMQ',default=plumber,required" ClientName string `` /* 183-byte string literal not displayed */ 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) GetPassword ¶ added in v0.0.46
func (m *RabbitStreamsConn) GetPassword() string
func (*RabbitStreamsConn) GetTlsSkipVerify ¶ added in v0.0.114
func (m *RabbitStreamsConn) GetTlsSkipVerify() bool
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 `` /* 214-byte string literal not displayed */ // TODO: Will this break? Might just need to be a string. // @gotags: kong:"help='Offset to start reading at',embed" OffsetOptions *RabbitStreamsOffsetOptions `` /* 147-byte string literal not displayed */ 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" Channels []string `` /* 180-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) GetChannels ¶ added in v0.0.114
func (m *RedisPubSubReadArgs) GetChannels() []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" Channels []string `` /* 137-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) GetChannels ¶ added in v0.0.114
func (m *RedisPubSubWriteArgs) GetChannels() []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'" Streams []string `` /* 153-byte string literal not displayed */ // @gotags: kong:"help='Consumer group name',env='PLUMBER_RELAY_REDIS_STREAMS_CONSUMER_GROUP',default=plumber" ConsumerGroup string `` /* 199-byte string literal not displayed */ // @gotags: kong:"help='Consumer name',env='PLUMBER_RELAY_REDIS_STREAMS_CONSUMER_NAME',default=plumber-consumer-1" ConsumerName string `` /* 200-byte string literal not displayed */ // @gotags: kong:"help='Number of records to read from stream(s) per read',env='PLUMBER_RELAY_REDIS_STREAMS_COUNT',default=10" Count uint32 `` /* 179-byte string literal not displayed */ // @gotags: kong:"embed" CreateConsumerConfig *CreateConsumerConfig `` /* 136-byte string literal not displayed */ 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) GetStreams ¶ added in v0.0.114
func (m *RedisStreamsReadArgs) GetStreams() []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 SubscriptionInitialPosition ¶ added in v0.0.176
type SubscriptionInitialPosition int32
const ( SubscriptionInitialPosition_PULSAR_LATEST SubscriptionInitialPosition = 0 SubscriptionInitialPosition_PULSAR_EARLIEST SubscriptionInitialPosition = 1 )
func (SubscriptionInitialPosition) EnumDescriptor ¶ added in v0.0.176
func (SubscriptionInitialPosition) EnumDescriptor() ([]byte, []int)
func (SubscriptionInitialPosition) String ¶ added in v0.0.176
func (x SubscriptionInitialPosition) String() string
type SubscriptionType ¶ added in v0.0.46
type SubscriptionType int32
const ( SubscriptionType_SHARED SubscriptionType = 0 SubscriptionType_EXCLUSIVE SubscriptionType = 1 SubscriptionType_FAILOVER SubscriptionType = 2 SubscriptionType_KEYSHARED SubscriptionType = 3 )
func (SubscriptionType) EnumDescriptor ¶ added in v0.0.46
func (SubscriptionType) EnumDescriptor() ([]byte, []int)
func (SubscriptionType) String ¶ added in v0.0.46
func (x SubscriptionType) String() string
Source Files ¶
- ps_args_activemq.pb.go
- ps_args_aws_kinesis.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_memphis.pb.go
- ps_args_mongo.pb.go
- ps_args_mqtt.pb.go
- ps_args_nats.pb.go
- ps_args_nats_jetstream.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.