Documentation ¶
Index ¶
- Variables
- type AWSKinesisConn
- func (*AWSKinesisConn) Descriptor() ([]byte, []int)deprecated
- func (x *AWSKinesisConn) GetAwsAccessKeyId() string
- func (x *AWSKinesisConn) GetAwsProfile() string
- func (x *AWSKinesisConn) GetAwsRegion() string
- func (x *AWSKinesisConn) GetAwsSecretAccessKey() string
- func (*AWSKinesisConn) ProtoMessage()
- func (x *AWSKinesisConn) ProtoReflect() protoreflect.Message
- func (x *AWSKinesisConn) Reset()
- func (x *AWSKinesisConn) String() string
- type AWSKinesisReadArgs
- func (*AWSKinesisReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *AWSKinesisReadArgs) GetMaxRecords() int64
- func (x *AWSKinesisReadArgs) GetReadAfterSequenceNumber() string
- func (x *AWSKinesisReadArgs) GetReadFromTimestamp() int64
- func (x *AWSKinesisReadArgs) GetReadLatest() bool
- func (x *AWSKinesisReadArgs) GetReadSequenceNumber() string
- func (x *AWSKinesisReadArgs) GetReadTrimHorizon() bool
- func (x *AWSKinesisReadArgs) GetShard() string
- func (x *AWSKinesisReadArgs) GetStream() string
- func (*AWSKinesisReadArgs) ProtoMessage()
- func (x *AWSKinesisReadArgs) ProtoReflect() protoreflect.Message
- func (x *AWSKinesisReadArgs) Reset()
- func (x *AWSKinesisReadArgs) String() string
- type AWSKinesisWriteArgs
- func (*AWSKinesisWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *AWSKinesisWriteArgs) GetPartitionKey() string
- func (x *AWSKinesisWriteArgs) GetSequenceNumber() string
- func (x *AWSKinesisWriteArgs) GetStream() string
- func (*AWSKinesisWriteArgs) ProtoMessage()
- func (x *AWSKinesisWriteArgs) ProtoReflect() protoreflect.Message
- func (x *AWSKinesisWriteArgs) Reset()
- func (x *AWSKinesisWriteArgs) String() string
- type AWSSNSConn
- func (*AWSSNSConn) Descriptor() ([]byte, []int)deprecated
- func (x *AWSSNSConn) GetAwsAccessKeyId() string
- func (x *AWSSNSConn) GetAwsProfile() string
- func (x *AWSSNSConn) GetAwsRegion() string
- func (x *AWSSNSConn) GetAwsSecretAccessKey() string
- func (*AWSSNSConn) ProtoMessage()
- func (x *AWSSNSConn) ProtoReflect() protoreflect.Message
- func (x *AWSSNSConn) Reset()
- func (x *AWSSNSConn) String() string
- type AWSSNSWriteArgs
- type AWSSQSConn
- func (*AWSSQSConn) Descriptor() ([]byte, []int)deprecated
- func (x *AWSSQSConn) GetAwsAccessKeyId() string
- func (x *AWSSQSConn) GetAwsProfile() string
- func (x *AWSSQSConn) GetAwsRegion() string
- func (x *AWSSQSConn) GetAwsSecretAccessKey() string
- func (*AWSSQSConn) ProtoMessage()
- func (x *AWSSQSConn) ProtoReflect() protoreflect.Message
- func (x *AWSSQSConn) Reset()
- func (x *AWSSQSConn) String() string
- type AWSSQSReadArgs
- func (*AWSSQSReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *AWSSQSReadArgs) GetAutoDelete() bool
- func (x *AWSSQSReadArgs) GetMaxNumMessages() int64
- func (x *AWSSQSReadArgs) GetQueueName() string
- func (x *AWSSQSReadArgs) GetReceiveRequestAttemptId() string
- func (x *AWSSQSReadArgs) GetRemoteAccountId() string
- func (x *AWSSQSReadArgs) GetWaitTimeSeconds() int64
- func (*AWSSQSReadArgs) ProtoMessage()
- func (x *AWSSQSReadArgs) ProtoReflect() protoreflect.Message
- func (x *AWSSQSReadArgs) Reset()
- func (x *AWSSQSReadArgs) String() string
- type AWSSQSRelayArgs
- func (*AWSSQSRelayArgs) Descriptor() ([]byte, []int)deprecated
- func (x *AWSSQSRelayArgs) GetAutoDelete() bool
- func (x *AWSSQSRelayArgs) GetMaxNumMessages() int64
- func (x *AWSSQSRelayArgs) GetQueueName() string
- func (x *AWSSQSRelayArgs) GetReceiveRequestAttemptId() string
- func (x *AWSSQSRelayArgs) GetRemoteAccountId() string
- func (x *AWSSQSRelayArgs) GetWaitTimeSeconds() int64
- func (*AWSSQSRelayArgs) ProtoMessage()
- func (x *AWSSQSRelayArgs) ProtoReflect() protoreflect.Message
- func (x *AWSSQSRelayArgs) Reset()
- func (x *AWSSQSRelayArgs) String() string
- type AWSSQSWriteArgs
- func (*AWSSQSWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *AWSSQSWriteArgs) GetAttributes() map[string]string
- func (x *AWSSQSWriteArgs) GetDelaySeconds() int64
- func (x *AWSSQSWriteArgs) GetMessageDeduplicationId() string
- func (x *AWSSQSWriteArgs) GetMessageGroupId() string
- func (x *AWSSQSWriteArgs) GetQueueName() string
- func (x *AWSSQSWriteArgs) GetRemoteAccountId() string
- func (*AWSSQSWriteArgs) ProtoMessage()
- func (x *AWSSQSWriteArgs) ProtoReflect() protoreflect.Message
- func (x *AWSSQSWriteArgs) Reset()
- func (x *AWSSQSWriteArgs) String() string
- type ActiveMQConn
- type ActiveMQReadArgs
- func (*ActiveMQReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *ActiveMQReadArgs) GetQueue() string
- func (x *ActiveMQReadArgs) GetTopic() string
- func (*ActiveMQReadArgs) ProtoMessage()
- func (x *ActiveMQReadArgs) ProtoReflect() protoreflect.Message
- func (x *ActiveMQReadArgs) Reset()
- func (x *ActiveMQReadArgs) String() string
- type ActiveMQWriteArgs
- func (*ActiveMQWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *ActiveMQWriteArgs) GetQueue() string
- func (x *ActiveMQWriteArgs) GetTopic() string
- func (*ActiveMQWriteArgs) ProtoMessage()
- func (x *ActiveMQWriteArgs) ProtoReflect() protoreflect.Message
- func (x *ActiveMQWriteArgs) Reset()
- func (x *ActiveMQWriteArgs) String() string
- type AzureEventHubConn
- func (*AzureEventHubConn) Descriptor() ([]byte, []int)deprecated
- func (x *AzureEventHubConn) GetConnectionString() string
- func (*AzureEventHubConn) ProtoMessage()
- func (x *AzureEventHubConn) ProtoReflect() protoreflect.Message
- func (x *AzureEventHubConn) Reset()
- func (x *AzureEventHubConn) String() string
- type AzureEventHubReadArgs
- type AzureEventHubWriteArgs
- func (*AzureEventHubWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *AzureEventHubWriteArgs) GetMessageId() string
- func (x *AzureEventHubWriteArgs) GetPartitionKey() string
- func (*AzureEventHubWriteArgs) ProtoMessage()
- func (x *AzureEventHubWriteArgs) ProtoReflect() protoreflect.Message
- func (x *AzureEventHubWriteArgs) Reset()
- func (x *AzureEventHubWriteArgs) String() string
- type AzureServiceBusConn
- func (*AzureServiceBusConn) Descriptor() ([]byte, []int)deprecated
- func (x *AzureServiceBusConn) GetConnectionString() string
- func (*AzureServiceBusConn) ProtoMessage()
- func (x *AzureServiceBusConn) ProtoReflect() protoreflect.Message
- func (x *AzureServiceBusConn) Reset()
- func (x *AzureServiceBusConn) String() string
- type AzureServiceBusReadArgs
- func (*AzureServiceBusReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *AzureServiceBusReadArgs) GetQueue() string
- func (x *AzureServiceBusReadArgs) GetSubscriptionName() string
- func (x *AzureServiceBusReadArgs) GetTopic() string
- func (*AzureServiceBusReadArgs) ProtoMessage()
- func (x *AzureServiceBusReadArgs) ProtoReflect() protoreflect.Message
- func (x *AzureServiceBusReadArgs) Reset()
- func (x *AzureServiceBusReadArgs) String() string
- type AzureServiceBusWriteArgs
- func (*AzureServiceBusWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *AzureServiceBusWriteArgs) GetQueue() string
- func (x *AzureServiceBusWriteArgs) GetTopic() string
- func (*AzureServiceBusWriteArgs) ProtoMessage()
- func (x *AzureServiceBusWriteArgs) ProtoReflect() protoreflect.Message
- func (x *AzureServiceBusWriteArgs) Reset()
- func (x *AzureServiceBusWriteArgs) String() string
- type CreateConsumerConfig
- func (*CreateConsumerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *CreateConsumerConfig) GetCreateStreams() bool
- func (x *CreateConsumerConfig) GetOffsetStart() OffsetStart
- func (x *CreateConsumerConfig) GetRecreateConsumerGroup() bool
- func (*CreateConsumerConfig) ProtoMessage()
- func (x *CreateConsumerConfig) ProtoReflect() protoreflect.Message
- func (x *CreateConsumerConfig) Reset()
- func (x *CreateConsumerConfig) String() string
- type GCPPubSubConn
- func (*GCPPubSubConn) Descriptor() ([]byte, []int)deprecated
- func (x *GCPPubSubConn) GetCredentialsFile() string
- func (x *GCPPubSubConn) GetCredentialsJson() string
- func (x *GCPPubSubConn) GetProjectId() string
- func (*GCPPubSubConn) ProtoMessage()
- func (x *GCPPubSubConn) ProtoReflect() protoreflect.Message
- func (x *GCPPubSubConn) Reset()
- func (x *GCPPubSubConn) String() string
- type GCPPubSubReadArgs
- func (*GCPPubSubReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *GCPPubSubReadArgs) GetAckMessages() bool
- func (x *GCPPubSubReadArgs) GetSubscriptionId() string
- func (*GCPPubSubReadArgs) ProtoMessage()
- func (x *GCPPubSubReadArgs) ProtoReflect() protoreflect.Message
- func (x *GCPPubSubReadArgs) Reset()
- func (x *GCPPubSubReadArgs) String() string
- type GCPPubSubWriteArgs
- func (*GCPPubSubWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *GCPPubSubWriteArgs) GetTopicId() string
- func (*GCPPubSubWriteArgs) ProtoMessage()
- func (x *GCPPubSubWriteArgs) ProtoReflect() protoreflect.Message
- func (x *GCPPubSubWriteArgs) Reset()
- func (x *GCPPubSubWriteArgs) String() string
- type KafkaConn
- func (*KafkaConn) Descriptor() ([]byte, []int)deprecated
- func (x *KafkaConn) GetAddress() []string
- func (x *KafkaConn) GetSaslPassword() string
- func (x *KafkaConn) GetSaslType() SASLType
- func (x *KafkaConn) GetSaslUsername() string
- func (x *KafkaConn) GetTimeoutSeconds() int32
- func (x *KafkaConn) GetTlsSkipVerify() bool
- func (x *KafkaConn) GetUseTls() bool
- func (*KafkaConn) ProtoMessage()
- func (x *KafkaConn) ProtoReflect() protoreflect.Message
- func (x *KafkaConn) Reset()
- func (x *KafkaConn) String() string
- type KafkaReadArgs
- func (*KafkaReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *KafkaReadArgs) GetCommitIntervalSeconds() int32
- func (x *KafkaReadArgs) GetConsumerGroupName() string
- func (x *KafkaReadArgs) GetIncludeOffsetInfo() bool
- func (x *KafkaReadArgs) GetLag() bool
- func (x *KafkaReadArgs) GetLagConsumerGroup() string
- func (x *KafkaReadArgs) GetMaxBytes() int32
- func (x *KafkaReadArgs) GetMaxWaitSeconds() int32
- func (x *KafkaReadArgs) GetMinBytes() int32
- func (x *KafkaReadArgs) GetQueueCapacity() int32
- func (x *KafkaReadArgs) GetReadOffset() int64
- func (x *KafkaReadArgs) GetRebalanceTimeoutSeconds() int32
- func (x *KafkaReadArgs) GetTopics() []string
- func (x *KafkaReadArgs) GetUseConsumerGroup() bool
- func (*KafkaReadArgs) ProtoMessage()
- func (x *KafkaReadArgs) ProtoReflect() protoreflect.Message
- func (x *KafkaReadArgs) Reset()
- func (x *KafkaReadArgs) String() string
- type KafkaRelayArgs
- func (*KafkaRelayArgs) Descriptor() ([]byte, []int)deprecated
- func (x *KafkaRelayArgs) GetCommitIntervalSeconds() int32
- func (x *KafkaRelayArgs) GetConsumerGroupName() string
- func (x *KafkaRelayArgs) GetMaxBytes() int32
- func (x *KafkaRelayArgs) GetMaxWaitSeconds() int32
- func (x *KafkaRelayArgs) GetMinBytes() int32
- func (x *KafkaRelayArgs) GetQueueCapacity() int32
- func (x *KafkaRelayArgs) GetReadOffset() int64
- func (x *KafkaRelayArgs) GetRebalanceTimeoutSeconds() int32
- func (x *KafkaRelayArgs) GetTopics() []string
- func (x *KafkaRelayArgs) GetUseConsumerGroup() bool
- func (*KafkaRelayArgs) ProtoMessage()
- func (x *KafkaRelayArgs) ProtoReflect() protoreflect.Message
- func (x *KafkaRelayArgs) Reset()
- func (x *KafkaRelayArgs) String() string
- type KafkaWriteArgs
- func (*KafkaWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *KafkaWriteArgs) GetHeaders() map[string]string
- func (x *KafkaWriteArgs) GetKey() string
- func (x *KafkaWriteArgs) GetTopics() []string
- func (*KafkaWriteArgs) ProtoMessage()
- func (x *KafkaWriteArgs) ProtoReflect() protoreflect.Message
- func (x *KafkaWriteArgs) Reset()
- func (x *KafkaWriteArgs) String() string
- type KubeMQQueueConn
- func (*KubeMQQueueConn) Descriptor() ([]byte, []int)deprecated
- func (x *KubeMQQueueConn) GetAddress() string
- func (x *KubeMQQueueConn) GetAuthToken() string
- func (x *KubeMQQueueConn) GetClientId() string
- func (x *KubeMQQueueConn) GetTlsClientCert() string
- func (*KubeMQQueueConn) ProtoMessage()
- func (x *KubeMQQueueConn) ProtoReflect() protoreflect.Message
- func (x *KubeMQQueueConn) Reset()
- func (x *KubeMQQueueConn) String() string
- type KubeMQQueueReadArgs
- func (*KubeMQQueueReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *KubeMQQueueReadArgs) GetQueueName() string
- func (*KubeMQQueueReadArgs) ProtoMessage()
- func (x *KubeMQQueueReadArgs) ProtoReflect() protoreflect.Message
- func (x *KubeMQQueueReadArgs) Reset()
- func (x *KubeMQQueueReadArgs) String() string
- type KubeMQQueueWriteArgs
- func (*KubeMQQueueWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *KubeMQQueueWriteArgs) GetQueueName() string
- func (*KubeMQQueueWriteArgs) ProtoMessage()
- func (x *KubeMQQueueWriteArgs) ProtoReflect() protoreflect.Message
- func (x *KubeMQQueueWriteArgs) Reset()
- func (x *KubeMQQueueWriteArgs) String() string
- type MQTTConn
- func (*MQTTConn) Descriptor() ([]byte, []int)deprecated
- func (x *MQTTConn) GetAddress() string
- func (x *MQTTConn) GetClientId() string
- func (x *MQTTConn) GetConnTimeoutSeconds() uint32
- func (x *MQTTConn) GetQosLevel() MQTTQoSLevel
- func (x *MQTTConn) GetTlsOptions() *MQTTTLSOptions
- func (*MQTTConn) ProtoMessage()
- func (x *MQTTConn) ProtoReflect() protoreflect.Message
- func (x *MQTTConn) Reset()
- func (x *MQTTConn) String() string
- type MQTTQoSLevel
- func (MQTTQoSLevel) Descriptor() protoreflect.EnumDescriptor
- func (x MQTTQoSLevel) Enum() *MQTTQoSLevel
- func (MQTTQoSLevel) EnumDescriptor() ([]byte, []int)deprecated
- func (x MQTTQoSLevel) Number() protoreflect.EnumNumber
- func (x MQTTQoSLevel) String() string
- func (MQTTQoSLevel) Type() protoreflect.EnumType
- type MQTTReadArgs
- func (*MQTTReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *MQTTReadArgs) GetReadTimeoutSeconds() uint32
- func (x *MQTTReadArgs) GetTopic() string
- func (*MQTTReadArgs) ProtoMessage()
- func (x *MQTTReadArgs) ProtoReflect() protoreflect.Message
- func (x *MQTTReadArgs) Reset()
- func (x *MQTTReadArgs) String() string
- type MQTTTLSOptions
- func (*MQTTTLSOptions) Descriptor() ([]byte, []int)deprecated
- func (x *MQTTTLSOptions) GetTlsCaCert() string
- func (x *MQTTTLSOptions) GetTlsClientCert() string
- func (x *MQTTTLSOptions) GetTlsClientKey() string
- func (x *MQTTTLSOptions) GetTlsSkipVerify() bool
- func (*MQTTTLSOptions) ProtoMessage()
- func (x *MQTTTLSOptions) ProtoReflect() protoreflect.Message
- func (x *MQTTTLSOptions) Reset()
- func (x *MQTTTLSOptions) String() string
- type MQTTWriteArgs
- func (*MQTTWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *MQTTWriteArgs) GetTopic() string
- func (x *MQTTWriteArgs) GetWriteTimeoutSeconds() uint32
- func (*MQTTWriteArgs) ProtoMessage()
- func (x *MQTTWriteArgs) ProtoReflect() protoreflect.Message
- func (x *MQTTWriteArgs) Reset()
- func (x *MQTTWriteArgs) String() string
- type MemphisConn
- func (*MemphisConn) Descriptor() ([]byte, []int)deprecated
- func (x *MemphisConn) GetAddress() string
- func (x *MemphisConn) GetBrokerToken() string
- func (x *MemphisConn) GetUsername() string
- func (*MemphisConn) ProtoMessage()
- func (x *MemphisConn) ProtoReflect() protoreflect.Message
- func (x *MemphisConn) Reset()
- func (x *MemphisConn) String() string
- type MemphisReadArgs
- func (*MemphisReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *MemphisReadArgs) GetConsumerGroup() string
- func (x *MemphisReadArgs) GetConsumerName() string
- func (x *MemphisReadArgs) GetStation() string
- func (*MemphisReadArgs) ProtoMessage()
- func (x *MemphisReadArgs) ProtoReflect() protoreflect.Message
- func (x *MemphisReadArgs) Reset()
- func (x *MemphisReadArgs) String() string
- type MemphisWriteArgs
- func (*MemphisWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *MemphisWriteArgs) GetHeaders() map[string]string
- func (x *MemphisWriteArgs) GetMessageId() string
- func (x *MemphisWriteArgs) GetProducerName() string
- func (x *MemphisWriteArgs) GetStation() string
- func (*MemphisWriteArgs) ProtoMessage()
- func (x *MemphisWriteArgs) ProtoReflect() protoreflect.Message
- func (x *MemphisWriteArgs) Reset()
- func (x *MemphisWriteArgs) String() string
- type MongoConn
- type MongoReadArgs
- func (*MongoReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *MongoReadArgs) GetCollection() string
- func (x *MongoReadArgs) GetDatabase() string
- func (x *MongoReadArgs) GetIncludeFullDocument() bool
- func (*MongoReadArgs) ProtoMessage()
- func (x *MongoReadArgs) ProtoReflect() protoreflect.Message
- func (x *MongoReadArgs) Reset()
- func (x *MongoReadArgs) String() string
- type NSQConn
- func (*NSQConn) Descriptor() ([]byte, []int)deprecated
- func (x *NSQConn) GetAuthSecret() string
- func (x *NSQConn) GetClientId() string
- func (x *NSQConn) GetLookupdAddress() string
- func (x *NSQConn) GetNsqdAddress() string
- func (x *NSQConn) GetTlsCaCert() string
- func (x *NSQConn) GetTlsClientCert() string
- func (x *NSQConn) GetTlsClientKey() string
- func (x *NSQConn) GetTlsSkipVerify() bool
- func (x *NSQConn) GetUseTls() bool
- func (*NSQConn) ProtoMessage()
- func (x *NSQConn) ProtoReflect() protoreflect.Message
- func (x *NSQConn) Reset()
- func (x *NSQConn) String() string
- type NSQReadArgs
- func (*NSQReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *NSQReadArgs) GetChannel() string
- func (x *NSQReadArgs) GetTopic() string
- func (*NSQReadArgs) ProtoMessage()
- func (x *NSQReadArgs) ProtoReflect() protoreflect.Message
- func (x *NSQReadArgs) Reset()
- func (x *NSQReadArgs) String() string
- type NSQWriteArgs
- type NatsConn
- func (*NatsConn) Descriptor() ([]byte, []int)deprecated
- func (x *NatsConn) GetDsn() string
- func (x *NatsConn) GetNkey() string
- func (x *NatsConn) GetTlsOptions() *NatsTLSOptions
- func (x *NatsConn) GetUserCredentials() string
- func (*NatsConn) ProtoMessage()
- func (x *NatsConn) ProtoReflect() protoreflect.Message
- func (x *NatsConn) Reset()
- func (x *NatsConn) String() string
- type NatsJetstreamConn
- func (*NatsJetstreamConn) Descriptor() ([]byte, []int)deprecated
- func (x *NatsJetstreamConn) GetClientId() string
- func (x *NatsJetstreamConn) GetDsn() string
- func (x *NatsJetstreamConn) GetNkey() string
- func (x *NatsJetstreamConn) GetTlsOptions() *NatsJetstreamTLSOptions
- func (x *NatsJetstreamConn) GetUserCredentials() string
- func (*NatsJetstreamConn) ProtoMessage()
- func (x *NatsJetstreamConn) ProtoReflect() protoreflect.Message
- func (x *NatsJetstreamConn) Reset()
- func (x *NatsJetstreamConn) String() string
- type NatsJetstreamReadArgs
- func (*NatsJetstreamReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *NatsJetstreamReadArgs) GetConsumerFilterSubject() string
- func (x *NatsJetstreamReadArgs) GetConsumerName() string
- func (x *NatsJetstreamReadArgs) GetConsumerStartSequence() int64
- func (x *NatsJetstreamReadArgs) GetConsumerStartTime() string
- func (x *NatsJetstreamReadArgs) GetCreateDurableConsumer() bool
- func (x *NatsJetstreamReadArgs) GetExistingDurableConsumer() bool
- func (x *NatsJetstreamReadArgs) GetKeepConsumer() bool
- func (x *NatsJetstreamReadArgs) GetStream() string
- func (*NatsJetstreamReadArgs) ProtoMessage()
- func (x *NatsJetstreamReadArgs) ProtoReflect() protoreflect.Message
- func (x *NatsJetstreamReadArgs) Reset()
- func (x *NatsJetstreamReadArgs) String() string
- type NatsJetstreamTLSOptions
- func (*NatsJetstreamTLSOptions) Descriptor() ([]byte, []int)deprecated
- func (x *NatsJetstreamTLSOptions) GetTlsCaCert() string
- func (x *NatsJetstreamTLSOptions) GetTlsClientCert() string
- func (x *NatsJetstreamTLSOptions) GetTlsClientKey() string
- func (x *NatsJetstreamTLSOptions) GetTlsSkipVerify() bool
- func (x *NatsJetstreamTLSOptions) GetUseTls() bool
- func (*NatsJetstreamTLSOptions) ProtoMessage()
- func (x *NatsJetstreamTLSOptions) ProtoReflect() protoreflect.Message
- func (x *NatsJetstreamTLSOptions) Reset()
- func (x *NatsJetstreamTLSOptions) String() string
- type NatsJetstreamWriteArgs
- func (*NatsJetstreamWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *NatsJetstreamWriteArgs) GetSubject() string
- func (*NatsJetstreamWriteArgs) ProtoMessage()
- func (x *NatsJetstreamWriteArgs) ProtoReflect() protoreflect.Message
- func (x *NatsJetstreamWriteArgs) Reset()
- func (x *NatsJetstreamWriteArgs) String() string
- type NatsReadArgs
- type NatsStreamingConn
- func (*NatsStreamingConn) Descriptor() ([]byte, []int)deprecated
- func (x *NatsStreamingConn) GetClientId() string
- func (x *NatsStreamingConn) GetClusterId() string
- func (x *NatsStreamingConn) GetDsn() string
- func (x *NatsStreamingConn) GetTlsOptions() *NatsStreamingTLSOptions
- func (x *NatsStreamingConn) GetUserCredentials() string
- func (*NatsStreamingConn) ProtoMessage()
- func (x *NatsStreamingConn) ProtoReflect() protoreflect.Message
- func (x *NatsStreamingConn) Reset()
- func (x *NatsStreamingConn) String() string
- type NatsStreamingReadArgs
- func (*NatsStreamingReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *NatsStreamingReadArgs) GetChannel() string
- func (x *NatsStreamingReadArgs) GetDurableName() string
- func (x *NatsStreamingReadArgs) GetReadAll() bool
- func (x *NatsStreamingReadArgs) GetReadLastAvailable() bool
- func (x *NatsStreamingReadArgs) GetReadSequenceNumber() uint32
- func (x *NatsStreamingReadArgs) GetReadSince() string
- func (*NatsStreamingReadArgs) ProtoMessage()
- func (x *NatsStreamingReadArgs) ProtoReflect() protoreflect.Message
- func (x *NatsStreamingReadArgs) Reset()
- func (x *NatsStreamingReadArgs) String() string
- type NatsStreamingTLSOptions
- func (*NatsStreamingTLSOptions) Descriptor() ([]byte, []int)deprecated
- func (x *NatsStreamingTLSOptions) GetTlsCaCert() string
- func (x *NatsStreamingTLSOptions) GetTlsClientCert() string
- func (x *NatsStreamingTLSOptions) GetTlsClientKey() string
- func (x *NatsStreamingTLSOptions) GetTlsSkipVerify() bool
- func (x *NatsStreamingTLSOptions) GetUseTls() bool
- func (*NatsStreamingTLSOptions) ProtoMessage()
- func (x *NatsStreamingTLSOptions) ProtoReflect() protoreflect.Message
- func (x *NatsStreamingTLSOptions) Reset()
- func (x *NatsStreamingTLSOptions) String() string
- type NatsStreamingWriteArgs
- func (*NatsStreamingWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *NatsStreamingWriteArgs) GetChannel() string
- func (*NatsStreamingWriteArgs) ProtoMessage()
- func (x *NatsStreamingWriteArgs) ProtoReflect() protoreflect.Message
- func (x *NatsStreamingWriteArgs) Reset()
- func (x *NatsStreamingWriteArgs) String() string
- type NatsTLSOptions
- func (*NatsTLSOptions) Descriptor() ([]byte, []int)deprecated
- func (x *NatsTLSOptions) GetTlsCaCert() string
- func (x *NatsTLSOptions) GetTlsClientCert() string
- func (x *NatsTLSOptions) GetTlsClientKey() string
- func (x *NatsTLSOptions) GetTlsSkipVerify() bool
- func (x *NatsTLSOptions) GetUseTls() bool
- func (*NatsTLSOptions) ProtoMessage()
- func (x *NatsTLSOptions) ProtoReflect() protoreflect.Message
- func (x *NatsTLSOptions) Reset()
- func (x *NatsTLSOptions) String() string
- type NatsWriteArgs
- type OffsetStart
- func (OffsetStart) Descriptor() protoreflect.EnumDescriptor
- func (x OffsetStart) Enum() *OffsetStart
- func (OffsetStart) EnumDescriptor() ([]byte, []int)deprecated
- func (x OffsetStart) Number() protoreflect.EnumNumber
- func (x OffsetStart) String() string
- func (OffsetStart) Type() protoreflect.EnumType
- type PostgresConn
- func (*PostgresConn) Descriptor() ([]byte, []int)deprecated
- func (x *PostgresConn) GetAddress() string
- func (x *PostgresConn) GetDatabase() string
- func (x *PostgresConn) GetPassword() string
- func (x *PostgresConn) GetPort() uint32
- func (x *PostgresConn) GetTlsSkipVerify() bool
- func (x *PostgresConn) GetUseTls() bool
- func (x *PostgresConn) GetUsername() string
- func (*PostgresConn) ProtoMessage()
- func (x *PostgresConn) ProtoReflect() protoreflect.Message
- func (x *PostgresConn) Reset()
- func (x *PostgresConn) String() string
- type PostgresReadArgs
- func (*PostgresReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *PostgresReadArgs) GetPublisherName() string
- func (x *PostgresReadArgs) GetReplicationSlotName() string
- func (*PostgresReadArgs) ProtoMessage()
- func (x *PostgresReadArgs) ProtoReflect() protoreflect.Message
- func (x *PostgresReadArgs) Reset()
- func (x *PostgresReadArgs) String() string
- type PulsarConn
- func (*PulsarConn) Descriptor() ([]byte, []int)deprecated
- func (x *PulsarConn) GetConnectTimeoutSeconds() uint32
- func (x *PulsarConn) GetDsn() string
- func (x *PulsarConn) GetListenerName() string
- func (x *PulsarConn) GetTlsClientCert() string
- func (x *PulsarConn) GetTlsClientKey() string
- func (x *PulsarConn) GetTlsSkipVerify() bool
- func (x *PulsarConn) GetToken() string
- func (*PulsarConn) ProtoMessage()
- func (x *PulsarConn) ProtoReflect() protoreflect.Message
- func (x *PulsarConn) Reset()
- func (x *PulsarConn) String() string
- type PulsarReadArgs
- func (*PulsarReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *PulsarReadArgs) GetInitialPosition() SubscriptionInitialPosition
- func (x *PulsarReadArgs) GetSubscriptionName() string
- func (x *PulsarReadArgs) GetSubscriptionType() SubscriptionType
- func (x *PulsarReadArgs) GetTopic() string
- func (*PulsarReadArgs) ProtoMessage()
- func (x *PulsarReadArgs) ProtoReflect() protoreflect.Message
- func (x *PulsarReadArgs) Reset()
- func (x *PulsarReadArgs) String() string
- type PulsarWriteArgs
- type RabbitConn
- func (*RabbitConn) Descriptor() ([]byte, []int)deprecated
- func (x *RabbitConn) GetAddress() string
- func (x *RabbitConn) GetTlsSkipVerify() bool
- func (x *RabbitConn) GetUseTls() bool
- func (*RabbitConn) ProtoMessage()
- func (x *RabbitConn) ProtoReflect() protoreflect.Message
- func (x *RabbitConn) Reset()
- func (x *RabbitConn) String() string
- type RabbitReadArgs
- func (*RabbitReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *RabbitReadArgs) GetAutoAck() bool
- func (x *RabbitReadArgs) GetBindingKey() string
- func (x *RabbitReadArgs) GetConsumerTag() string
- func (x *RabbitReadArgs) GetExchangeName() string
- func (x *RabbitReadArgs) GetExcludeBindingKeyRegex() string
- func (x *RabbitReadArgs) GetQueueArg() map[string]string
- func (x *RabbitReadArgs) GetQueueDeclare() bool
- func (x *RabbitReadArgs) GetQueueDelete() bool
- func (x *RabbitReadArgs) GetQueueDurable() bool
- func (x *RabbitReadArgs) GetQueueExclusive() bool
- func (x *RabbitReadArgs) GetQueueName() string
- func (*RabbitReadArgs) ProtoMessage()
- func (x *RabbitReadArgs) ProtoReflect() protoreflect.Message
- func (x *RabbitReadArgs) Reset()
- func (x *RabbitReadArgs) String() string
- type RabbitStreamsConn
- func (*RabbitStreamsConn) Descriptor() ([]byte, []int)deprecated
- func (x *RabbitStreamsConn) GetClientName() string
- func (x *RabbitStreamsConn) GetDsn() string
- func (x *RabbitStreamsConn) GetPassword() string
- func (x *RabbitStreamsConn) GetTlsSkipVerify() bool
- func (x *RabbitStreamsConn) GetUseTls() bool
- func (x *RabbitStreamsConn) GetUsername() string
- func (*RabbitStreamsConn) ProtoMessage()
- func (x *RabbitStreamsConn) ProtoReflect() protoreflect.Message
- func (x *RabbitStreamsConn) Reset()
- func (x *RabbitStreamsConn) String() string
- type RabbitStreamsOffsetOptions
- func (*RabbitStreamsOffsetOptions) Descriptor() ([]byte, []int)deprecated
- func (x *RabbitStreamsOffsetOptions) GetFirstOffset() bool
- func (x *RabbitStreamsOffsetOptions) GetLastConsumed() bool
- func (x *RabbitStreamsOffsetOptions) GetLastOffset() bool
- func (x *RabbitStreamsOffsetOptions) GetNextOffset() bool
- func (x *RabbitStreamsOffsetOptions) GetSpecificOffset() int64
- func (*RabbitStreamsOffsetOptions) ProtoMessage()
- func (x *RabbitStreamsOffsetOptions) ProtoReflect() protoreflect.Message
- func (x *RabbitStreamsOffsetOptions) Reset()
- func (x *RabbitStreamsOffsetOptions) String() string
- type RabbitStreamsReadArgs
- func (*RabbitStreamsReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *RabbitStreamsReadArgs) GetDeclareStream() bool
- func (x *RabbitStreamsReadArgs) GetDeclareStreamSize() string
- func (x *RabbitStreamsReadArgs) GetOffsetOptions() *RabbitStreamsOffsetOptions
- func (x *RabbitStreamsReadArgs) GetStream() string
- func (*RabbitStreamsReadArgs) ProtoMessage()
- func (x *RabbitStreamsReadArgs) ProtoReflect() protoreflect.Message
- func (x *RabbitStreamsReadArgs) Reset()
- func (x *RabbitStreamsReadArgs) String() string
- type RabbitStreamsWriteArgs
- func (*RabbitStreamsWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *RabbitStreamsWriteArgs) GetDeclareStream() bool
- func (x *RabbitStreamsWriteArgs) GetDeclareStreamSize() string
- func (x *RabbitStreamsWriteArgs) GetStream() string
- func (*RabbitStreamsWriteArgs) ProtoMessage()
- func (x *RabbitStreamsWriteArgs) ProtoReflect() protoreflect.Message
- func (x *RabbitStreamsWriteArgs) Reset()
- func (x *RabbitStreamsWriteArgs) String() string
- type RabbitWriteArgs
- func (*RabbitWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *RabbitWriteArgs) GetAppId() string
- func (x *RabbitWriteArgs) GetExchangeAutoDelete() bool
- func (x *RabbitWriteArgs) GetExchangeDeclare() bool
- func (x *RabbitWriteArgs) GetExchangeDurable() bool
- func (x *RabbitWriteArgs) GetExchangeName() string
- func (x *RabbitWriteArgs) GetExchangeType() string
- func (x *RabbitWriteArgs) GetRoutingKey() string
- func (*RabbitWriteArgs) ProtoMessage()
- func (x *RabbitWriteArgs) ProtoReflect() protoreflect.Message
- func (x *RabbitWriteArgs) Reset()
- func (x *RabbitWriteArgs) String() string
- type RedisPubSubConn
- func (*RedisPubSubConn) Descriptor() ([]byte, []int)deprecated
- func (x *RedisPubSubConn) GetAddress() string
- func (x *RedisPubSubConn) GetDatabase() uint32
- func (x *RedisPubSubConn) GetPassword() string
- func (x *RedisPubSubConn) GetUsername() string
- func (*RedisPubSubConn) ProtoMessage()
- func (x *RedisPubSubConn) ProtoReflect() protoreflect.Message
- func (x *RedisPubSubConn) Reset()
- func (x *RedisPubSubConn) String() string
- type RedisPubSubReadArgs
- func (*RedisPubSubReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *RedisPubSubReadArgs) GetChannels() []string
- func (*RedisPubSubReadArgs) ProtoMessage()
- func (x *RedisPubSubReadArgs) ProtoReflect() protoreflect.Message
- func (x *RedisPubSubReadArgs) Reset()
- func (x *RedisPubSubReadArgs) String() string
- type RedisPubSubWriteArgs
- func (*RedisPubSubWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *RedisPubSubWriteArgs) GetChannels() []string
- func (*RedisPubSubWriteArgs) ProtoMessage()
- func (x *RedisPubSubWriteArgs) ProtoReflect() protoreflect.Message
- func (x *RedisPubSubWriteArgs) Reset()
- func (x *RedisPubSubWriteArgs) String() string
- type RedisStreamsConn
- func (*RedisStreamsConn) Descriptor() ([]byte, []int)deprecated
- func (x *RedisStreamsConn) GetAddress() string
- func (x *RedisStreamsConn) GetDatabase() uint32
- func (x *RedisStreamsConn) GetPassword() string
- func (x *RedisStreamsConn) GetUsername() string
- func (*RedisStreamsConn) ProtoMessage()
- func (x *RedisStreamsConn) ProtoReflect() protoreflect.Message
- func (x *RedisStreamsConn) Reset()
- func (x *RedisStreamsConn) String() string
- type RedisStreamsReadArgs
- func (*RedisStreamsReadArgs) Descriptor() ([]byte, []int)deprecated
- func (x *RedisStreamsReadArgs) GetConsumerGroup() string
- func (x *RedisStreamsReadArgs) GetConsumerName() string
- func (x *RedisStreamsReadArgs) GetCount() uint32
- func (x *RedisStreamsReadArgs) GetCreateConsumerConfig() *CreateConsumerConfig
- func (x *RedisStreamsReadArgs) GetStreams() []string
- func (*RedisStreamsReadArgs) ProtoMessage()
- func (x *RedisStreamsReadArgs) ProtoReflect() protoreflect.Message
- func (x *RedisStreamsReadArgs) Reset()
- func (x *RedisStreamsReadArgs) String() string
- type RedisStreamsWriteArgs
- func (*RedisStreamsWriteArgs) Descriptor() ([]byte, []int)deprecated
- func (x *RedisStreamsWriteArgs) GetKey() string
- func (x *RedisStreamsWriteArgs) GetStreams() []string
- func (x *RedisStreamsWriteArgs) GetWriteId() string
- func (*RedisStreamsWriteArgs) ProtoMessage()
- func (x *RedisStreamsWriteArgs) ProtoReflect() protoreflect.Message
- func (x *RedisStreamsWriteArgs) Reset()
- func (x *RedisStreamsWriteArgs) String() string
- type SASLType
- type SubscriptionInitialPosition
- func (SubscriptionInitialPosition) Descriptor() protoreflect.EnumDescriptor
- func (x SubscriptionInitialPosition) Enum() *SubscriptionInitialPosition
- func (SubscriptionInitialPosition) EnumDescriptor() ([]byte, []int)deprecated
- func (x SubscriptionInitialPosition) Number() protoreflect.EnumNumber
- func (x SubscriptionInitialPosition) String() string
- func (SubscriptionInitialPosition) Type() protoreflect.EnumType
- type SubscriptionType
- func (SubscriptionType) Descriptor() protoreflect.EnumDescriptor
- func (x SubscriptionType) Enum() *SubscriptionType
- func (SubscriptionType) EnumDescriptor() ([]byte, []int)deprecated
- func (x SubscriptionType) Number() protoreflect.EnumNumber
- func (x SubscriptionType) String() string
- func (SubscriptionType) Type() protoreflect.EnumType
Constants ¶
This section is empty.
Variables ¶
var ( SASLType_name = map[int32]string{ 0: "NONE", 1: "PLAIN", 2: "SCRAM", } SASLType_value = map[string]int32{ "NONE": 0, "PLAIN": 1, "SCRAM": 2, } )
Enum value maps for SASLType.
var ( MQTTQoSLevel_name = map[int32]string{ 0: "MQTT_QOS_LEVEL_AT_MOST_ONCE", 1: "MQTT_QOS_LEVEL_AT_LEAST_ONCE", 2: "MQTT_QOS_LEVEL_EXACTLY_ONCE", } MQTTQoSLevel_value = map[string]int32{ "MQTT_QOS_LEVEL_AT_MOST_ONCE": 0, "MQTT_QOS_LEVEL_AT_LEAST_ONCE": 1, "MQTT_QOS_LEVEL_EXACTLY_ONCE": 2, } )
Enum value maps for MQTTQoSLevel.
var ( SubscriptionType_name = map[int32]string{ 0: "SHARED", 1: "EXCLUSIVE", 2: "FAILOVER", 3: "KEYSHARED", } SubscriptionType_value = map[string]int32{ "SHARED": 0, "EXCLUSIVE": 1, "FAILOVER": 2, "KEYSHARED": 3, } )
Enum value maps for SubscriptionType.
var ( SubscriptionInitialPosition_name = map[int32]string{ 0: "PULSAR_LATEST", 1: "PULSAR_EARLIEST", } SubscriptionInitialPosition_value = map[string]int32{ "PULSAR_LATEST": 0, "PULSAR_EARLIEST": 1, } )
Enum value maps for SubscriptionInitialPosition.
var ( OffsetStart_name = map[int32]string{ 0: "LATEST", 1: "OLDEST", } OffsetStart_value = map[string]int32{ "LATEST": 0, "OLDEST": 1, } )
Enum value maps for OffsetStart.
var File_ps_args_activemq_proto protoreflect.FileDescriptor
var File_ps_args_aws_kinesis_proto protoreflect.FileDescriptor
var File_ps_args_aws_sns_proto protoreflect.FileDescriptor
var File_ps_args_aws_sqs_proto protoreflect.FileDescriptor
var File_ps_args_azure_event_hub_proto protoreflect.FileDescriptor
var File_ps_args_azure_service_bus_proto protoreflect.FileDescriptor
var File_ps_args_gcp_pubsub_proto protoreflect.FileDescriptor
var File_ps_args_kafka_proto protoreflect.FileDescriptor
var File_ps_args_kubemq_queue_proto protoreflect.FileDescriptor
var File_ps_args_memphis_proto protoreflect.FileDescriptor
var File_ps_args_mongo_proto protoreflect.FileDescriptor
var File_ps_args_mqtt_proto protoreflect.FileDescriptor
var File_ps_args_nats_jetstream_proto protoreflect.FileDescriptor
var File_ps_args_nats_proto protoreflect.FileDescriptor
var File_ps_args_nats_streaming_proto protoreflect.FileDescriptor
var File_ps_args_nsq_proto protoreflect.FileDescriptor
var File_ps_args_postgres_proto protoreflect.FileDescriptor
var File_ps_args_pulsar_proto protoreflect.FileDescriptor
var File_ps_args_rabbit_proto protoreflect.FileDescriptor
var File_ps_args_rabbit_streams_proto protoreflect.FileDescriptor
var File_ps_args_redis_pubsub_proto protoreflect.FileDescriptor
var File_ps_args_redis_streams_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AWSKinesisConn ¶ added in v0.0.121
type AWSKinesisConn struct { // @gotags: kong:"env=AWS_DEFAULT_REGION,hidden" AwsRegion string `protobuf:"bytes,1,opt,name=aws_region,json=awsRegion,proto3" json:"aws_region,omitempty" kong:"env=AWS_DEFAULT_REGION,hidden"` // @gotags: kong:"env=AWS_ACCESS_KEY_ID,hidden" AwsAccessKeyId string `` /* 143-byte string literal not displayed */ // @gotags: kong:"env=AWS_SECRET_ACCESS_KEY,hidden" AwsSecretAccessKey string `` /* 159-byte string literal not displayed */ // @gotags: kong:"env=AWS_PROFILE,hidden" AwsProfile string `protobuf:"bytes,4,opt,name=aws_profile,json=awsProfile,proto3" json:"aws_profile,omitempty" kong:"env=AWS_PROFILE,hidden"` // contains filtered or unexported fields }
func (*AWSKinesisConn) Descriptor
deprecated
added in
v0.0.121
func (*AWSKinesisConn) Descriptor() ([]byte, []int)
Deprecated: Use AWSKinesisConn.ProtoReflect.Descriptor instead.
func (*AWSKinesisConn) GetAwsAccessKeyId ¶ added in v0.0.121
func (x *AWSKinesisConn) GetAwsAccessKeyId() string
func (*AWSKinesisConn) GetAwsProfile ¶ added in v0.0.123
func (x *AWSKinesisConn) GetAwsProfile() string
func (*AWSKinesisConn) GetAwsRegion ¶ added in v0.0.121
func (x *AWSKinesisConn) GetAwsRegion() string
func (*AWSKinesisConn) GetAwsSecretAccessKey ¶ added in v0.0.121
func (x *AWSKinesisConn) GetAwsSecretAccessKey() string
func (*AWSKinesisConn) ProtoMessage ¶ added in v0.0.121
func (*AWSKinesisConn) ProtoMessage()
func (*AWSKinesisConn) ProtoReflect ¶ added in v0.0.181
func (x *AWSKinesisConn) ProtoReflect() protoreflect.Message
func (*AWSKinesisConn) Reset ¶ added in v0.0.121
func (x *AWSKinesisConn) Reset()
func (*AWSKinesisConn) String ¶ added in v0.0.121
func (x *AWSKinesisConn) String() string
type AWSKinesisReadArgs ¶ added in v0.0.121
type AWSKinesisReadArgs struct { // @gotags: kong:"help='Stream Name',required" Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty" kong:"help='Stream Name',required"` // @gotags: kong:"help='Shard ID. If empty, will read from all shards'" Shard string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty" kong:"help='Shard ID. If empty, will read from all shards'"` // @gotags: kong:"help='Maximum number of records to read from kinesis',default=1" MaxRecords int64 `` /* 163-byte string literal not displayed */ // @gotags: kong:"help='Deliver starting at this timestamp',xor=kinesis_delivery_option" ReadFromTimestamp int64 `` /* 192-byte string literal not displayed */ // @gotags: kong:"help='Deliver messages starting at sequence number',xor=kinesis_delivery_option" ReadSequenceNumber string `` /* 204-byte string literal not displayed */ // @gotags: kong:"help='Deliver messages starting after this sequence number',xor=kinesis_delivery_option" ReadAfterSequenceNumber string `` /* 229-byte string literal not displayed */ // @gotags: kong:"help='Deliver messages starting at the last untrimmed record in the shard in the system, which is the oldest data record in the shard.',xor=kinesis_delivery_option" ReadTrimHorizon bool `` /* 280-byte string literal not displayed */ // @gotags: kong:"help='Deliver messages after the most recent record',xor=kinesis_delivery_option" ReadLatest bool `` /* 180-byte string literal not displayed */ // contains filtered or unexported fields }
func (*AWSKinesisReadArgs) Descriptor
deprecated
added in
v0.0.121
func (*AWSKinesisReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use AWSKinesisReadArgs.ProtoReflect.Descriptor instead.
func (*AWSKinesisReadArgs) GetMaxRecords ¶ added in v0.0.121
func (x *AWSKinesisReadArgs) GetMaxRecords() int64
func (*AWSKinesisReadArgs) GetReadAfterSequenceNumber ¶ added in v0.0.121
func (x *AWSKinesisReadArgs) GetReadAfterSequenceNumber() string
func (*AWSKinesisReadArgs) GetReadFromTimestamp ¶ added in v0.0.121
func (x *AWSKinesisReadArgs) GetReadFromTimestamp() int64
func (*AWSKinesisReadArgs) GetReadLatest ¶ added in v0.0.121
func (x *AWSKinesisReadArgs) GetReadLatest() bool
func (*AWSKinesisReadArgs) GetReadSequenceNumber ¶ added in v0.0.121
func (x *AWSKinesisReadArgs) GetReadSequenceNumber() string
func (*AWSKinesisReadArgs) GetReadTrimHorizon ¶ added in v0.0.121
func (x *AWSKinesisReadArgs) GetReadTrimHorizon() bool
func (*AWSKinesisReadArgs) GetShard ¶ added in v0.0.121
func (x *AWSKinesisReadArgs) GetShard() string
func (*AWSKinesisReadArgs) GetStream ¶ added in v0.0.121
func (x *AWSKinesisReadArgs) GetStream() string
func (*AWSKinesisReadArgs) ProtoMessage ¶ added in v0.0.121
func (*AWSKinesisReadArgs) ProtoMessage()
func (*AWSKinesisReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *AWSKinesisReadArgs) ProtoReflect() protoreflect.Message
func (*AWSKinesisReadArgs) Reset ¶ added in v0.0.121
func (x *AWSKinesisReadArgs) Reset()
func (*AWSKinesisReadArgs) String ¶ added in v0.0.121
func (x *AWSKinesisReadArgs) String() string
type AWSKinesisWriteArgs ¶ added in v0.0.121
type AWSKinesisWriteArgs struct { // @gotags: kong:"help='Stream Name',required" Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty" kong:"help='Stream Name',required"` // @gotags: kong:"help='Partition Key',required" PartitionKey string `` /* 134-byte string literal not displayed */ // @gotags: kong:"help='Sequence number for ordering'" SequenceNumber string `` /* 146-byte string literal not displayed */ // contains filtered or unexported fields }
func (*AWSKinesisWriteArgs) Descriptor
deprecated
added in
v0.0.121
func (*AWSKinesisWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use AWSKinesisWriteArgs.ProtoReflect.Descriptor instead.
func (*AWSKinesisWriteArgs) GetPartitionKey ¶ added in v0.0.121
func (x *AWSKinesisWriteArgs) GetPartitionKey() string
func (*AWSKinesisWriteArgs) GetSequenceNumber ¶ added in v0.0.121
func (x *AWSKinesisWriteArgs) GetSequenceNumber() string
func (*AWSKinesisWriteArgs) GetStream ¶ added in v0.0.121
func (x *AWSKinesisWriteArgs) GetStream() string
func (*AWSKinesisWriteArgs) ProtoMessage ¶ added in v0.0.121
func (*AWSKinesisWriteArgs) ProtoMessage()
func (*AWSKinesisWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *AWSKinesisWriteArgs) ProtoReflect() protoreflect.Message
func (*AWSKinesisWriteArgs) Reset ¶ added in v0.0.121
func (x *AWSKinesisWriteArgs) Reset()
func (*AWSKinesisWriteArgs) String ¶ added in v0.0.121
func (x *AWSKinesisWriteArgs) String() string
type AWSSNSConn ¶ added in v0.0.46
type AWSSNSConn struct { // @gotags: kong:"env=AWS_DEFAULT_REGION,hidden" AwsRegion string `protobuf:"bytes,1,opt,name=aws_region,json=awsRegion,proto3" json:"aws_region,omitempty" kong:"env=AWS_DEFAULT_REGION,hidden"` // @gotags: kong:"env=AWS_ACCESS_KEY_ID,hidden" AwsAccessKeyId string `` /* 143-byte string literal not displayed */ // @gotags: kong:"env=AWS_SECRET_ACCESS_KEY,hidden" AwsSecretAccessKey string `` /* 159-byte string literal not displayed */ // @gotags: kong:"env=AWS_PROFILE,hidden" AwsProfile string `protobuf:"bytes,4,opt,name=aws_profile,json=awsProfile,proto3" json:"aws_profile,omitempty" kong:"env=AWS_PROFILE,hidden"` // contains filtered or unexported fields }
func (*AWSSNSConn) Descriptor
deprecated
added in
v0.0.46
func (*AWSSNSConn) Descriptor() ([]byte, []int)
Deprecated: Use AWSSNSConn.ProtoReflect.Descriptor instead.
func (*AWSSNSConn) GetAwsAccessKeyId ¶ added in v0.0.46
func (x *AWSSNSConn) GetAwsAccessKeyId() string
func (*AWSSNSConn) GetAwsProfile ¶ added in v0.0.123
func (x *AWSSNSConn) GetAwsProfile() string
func (*AWSSNSConn) GetAwsRegion ¶ added in v0.0.46
func (x *AWSSNSConn) GetAwsRegion() string
func (*AWSSNSConn) GetAwsSecretAccessKey ¶ added in v0.0.46
func (x *AWSSNSConn) GetAwsSecretAccessKey() string
func (*AWSSNSConn) ProtoMessage ¶ added in v0.0.46
func (*AWSSNSConn) ProtoMessage()
func (*AWSSNSConn) ProtoReflect ¶ added in v0.0.181
func (x *AWSSNSConn) ProtoReflect() protoreflect.Message
func (*AWSSNSConn) Reset ¶ added in v0.0.46
func (x *AWSSNSConn) Reset()
func (*AWSSNSConn) String ¶ added in v0.0.46
func (x *AWSSNSConn) String() string
type AWSSNSWriteArgs ¶ added in v0.0.47
type AWSSNSWriteArgs struct { // @gotags: kong:"help='Topic ARN',required" Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic ARN',required"` // contains filtered or unexported fields }
func (*AWSSNSWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*AWSSNSWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use AWSSNSWriteArgs.ProtoReflect.Descriptor instead.
func (*AWSSNSWriteArgs) GetTopic ¶ added in v0.0.47
func (x *AWSSNSWriteArgs) GetTopic() string
func (*AWSSNSWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*AWSSNSWriteArgs) ProtoMessage()
func (*AWSSNSWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *AWSSNSWriteArgs) ProtoReflect() protoreflect.Message
func (*AWSSNSWriteArgs) Reset ¶ added in v0.0.47
func (x *AWSSNSWriteArgs) Reset()
func (*AWSSNSWriteArgs) String ¶ added in v0.0.47
func (x *AWSSNSWriteArgs) String() string
type AWSSQSConn ¶ added in v0.0.46
type AWSSQSConn struct { // @gotags: kong:"env=AWS_DEFAULT_REGION,hidden" AwsRegion string `protobuf:"bytes,1,opt,name=aws_region,json=awsRegion,proto3" json:"aws_region,omitempty" kong:"env=AWS_DEFAULT_REGION,hidden"` // @gotags: kong:"env=AWS_ACCESS_KEY_ID,hidden" AwsAccessKeyId string `` /* 143-byte string literal not displayed */ // @gotags: kong:"env=AWS_SECRET_ACCESS_KEY,hidden" AwsSecretAccessKey string `` /* 159-byte string literal not displayed */ // @gotags: kong:"env=AWS_PROFILE,hidden" AwsProfile string `protobuf:"bytes,4,opt,name=aws_profile,json=awsProfile,proto3" json:"aws_profile,omitempty" kong:"env=AWS_PROFILE,hidden"` // contains filtered or unexported fields }
func (*AWSSQSConn) Descriptor
deprecated
added in
v0.0.46
func (*AWSSQSConn) Descriptor() ([]byte, []int)
Deprecated: Use AWSSQSConn.ProtoReflect.Descriptor instead.
func (*AWSSQSConn) GetAwsAccessKeyId ¶ added in v0.0.46
func (x *AWSSQSConn) GetAwsAccessKeyId() string
func (*AWSSQSConn) GetAwsProfile ¶ added in v0.0.123
func (x *AWSSQSConn) GetAwsProfile() string
func (*AWSSQSConn) GetAwsRegion ¶ added in v0.0.46
func (x *AWSSQSConn) GetAwsRegion() string
func (*AWSSQSConn) GetAwsSecretAccessKey ¶ added in v0.0.46
func (x *AWSSQSConn) GetAwsSecretAccessKey() string
func (*AWSSQSConn) ProtoMessage ¶ added in v0.0.46
func (*AWSSQSConn) ProtoMessage()
func (*AWSSQSConn) ProtoReflect ¶ added in v0.0.181
func (x *AWSSQSConn) ProtoReflect() protoreflect.Message
func (*AWSSQSConn) Reset ¶ added in v0.0.46
func (x *AWSSQSConn) Reset()
func (*AWSSQSConn) String ¶ added in v0.0.46
func (x *AWSSQSConn) String() string
type AWSSQSReadArgs ¶ added in v0.0.47
type AWSSQSReadArgs struct { // @gotags: kong:"help='Queue name'" QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty" kong:"help='Queue name'"` // @gotags: kong:"help='Remote AWS account ID',optional" RemoteAccountId string `` /* 153-byte string literal not displayed */ // @gotags: kong:"help='Max number of messages to read',default=1" MaxNumMessages int64 `` /* 161-byte string literal not displayed */ // @gotags: kong:"help='An id to identify this read request by',default='plumber/relay'" ReceiveRequestAttemptId string `` /* 211-byte string literal not displayed */ // @gotags: kong:"help='Auto-delete read/received message(s)'" AutoDelete bool `` /* 143-byte string literal not displayed */ // @gotags: kong:"help='Number of seconds to wait for messages (not used when using --continuous)',default=5" WaitTimeSeconds int64 `` /* 207-byte string literal not displayed */ // contains filtered or unexported fields }
func (*AWSSQSReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*AWSSQSReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use AWSSQSReadArgs.ProtoReflect.Descriptor instead.
func (*AWSSQSReadArgs) GetAutoDelete ¶ added in v0.0.47
func (x *AWSSQSReadArgs) GetAutoDelete() bool
func (*AWSSQSReadArgs) GetMaxNumMessages ¶ added in v0.0.47
func (x *AWSSQSReadArgs) GetMaxNumMessages() int64
func (*AWSSQSReadArgs) GetQueueName ¶ added in v0.0.47
func (x *AWSSQSReadArgs) GetQueueName() string
func (*AWSSQSReadArgs) GetReceiveRequestAttemptId ¶ added in v0.0.47
func (x *AWSSQSReadArgs) GetReceiveRequestAttemptId() string
func (*AWSSQSReadArgs) GetRemoteAccountId ¶ added in v0.0.47
func (x *AWSSQSReadArgs) GetRemoteAccountId() string
func (*AWSSQSReadArgs) GetWaitTimeSeconds ¶ added in v0.0.47
func (x *AWSSQSReadArgs) GetWaitTimeSeconds() int64
func (*AWSSQSReadArgs) ProtoMessage ¶ added in v0.0.47
func (*AWSSQSReadArgs) ProtoMessage()
func (*AWSSQSReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *AWSSQSReadArgs) ProtoReflect() protoreflect.Message
func (*AWSSQSReadArgs) Reset ¶ added in v0.0.47
func (x *AWSSQSReadArgs) Reset()
func (*AWSSQSReadArgs) String ¶ added in v0.0.47
func (x *AWSSQSReadArgs) String() string
type AWSSQSRelayArgs ¶ added in v0.0.47
type AWSSQSRelayArgs struct { // @gotags: kong:"help='Queue name',env=PLUMBER_RELAY_SQS_QUEUE_NAME" QueueName string `` /* 146-byte string literal not displayed */ // @gotags: kong:"help='Remote AWS account ID',env=PLUMBER_RELAY_SQS_REMOTE_ACCOUNT_ID,optional" RemoteAccountId string `` /* 193-byte string literal not displayed */ // @gotags: kong:"help='Max number of messages to read',env=PLUMBER_RELAY_SQS_MAX_NUM_MESSAGES,default=1" MaxNumMessages int64 `` /* 200-byte string literal not displayed */ // @gotags: kong:"help='An id to identify this read request by',env=PLUMBER_RELAY_SQS_RECEIVE_REQUEST_ATTEMPT_ID,default='plumber/relay'" ReceiveRequestAttemptId string `` /* 260-byte string literal not displayed */ // @gotags: kong:"help='Auto-delete read/received message(s)',env=PLUMBER_RELAY_SQS_AUTO_DELETE" AutoDelete bool `` /* 177-byte string literal not displayed */ // @gotags: kong:"help='Number of seconds to wait for messages (not used when using --continuous)',env=PLUMBER_RELAY_SQS_WAIT_TIME_SECONDS,default=5" WaitTimeSeconds int64 `` /* 247-byte string literal not displayed */ // contains filtered or unexported fields }
SQS has a dedicated RelayArgs struct as relay has different defaults than read
func (*AWSSQSRelayArgs) Descriptor
deprecated
added in
v0.0.47
func (*AWSSQSRelayArgs) Descriptor() ([]byte, []int)
Deprecated: Use AWSSQSRelayArgs.ProtoReflect.Descriptor instead.
func (*AWSSQSRelayArgs) GetAutoDelete ¶ added in v0.0.47
func (x *AWSSQSRelayArgs) GetAutoDelete() bool
func (*AWSSQSRelayArgs) GetMaxNumMessages ¶ added in v0.0.47
func (x *AWSSQSRelayArgs) GetMaxNumMessages() int64
func (*AWSSQSRelayArgs) GetQueueName ¶ added in v0.0.47
func (x *AWSSQSRelayArgs) GetQueueName() string
func (*AWSSQSRelayArgs) GetReceiveRequestAttemptId ¶ added in v0.0.47
func (x *AWSSQSRelayArgs) GetReceiveRequestAttemptId() string
func (*AWSSQSRelayArgs) GetRemoteAccountId ¶ added in v0.0.47
func (x *AWSSQSRelayArgs) GetRemoteAccountId() string
func (*AWSSQSRelayArgs) GetWaitTimeSeconds ¶ added in v0.0.47
func (x *AWSSQSRelayArgs) GetWaitTimeSeconds() int64
func (*AWSSQSRelayArgs) ProtoMessage ¶ added in v0.0.47
func (*AWSSQSRelayArgs) ProtoMessage()
func (*AWSSQSRelayArgs) ProtoReflect ¶ added in v0.0.181
func (x *AWSSQSRelayArgs) ProtoReflect() protoreflect.Message
func (*AWSSQSRelayArgs) Reset ¶ added in v0.0.47
func (x *AWSSQSRelayArgs) Reset()
func (*AWSSQSRelayArgs) String ¶ added in v0.0.47
func (x *AWSSQSRelayArgs) String() string
type AWSSQSWriteArgs ¶ added in v0.0.47
type AWSSQSWriteArgs struct { // @gotags: kong:"help='Queue name'" QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty" kong:"help='Queue name'"` // @gotags: kong:"help='Remote AWS account ID',optional" RemoteAccountId string `` /* 153-byte string literal not displayed */ // @gotags: kong:"help='How many seconds to delay message delivery by',default=0" DelaySeconds int64 `` /* 168-byte string literal not displayed */ // @gotags: kong:"help='Add optional attributes to outgoing message (assign: k=v delimit: ;)'" Attributes map[string]string `` /* 244-byte string literal not displayed */ // @gotags: kong:"help='Message Group ID. For FIFO queues only'" MessageGroupId string `` /* 158-byte string literal not displayed */ // @gotags: kong:"help='Required when publishing to a FIFO queue that does not have content based deduplication enabled'" MessageDeduplicationId string `` /* 239-byte string literal not displayed */ // contains filtered or unexported fields }
func (*AWSSQSWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*AWSSQSWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use AWSSQSWriteArgs.ProtoReflect.Descriptor instead.
func (*AWSSQSWriteArgs) GetAttributes ¶ added in v0.0.47
func (x *AWSSQSWriteArgs) GetAttributes() map[string]string
func (*AWSSQSWriteArgs) GetDelaySeconds ¶ added in v0.0.47
func (x *AWSSQSWriteArgs) GetDelaySeconds() int64
func (*AWSSQSWriteArgs) GetMessageDeduplicationId ¶ added in v0.0.47
func (x *AWSSQSWriteArgs) GetMessageDeduplicationId() string
func (*AWSSQSWriteArgs) GetMessageGroupId ¶ added in v0.0.47
func (x *AWSSQSWriteArgs) GetMessageGroupId() string
func (*AWSSQSWriteArgs) GetQueueName ¶ added in v0.0.47
func (x *AWSSQSWriteArgs) GetQueueName() string
func (*AWSSQSWriteArgs) GetRemoteAccountId ¶ added in v0.0.47
func (x *AWSSQSWriteArgs) GetRemoteAccountId() string
func (*AWSSQSWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*AWSSQSWriteArgs) ProtoMessage()
func (*AWSSQSWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *AWSSQSWriteArgs) ProtoReflect() protoreflect.Message
func (*AWSSQSWriteArgs) Reset ¶ added in v0.0.47
func (x *AWSSQSWriteArgs) Reset()
func (*AWSSQSWriteArgs) String ¶ added in v0.0.47
func (x *AWSSQSWriteArgs) String() string
type ActiveMQConn ¶ added in v0.0.46
type ActiveMQConn struct { // @gotags: kong:"help='Destination host address',required,default=localhost:61613" Address string `` /* 139-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ActiveMQConn) Descriptor
deprecated
added in
v0.0.46
func (*ActiveMQConn) Descriptor() ([]byte, []int)
Deprecated: Use ActiveMQConn.ProtoReflect.Descriptor instead.
func (*ActiveMQConn) GetAddress ¶ added in v0.0.46
func (x *ActiveMQConn) GetAddress() string
func (*ActiveMQConn) ProtoMessage ¶ added in v0.0.46
func (*ActiveMQConn) ProtoMessage()
func (*ActiveMQConn) ProtoReflect ¶ added in v0.0.181
func (x *ActiveMQConn) ProtoReflect() protoreflect.Message
func (*ActiveMQConn) Reset ¶ added in v0.0.46
func (x *ActiveMQConn) Reset()
func (*ActiveMQConn) String ¶ added in v0.0.46
func (x *ActiveMQConn) String() string
type ActiveMQReadArgs ¶ added in v0.0.47
type ActiveMQReadArgs struct { // @gotags: kong:"help='Topic to read message(s) from',xor=activemq_read" Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic to read message(s) from',xor=activemq_read"` // @gotags: kong:'help='Queue to read message(s) from',xor=activemq_read" Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"` // contains filtered or unexported fields }
func (*ActiveMQReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*ActiveMQReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use ActiveMQReadArgs.ProtoReflect.Descriptor instead.
func (*ActiveMQReadArgs) GetQueue ¶ added in v0.0.47
func (x *ActiveMQReadArgs) GetQueue() string
func (*ActiveMQReadArgs) GetTopic ¶ added in v0.0.47
func (x *ActiveMQReadArgs) GetTopic() string
func (*ActiveMQReadArgs) ProtoMessage ¶ added in v0.0.47
func (*ActiveMQReadArgs) ProtoMessage()
func (*ActiveMQReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *ActiveMQReadArgs) ProtoReflect() protoreflect.Message
func (*ActiveMQReadArgs) Reset ¶ added in v0.0.47
func (x *ActiveMQReadArgs) Reset()
func (*ActiveMQReadArgs) String ¶ added in v0.0.47
func (x *ActiveMQReadArgs) String() string
type ActiveMQWriteArgs ¶ added in v0.0.47
type ActiveMQWriteArgs struct { // @gotags: kong:"help='Topic to write message(s) to',xor=activemq_write" Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic to write message(s) to',xor=activemq_write"` // @gotags: kong:'help='Queue to write message(s) to',xor=activemq_write" Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"` // contains filtered or unexported fields }
func (*ActiveMQWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*ActiveMQWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use ActiveMQWriteArgs.ProtoReflect.Descriptor instead.
func (*ActiveMQWriteArgs) GetQueue ¶ added in v0.0.47
func (x *ActiveMQWriteArgs) GetQueue() string
func (*ActiveMQWriteArgs) GetTopic ¶ added in v0.0.47
func (x *ActiveMQWriteArgs) GetTopic() string
func (*ActiveMQWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*ActiveMQWriteArgs) ProtoMessage()
func (*ActiveMQWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *ActiveMQWriteArgs) ProtoReflect() protoreflect.Message
func (*ActiveMQWriteArgs) Reset ¶ added in v0.0.47
func (x *ActiveMQWriteArgs) Reset()
func (*ActiveMQWriteArgs) String ¶ added in v0.0.47
func (x *ActiveMQWriteArgs) String() string
type AzureEventHubConn ¶ added in v0.0.46
type AzureEventHubConn struct { // @gotags: kong:"help='Connection string',env='EVENTHUB_CONNECTION_STRING',required" ConnectionString string `` /* 183-byte string literal not displayed */ // contains filtered or unexported fields }
func (*AzureEventHubConn) Descriptor
deprecated
added in
v0.0.46
func (*AzureEventHubConn) Descriptor() ([]byte, []int)
Deprecated: Use AzureEventHubConn.ProtoReflect.Descriptor instead.
func (*AzureEventHubConn) GetConnectionString ¶ added in v0.0.46
func (x *AzureEventHubConn) GetConnectionString() string
func (*AzureEventHubConn) ProtoMessage ¶ added in v0.0.46
func (*AzureEventHubConn) ProtoMessage()
func (*AzureEventHubConn) ProtoReflect ¶ added in v0.0.181
func (x *AzureEventHubConn) ProtoReflect() protoreflect.Message
func (*AzureEventHubConn) Reset ¶ added in v0.0.46
func (x *AzureEventHubConn) Reset()
func (*AzureEventHubConn) String ¶ added in v0.0.46
func (x *AzureEventHubConn) String() string
type AzureEventHubReadArgs ¶ added in v0.0.47
type AzureEventHubReadArgs struct {
// contains filtered or unexported fields
}
func (*AzureEventHubReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*AzureEventHubReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use AzureEventHubReadArgs.ProtoReflect.Descriptor instead.
func (*AzureEventHubReadArgs) ProtoMessage ¶ added in v0.0.47
func (*AzureEventHubReadArgs) ProtoMessage()
func (*AzureEventHubReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *AzureEventHubReadArgs) ProtoReflect() protoreflect.Message
func (*AzureEventHubReadArgs) Reset ¶ added in v0.0.47
func (x *AzureEventHubReadArgs) Reset()
func (*AzureEventHubReadArgs) String ¶ added in v0.0.47
func (x *AzureEventHubReadArgs) String() string
type AzureEventHubWriteArgs ¶ added in v0.0.47
type AzureEventHubWriteArgs struct { // @gotags: kong:"help='Send message with this ID'" MessageId string `` /* 128-byte string literal not displayed */ // @gotags: kong:"help='Send message with this partition key'" PartitionKey string `` /* 148-byte string literal not displayed */ // contains filtered or unexported fields }
func (*AzureEventHubWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*AzureEventHubWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use AzureEventHubWriteArgs.ProtoReflect.Descriptor instead.
func (*AzureEventHubWriteArgs) GetMessageId ¶ added in v0.0.47
func (x *AzureEventHubWriteArgs) GetMessageId() string
func (*AzureEventHubWriteArgs) GetPartitionKey ¶ added in v0.0.47
func (x *AzureEventHubWriteArgs) GetPartitionKey() string
func (*AzureEventHubWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*AzureEventHubWriteArgs) ProtoMessage()
func (*AzureEventHubWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *AzureEventHubWriteArgs) ProtoReflect() protoreflect.Message
func (*AzureEventHubWriteArgs) Reset ¶ added in v0.0.47
func (x *AzureEventHubWriteArgs) Reset()
func (*AzureEventHubWriteArgs) String ¶ added in v0.0.47
func (x *AzureEventHubWriteArgs) String() string
type AzureServiceBusConn ¶ added in v0.0.46
type AzureServiceBusConn struct { // NOTE: This is an azure-defined env var // @gotags: kong:"help='Connection string',env='SERVICEBUS_CONNECTION_STRING',required" ConnectionString string `` /* 185-byte string literal not displayed */ // contains filtered or unexported fields }
func (*AzureServiceBusConn) Descriptor
deprecated
added in
v0.0.46
func (*AzureServiceBusConn) Descriptor() ([]byte, []int)
Deprecated: Use AzureServiceBusConn.ProtoReflect.Descriptor instead.
func (*AzureServiceBusConn) GetConnectionString ¶ added in v0.0.46
func (x *AzureServiceBusConn) GetConnectionString() string
func (*AzureServiceBusConn) ProtoMessage ¶ added in v0.0.46
func (*AzureServiceBusConn) ProtoMessage()
func (*AzureServiceBusConn) ProtoReflect ¶ added in v0.0.181
func (x *AzureServiceBusConn) ProtoReflect() protoreflect.Message
func (*AzureServiceBusConn) Reset ¶ added in v0.0.46
func (x *AzureServiceBusConn) Reset()
func (*AzureServiceBusConn) String ¶ added in v0.0.46
func (x *AzureServiceBusConn) String() string
type AzureServiceBusReadArgs ¶ added in v0.0.47
type AzureServiceBusReadArgs struct { // @gotags: kong:"help='Queue name',env='PLUMBER_RELAY_AZURE_QUEUE_NAME',xor=asb_read" Queue string `` /* 138-byte string literal not displayed */ // @gotags: kong:"help='Topic name',env='PLUMBER_RELAY_AZURE_TOPIC_NAME',xor=asb_read" Topic string `` /* 138-byte string literal not displayed */ // @gotags: kong:"help='Subscription name',env='PLUMBER_RELAY_AZURE_SUBSCRIPTION',required" SubscriptionName string `` /* 189-byte string literal not displayed */ // contains filtered or unexported fields }
func (*AzureServiceBusReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*AzureServiceBusReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use AzureServiceBusReadArgs.ProtoReflect.Descriptor instead.
func (*AzureServiceBusReadArgs) GetQueue ¶ added in v0.0.47
func (x *AzureServiceBusReadArgs) GetQueue() string
func (*AzureServiceBusReadArgs) GetSubscriptionName ¶ added in v0.0.47
func (x *AzureServiceBusReadArgs) GetSubscriptionName() string
func (*AzureServiceBusReadArgs) GetTopic ¶ added in v0.0.47
func (x *AzureServiceBusReadArgs) GetTopic() string
func (*AzureServiceBusReadArgs) ProtoMessage ¶ added in v0.0.47
func (*AzureServiceBusReadArgs) ProtoMessage()
func (*AzureServiceBusReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *AzureServiceBusReadArgs) ProtoReflect() protoreflect.Message
func (*AzureServiceBusReadArgs) Reset ¶ added in v0.0.47
func (x *AzureServiceBusReadArgs) Reset()
func (*AzureServiceBusReadArgs) String ¶ added in v0.0.47
func (x *AzureServiceBusReadArgs) String() string
type AzureServiceBusWriteArgs ¶ added in v0.0.47
type AzureServiceBusWriteArgs struct { // @gotags: kong:"help='Queue name',xor=asb_write" Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty" kong:"help='Queue name',xor=asb_write"` // @gotags: kong:"help='Topic name',xor=asb_write" Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic name',xor=asb_write"` // contains filtered or unexported fields }
func (*AzureServiceBusWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*AzureServiceBusWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use AzureServiceBusWriteArgs.ProtoReflect.Descriptor instead.
func (*AzureServiceBusWriteArgs) GetQueue ¶ added in v0.0.47
func (x *AzureServiceBusWriteArgs) GetQueue() string
func (*AzureServiceBusWriteArgs) GetTopic ¶ added in v0.0.47
func (x *AzureServiceBusWriteArgs) GetTopic() string
func (*AzureServiceBusWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*AzureServiceBusWriteArgs) ProtoMessage()
func (*AzureServiceBusWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *AzureServiceBusWriteArgs) ProtoReflect() protoreflect.Message
func (*AzureServiceBusWriteArgs) Reset ¶ added in v0.0.47
func (x *AzureServiceBusWriteArgs) Reset()
func (*AzureServiceBusWriteArgs) String ¶ added in v0.0.47
func (x *AzureServiceBusWriteArgs) String() string
type CreateConsumerConfig ¶ added in v0.0.46
type CreateConsumerConfig struct { // @gotags: kong:"help='Create the streams if creating a new consumer group',env='PLUMBER_RELAY_REDIS_STREAMS_CREATE_STREAMS'" CreateStreams bool `` /* 216-byte string literal not displayed */ // @gotags: kong:"help='Recreate this consumer group if it does not exist',env='PLUMBER_RELAY_REDIS_STREAMS_RECREATE_CONSUMER_GROUP'" RecreateConsumerGroup bool `` /* 249-byte string literal not displayed */ // @gotags: kong:"help='What offset to start reading at (options: latest oldest)',default=latest,required,env='PLUMBER_RELAY_REDIS_STREAMS_START_ID',type=pbenum,pbenum_lowercase" OffsetStart OffsetStart `` /* 291-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CreateConsumerConfig) Descriptor
deprecated
added in
v0.0.46
func (*CreateConsumerConfig) Descriptor() ([]byte, []int)
Deprecated: Use CreateConsumerConfig.ProtoReflect.Descriptor instead.
func (*CreateConsumerConfig) GetCreateStreams ¶ added in v0.0.46
func (x *CreateConsumerConfig) GetCreateStreams() bool
func (*CreateConsumerConfig) GetOffsetStart ¶ added in v0.0.46
func (x *CreateConsumerConfig) GetOffsetStart() OffsetStart
func (*CreateConsumerConfig) GetRecreateConsumerGroup ¶ added in v0.0.46
func (x *CreateConsumerConfig) GetRecreateConsumerGroup() bool
func (*CreateConsumerConfig) ProtoMessage ¶ added in v0.0.46
func (*CreateConsumerConfig) ProtoMessage()
func (*CreateConsumerConfig) ProtoReflect ¶ added in v0.0.181
func (x *CreateConsumerConfig) ProtoReflect() protoreflect.Message
func (*CreateConsumerConfig) Reset ¶ added in v0.0.46
func (x *CreateConsumerConfig) Reset()
func (*CreateConsumerConfig) String ¶ added in v0.0.46
func (x *CreateConsumerConfig) String() string
type GCPPubSubConn ¶ added in v0.0.46
type GCPPubSubConn struct { // @gotags: kong:"help='Project ID',env='PLUMBER_RELAY_GCP_PROJECT_ID',required" ProjectId string `` /* 157-byte string literal not displayed */ // @gotags: kong:"help='GCP Credentials in JSON format',env='PLUMBER_RELAY_GCP_CREDENTIALS'" CredentialsJson string `` /* 187-byte string literal not displayed */ // @gotags: kong:"help='Path to GCP credentials JSON file',env='GOOGLE_APPLICATION_CREDENTIALS'" CredentialsFile string `` /* 191-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GCPPubSubConn) Descriptor
deprecated
added in
v0.0.46
func (*GCPPubSubConn) Descriptor() ([]byte, []int)
Deprecated: Use GCPPubSubConn.ProtoReflect.Descriptor instead.
func (*GCPPubSubConn) GetCredentialsFile ¶ added in v0.0.97
func (x *GCPPubSubConn) GetCredentialsFile() string
func (*GCPPubSubConn) GetCredentialsJson ¶ added in v0.0.97
func (x *GCPPubSubConn) GetCredentialsJson() string
func (*GCPPubSubConn) GetProjectId ¶ added in v0.0.46
func (x *GCPPubSubConn) GetProjectId() string
func (*GCPPubSubConn) ProtoMessage ¶ added in v0.0.46
func (*GCPPubSubConn) ProtoMessage()
func (*GCPPubSubConn) ProtoReflect ¶ added in v0.0.181
func (x *GCPPubSubConn) ProtoReflect() protoreflect.Message
func (*GCPPubSubConn) Reset ¶ added in v0.0.46
func (x *GCPPubSubConn) Reset()
func (*GCPPubSubConn) String ¶ added in v0.0.46
func (x *GCPPubSubConn) String() string
type GCPPubSubReadArgs ¶ added in v0.0.47
type GCPPubSubReadArgs struct { // @gotags: kong:"help='Subscription ID',env='PLUMBER_RELAY_GCP_SUBSCRIPTION_ID',required" SubscriptionId string `` /* 182-byte string literal not displayed */ // @gotags: kong:"help='Whether to acknowledge message receive',env='PLUMBER_RELAY_GCP_ACK_MESSAGE',default=true" AckMessages bool `` /* 197-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GCPPubSubReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*GCPPubSubReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use GCPPubSubReadArgs.ProtoReflect.Descriptor instead.
func (*GCPPubSubReadArgs) GetAckMessages ¶ added in v0.0.47
func (x *GCPPubSubReadArgs) GetAckMessages() bool
func (*GCPPubSubReadArgs) GetSubscriptionId ¶ added in v0.0.47
func (x *GCPPubSubReadArgs) GetSubscriptionId() string
func (*GCPPubSubReadArgs) ProtoMessage ¶ added in v0.0.47
func (*GCPPubSubReadArgs) ProtoMessage()
func (*GCPPubSubReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *GCPPubSubReadArgs) ProtoReflect() protoreflect.Message
func (*GCPPubSubReadArgs) Reset ¶ added in v0.0.47
func (x *GCPPubSubReadArgs) Reset()
func (*GCPPubSubReadArgs) String ¶ added in v0.0.47
func (x *GCPPubSubReadArgs) String() string
type GCPPubSubWriteArgs ¶ added in v0.0.47
type GCPPubSubWriteArgs struct { // @gotags: kong:"help='Topic ID to publish message(s) to',required" TopicId string `` /* 139-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GCPPubSubWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*GCPPubSubWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use GCPPubSubWriteArgs.ProtoReflect.Descriptor instead.
func (*GCPPubSubWriteArgs) GetTopicId ¶ added in v0.0.47
func (x *GCPPubSubWriteArgs) GetTopicId() string
func (*GCPPubSubWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*GCPPubSubWriteArgs) ProtoMessage()
func (*GCPPubSubWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *GCPPubSubWriteArgs) ProtoReflect() protoreflect.Message
func (*GCPPubSubWriteArgs) Reset ¶ added in v0.0.47
func (x *GCPPubSubWriteArgs) Reset()
func (*GCPPubSubWriteArgs) String ¶ added in v0.0.47
func (x *GCPPubSubWriteArgs) String() string
type KafkaConn ¶ added in v0.0.46
type KafkaConn struct { // @gotags: kong:"help='Kafka broker address (you may specify this flag multiple times)',env=PLUMBER_RELAY_KAFKA_ADDRESS,default='localhost:9092',required" Address []string `` /* 211-byte string literal not displayed */ // @gotags: kong:"help='Connect timeout',env=PLUMBER_RELAY_TIMEOUT_SECONDS,default=10" TimeoutSeconds int32 `` /* 179-byte string literal not displayed */ // @gotags: kong:"help='Enable TLS usage',env=PLUMBER_RELAY_USE_TLS" UseTls bool `` /* 137-byte string literal not displayed */ // @gotags: kong:"help='Allow insecure TLS usage',env=PLUMBER_RELAY_KAFKA_INSECURE_TLS" TlsSkipVerify bool `` /* 179-byte string literal not displayed */ // @gotags: kong:"help='SASL authentication type (options: none plain scram)',env=PLUMBER_RELAY_KAFKA_SASL_TYPE,type=pbenum,pbenum_lowercase,default=none" SaslType SASLType `` /* 255-byte string literal not displayed */ // @gotags: kong:"help='SASL Username',env=PLUMBER_RELAY_KAFKA_USERNAME" SaslUsername string `` /* 158-byte string literal not displayed */ // Required if sasl_type is not NONE // @gotags: kong:"help='SASL Password. You will be prompted for the password if omitted',env=PLUMBER_RELAY_KAFKA_PASSWORD" SaslPassword string `` /* 208-byte string literal not displayed */ // contains filtered or unexported fields }
func (*KafkaConn) Descriptor
deprecated
added in
v0.0.46
func (*KafkaConn) 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) ProtoReflect ¶ added in v0.0.181
func (x *KafkaConn) ProtoReflect() protoreflect.Message
type KafkaReadArgs ¶ added in v0.0.47
type KafkaReadArgs struct { // @gotags: kong:"help='Topic(s) to read from',required" Topics []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty" kong:"help='Topic(s) to read from',required"` // @gotags: kong:"help='Specify what offset the consumer should read from (only works if --use-consumer-group is false)',default=0" ReadOffset int64 `` /* 212-byte string literal not displayed */ // @gotags: kong:"help='Whether plumber should use a consumer group',default=true" UseConsumerGroup bool `` /* 183-byte string literal not displayed */ // @gotags: kong:"help='Specify a specific group-id to use when reading from kafka',default=plumber" ConsumerGroupName string `` /* 203-byte string literal not displayed */ // @gotags: kong:"help='How long to wait for new data when reading batches of messages',default=1" MaxWaitSeconds int32 `` /* 193-byte string literal not displayed */ // @gotags: kong:"help='Minimum number of bytes to fetch in a single kafka request (throughput optimization)',default=1" MinBytes int32 `` /* 195-byte string literal not displayed */ // @gotags: kong:"help='Maximum number of bytes to fetch in a single kafka request (throughput optimization)',default=1" MaxBytes int32 `` /* 195-byte string literal not displayed */ // @gotags: kong:"help='How often to commit offsets to broker (0 = synchronous)',default=5" CommitIntervalSeconds int32 `` /* 207-byte string literal not displayed */ // @gotags: kong:"help='How long a coordinator will wait for member joins as part of a rebalance',default=0" RebalanceTimeoutSeconds int32 `` /* 230-byte string literal not displayed */ // @gotags: kong:"help='Internal library queue capacity (throughput optimization)',default=1" QueueCapacity int32 `` /* 184-byte string literal not displayed */ // @gotags: kong:"help='Display consumer offset stats during read'" IncludeOffsetInfo bool `` /* 172-byte string literal not displayed */ // @gotags: kong:"help='Only lookup consumer group lag',group=lag" Lag bool `protobuf:"varint,12,opt,name=lag,proto3" json:"lag,omitempty" kong:"help='Only lookup consumer group lag',group=lag"` // @gotags: kong:"help='What consumer group to lookup lag for (required if --lag is set)',group=lag" LagConsumerGroup string `` /* 201-byte string literal not displayed */ // contains filtered or unexported fields }
func (*KafkaReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*KafkaReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use KafkaReadArgs.ProtoReflect.Descriptor instead.
func (*KafkaReadArgs) GetCommitIntervalSeconds ¶ added in v0.0.47
func (x *KafkaReadArgs) GetCommitIntervalSeconds() int32
func (*KafkaReadArgs) GetConsumerGroupName ¶ added in v0.0.47
func (x *KafkaReadArgs) GetConsumerGroupName() string
func (*KafkaReadArgs) GetIncludeOffsetInfo ¶ added in v0.0.51
func (x *KafkaReadArgs) GetIncludeOffsetInfo() bool
func (*KafkaReadArgs) GetLag ¶ added in v0.0.51
func (x *KafkaReadArgs) GetLag() bool
func (*KafkaReadArgs) GetLagConsumerGroup ¶ added in v0.0.51
func (x *KafkaReadArgs) GetLagConsumerGroup() string
func (*KafkaReadArgs) GetMaxBytes ¶ added in v0.0.47
func (x *KafkaReadArgs) GetMaxBytes() int32
func (*KafkaReadArgs) GetMaxWaitSeconds ¶ added in v0.0.47
func (x *KafkaReadArgs) GetMaxWaitSeconds() int32
func (*KafkaReadArgs) GetMinBytes ¶ added in v0.0.47
func (x *KafkaReadArgs) GetMinBytes() int32
func (*KafkaReadArgs) GetQueueCapacity ¶ added in v0.0.47
func (x *KafkaReadArgs) GetQueueCapacity() int32
func (*KafkaReadArgs) GetReadOffset ¶ added in v0.0.47
func (x *KafkaReadArgs) GetReadOffset() int64
func (*KafkaReadArgs) GetRebalanceTimeoutSeconds ¶ added in v0.0.47
func (x *KafkaReadArgs) GetRebalanceTimeoutSeconds() int32
func (*KafkaReadArgs) GetTopics ¶ added in v0.0.47
func (x *KafkaReadArgs) GetTopics() []string
func (*KafkaReadArgs) GetUseConsumerGroup ¶ added in v0.0.47
func (x *KafkaReadArgs) GetUseConsumerGroup() bool
func (*KafkaReadArgs) ProtoMessage ¶ added in v0.0.47
func (*KafkaReadArgs) ProtoMessage()
func (*KafkaReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *KafkaReadArgs) ProtoReflect() protoreflect.Message
func (*KafkaReadArgs) Reset ¶ added in v0.0.47
func (x *KafkaReadArgs) Reset()
func (*KafkaReadArgs) String ¶ added in v0.0.47
func (x *KafkaReadArgs) String() string
type KafkaRelayArgs ¶ added in v0.0.47
type KafkaRelayArgs struct { // @gotags: kong:"help='Topic(s) to read, write or get lag stats for',env=PLUMBER_RELAY_KAFKA_TOPIC,required" Topics []string `` /* 163-byte string literal not displayed */ // @gotags: kong:"help='Specify what offset the consumer should read from (only works if --use-consumer-group is false)',env=PLUMBER_RELAY_KAFKA_READ_OFFSET,default=0" ReadOffset int64 `` /* 248-byte string literal not displayed */ // @gotags: kong:"help='Whether plumber should use a consumer group',env=PLUMBER_RELAY_KAFKA_USE_CONSUMER_GROUP,default=true" UseConsumerGroup bool `` /* 226-byte string literal not displayed */ // @gotags: kong:"help='Specify a specific group-id to use when reading from kafka',env=PLUMBER_RELAY_KAFKA_GROUP_ID,default=plumber" ConsumerGroupName string `` /* 236-byte string literal not displayed */ // @gotags: kong:"help='How long to wait for new data when reading batches of messages',env=PLUMBER_RELAY_KAFKA_MAX_WAIT,default=5" MaxWaitSeconds int32 `` /* 226-byte string literal not displayed */ // @gotags: kong:"help='Minimum number of bytes to fetch in a single kafka request (throughput optimization)',env=PLUMBER_RELAY_KAFKA_MIN_BYTES,default=1048576" MinBytes int32 `` /* 235-byte string literal not displayed */ // @gotags: kong:"help='Maximum number of bytes to fetch in a single kafka request (throughput optimization)',env=PLUMBER_RELAY_KAFKA_MAX_BYTES,default=1048576" MaxBytes int32 `` /* 235-byte string literal not displayed */ // @gotags: kong:"help='How often to commit offsets to broker (0 = synchronous)',env=PLUMBER_RELAY_KAFKA_COMMIT_INTERVAL,default=5" CommitIntervalSeconds int32 `` /* 247-byte string literal not displayed */ // @gotags: kong:"help='How long a coordinator will wait for member joins as part of a rebalance',env=PLUMBER_RELAY_KAFKA_REBALANCE_TIMEOUT,default=5" RebalanceTimeoutSeconds int32 `` /* 272-byte string literal not displayed */ // @gotags: kong:"help='Internal library queue capacity (throughput optimization)',env=PLUMBER_RELAY_KAFKA_QUEUE_CAPACITY,default=1000" QueueCapacity int32 `` /* 226-byte string literal not displayed */ // contains filtered or unexported fields }
func (*KafkaRelayArgs) Descriptor
deprecated
added in
v0.0.47
func (*KafkaRelayArgs) Descriptor() ([]byte, []int)
Deprecated: Use KafkaRelayArgs.ProtoReflect.Descriptor instead.
func (*KafkaRelayArgs) GetCommitIntervalSeconds ¶ added in v0.0.47
func (x *KafkaRelayArgs) GetCommitIntervalSeconds() int32
func (*KafkaRelayArgs) GetConsumerGroupName ¶ added in v0.0.47
func (x *KafkaRelayArgs) GetConsumerGroupName() string
func (*KafkaRelayArgs) GetMaxBytes ¶ added in v0.0.47
func (x *KafkaRelayArgs) GetMaxBytes() int32
func (*KafkaRelayArgs) GetMaxWaitSeconds ¶ added in v0.0.47
func (x *KafkaRelayArgs) GetMaxWaitSeconds() int32
func (*KafkaRelayArgs) GetMinBytes ¶ added in v0.0.47
func (x *KafkaRelayArgs) GetMinBytes() int32
func (*KafkaRelayArgs) GetQueueCapacity ¶ added in v0.0.47
func (x *KafkaRelayArgs) GetQueueCapacity() int32
func (*KafkaRelayArgs) GetReadOffset ¶ added in v0.0.47
func (x *KafkaRelayArgs) GetReadOffset() int64
func (*KafkaRelayArgs) GetRebalanceTimeoutSeconds ¶ added in v0.0.47
func (x *KafkaRelayArgs) GetRebalanceTimeoutSeconds() int32
func (*KafkaRelayArgs) GetTopics ¶ added in v0.0.47
func (x *KafkaRelayArgs) GetTopics() []string
func (*KafkaRelayArgs) GetUseConsumerGroup ¶ added in v0.0.47
func (x *KafkaRelayArgs) GetUseConsumerGroup() bool
func (*KafkaRelayArgs) ProtoMessage ¶ added in v0.0.47
func (*KafkaRelayArgs) ProtoMessage()
func (*KafkaRelayArgs) ProtoReflect ¶ added in v0.0.181
func (x *KafkaRelayArgs) ProtoReflect() protoreflect.Message
func (*KafkaRelayArgs) Reset ¶ added in v0.0.47
func (x *KafkaRelayArgs) Reset()
func (*KafkaRelayArgs) String ¶ added in v0.0.47
func (x *KafkaRelayArgs) String() string
type KafkaWriteArgs ¶ added in v0.0.47
type KafkaWriteArgs struct { // @gotags: kong:"help='Key to write to kafka (optional)'" Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty" kong:"help='Key to write to kafka (optional)'"` // @gotags: kong:"help='Add one or more headers (optional; repeat flags to specify multiple)'" Headers map[string]string `` /* 238-byte string literal not displayed */ // @gotags: kong:"help='Topic(s) to write to',required" Topics []string `protobuf:"bytes,3,rep,name=topics,proto3" json:"topics,omitempty" kong:"help='Topic(s) to write to',required"` // contains filtered or unexported fields }
func (*KafkaWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*KafkaWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use KafkaWriteArgs.ProtoReflect.Descriptor instead.
func (*KafkaWriteArgs) GetHeaders ¶ added in v0.0.47
func (x *KafkaWriteArgs) GetHeaders() map[string]string
func (*KafkaWriteArgs) GetKey ¶ added in v0.0.47
func (x *KafkaWriteArgs) GetKey() string
func (*KafkaWriteArgs) GetTopics ¶ added in v0.0.52
func (x *KafkaWriteArgs) GetTopics() []string
func (*KafkaWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*KafkaWriteArgs) ProtoMessage()
func (*KafkaWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *KafkaWriteArgs) ProtoReflect() protoreflect.Message
func (*KafkaWriteArgs) Reset ¶ added in v0.0.47
func (x *KafkaWriteArgs) Reset()
func (*KafkaWriteArgs) String ¶ added in v0.0.47
func (x *KafkaWriteArgs) String() string
type KubeMQQueueConn ¶ added in v0.0.46
type KubeMQQueueConn struct { // @gotags: kong:"help='Dial string for KubeMQ server',env='PLUMBER_RELAY_KUBEMQ_QUEUE_ADDRESS',default='localhost:50000',required" Address string `` /* 187-byte string literal not displayed */ // @gotags: kong:"help='Client JWT authentication token',env='PLUMBER_RELAY_KUBEMQ_QUEUE_AUTH_TOKEN'" AuthToken string `` /* 178-byte string literal not displayed */ // @gotags: kong:"help='KubeMQ client cert file',env='PLUMBER_RELAY_KUBEMQ_QUEUE_TLS_CLIENT_CERT'" TlsClientCert string `` /* 189-byte string literal not displayed */ // @gotags: kong:"help='KubeMQ client ID',env='PLUMBER_RELAY_KUBEMQ_QUEUE_CLIENT_ID',default=plumber" ClientId string `` /* 175-byte string literal not displayed */ // contains filtered or unexported fields }
func (*KubeMQQueueConn) Descriptor
deprecated
added in
v0.0.46
func (*KubeMQQueueConn) Descriptor() ([]byte, []int)
Deprecated: Use KubeMQQueueConn.ProtoReflect.Descriptor instead.
func (*KubeMQQueueConn) GetAddress ¶ added in v0.0.46
func (x *KubeMQQueueConn) GetAddress() string
func (*KubeMQQueueConn) GetAuthToken ¶ added in v0.0.46
func (x *KubeMQQueueConn) GetAuthToken() string
func (*KubeMQQueueConn) GetClientId ¶ added in v0.0.101
func (x *KubeMQQueueConn) GetClientId() string
func (*KubeMQQueueConn) GetTlsClientCert ¶ added in v0.0.114
func (x *KubeMQQueueConn) GetTlsClientCert() string
func (*KubeMQQueueConn) ProtoMessage ¶ added in v0.0.46
func (*KubeMQQueueConn) ProtoMessage()
func (*KubeMQQueueConn) ProtoReflect ¶ added in v0.0.181
func (x *KubeMQQueueConn) ProtoReflect() protoreflect.Message
func (*KubeMQQueueConn) Reset ¶ added in v0.0.46
func (x *KubeMQQueueConn) Reset()
func (*KubeMQQueueConn) String ¶ added in v0.0.46
func (x *KubeMQQueueConn) String() string
type KubeMQQueueReadArgs ¶ added in v0.0.47
type KubeMQQueueReadArgs struct { // @gotags: kong:"help='KubeMQ queue name',env='PLUMBER_RELAY_KUBEMQ_QUEUE_QUEUE'" QueueName string `` /* 159-byte string literal not displayed */ // contains filtered or unexported fields }
func (*KubeMQQueueReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*KubeMQQueueReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use KubeMQQueueReadArgs.ProtoReflect.Descriptor instead.
func (*KubeMQQueueReadArgs) GetQueueName ¶ added in v0.0.47
func (x *KubeMQQueueReadArgs) GetQueueName() string
func (*KubeMQQueueReadArgs) ProtoMessage ¶ added in v0.0.47
func (*KubeMQQueueReadArgs) ProtoMessage()
func (*KubeMQQueueReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *KubeMQQueueReadArgs) ProtoReflect() protoreflect.Message
func (*KubeMQQueueReadArgs) Reset ¶ added in v0.0.47
func (x *KubeMQQueueReadArgs) Reset()
func (*KubeMQQueueReadArgs) String ¶ added in v0.0.47
func (x *KubeMQQueueReadArgs) String() string
type KubeMQQueueWriteArgs ¶ added in v0.0.47
type KubeMQQueueWriteArgs struct { // @gotags: kong:"help='KubeMQ queue name'" QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty" kong:"help='KubeMQ queue name'"` // contains filtered or unexported fields }
func (*KubeMQQueueWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*KubeMQQueueWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use KubeMQQueueWriteArgs.ProtoReflect.Descriptor instead.
func (*KubeMQQueueWriteArgs) GetQueueName ¶ added in v0.0.47
func (x *KubeMQQueueWriteArgs) GetQueueName() string
func (*KubeMQQueueWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*KubeMQQueueWriteArgs) ProtoMessage()
func (*KubeMQQueueWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *KubeMQQueueWriteArgs) ProtoReflect() protoreflect.Message
func (*KubeMQQueueWriteArgs) Reset ¶ added in v0.0.47
func (x *KubeMQQueueWriteArgs) Reset()
func (*KubeMQQueueWriteArgs) String ¶ added in v0.0.47
func (x *KubeMQQueueWriteArgs) String() string
type MQTTConn ¶ added in v0.0.46
type MQTTConn struct { // @gotags: kong:"help='MQTT address',default='tcp://localhost:1883',env='PLUMBER_RELAY_MQTT_ADDRESS',required" Address string `` /* 167-byte string literal not displayed */ // @gotags: kong:"help='How long to attempt to connect for',env='PLUMBER_RELAY_MQTT_CONNECT_TIMEOUT',default=5" ConnTimeoutSeconds uint32 `` /* 218-byte string literal not displayed */ // @gotags: kong:"help='Client id presented to MQTT broker',env='PLUMBER_RELAY_MQTT_CLIENT_ID',default=plumber" ClientId string `` /* 185-byte string literal not displayed */ // @gotags: kong:"help='QoS level to use for pub/sub (options: at_most_once, at_least_once, exactly_once)',env=PLUMBER_RELAY_MQTT_QOS,type=pbenum,pbenum_strip_prefix=MQTT_QOS_LEVEL_,pbenum_lowercase,default=at_most_once" QosLevel MQTTQoSLevel `` /* 325-byte string literal not displayed */ // @gotags: kong:"embed" TlsOptions *MQTTTLSOptions `protobuf:"bytes,6,opt,name=tls_options,json=tlsOptions,proto3" json:"tls_options,omitempty" kong:"embed"` // contains filtered or unexported fields }
func (*MQTTConn) Descriptor
deprecated
added in
v0.0.46
func (*MQTTConn) 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 (x *MQTTConn) GetQosLevel() MQTTQoSLevel
func (*MQTTConn) GetTlsOptions ¶ added in v0.0.46
func (x *MQTTConn) GetTlsOptions() *MQTTTLSOptions
func (*MQTTConn) ProtoMessage ¶ added in v0.0.46
func (*MQTTConn) ProtoMessage()
func (*MQTTConn) ProtoReflect ¶ added in v0.0.181
func (x *MQTTConn) ProtoReflect() protoreflect.Message
type MQTTQoSLevel ¶ added in v0.0.46
type MQTTQoSLevel int32
const ( MQTTQoSLevel_MQTT_QOS_LEVEL_AT_MOST_ONCE MQTTQoSLevel = 0 MQTTQoSLevel_MQTT_QOS_LEVEL_AT_LEAST_ONCE MQTTQoSLevel = 1 MQTTQoSLevel_MQTT_QOS_LEVEL_EXACTLY_ONCE MQTTQoSLevel = 2 )
func (MQTTQoSLevel) Descriptor ¶ added in v0.0.181
func (MQTTQoSLevel) Descriptor() protoreflect.EnumDescriptor
func (MQTTQoSLevel) Enum ¶ added in v0.0.181
func (x MQTTQoSLevel) Enum() *MQTTQoSLevel
func (MQTTQoSLevel) EnumDescriptor
deprecated
added in
v0.0.46
func (MQTTQoSLevel) EnumDescriptor() ([]byte, []int)
Deprecated: Use MQTTQoSLevel.Descriptor instead.
func (MQTTQoSLevel) Number ¶ added in v0.0.181
func (x MQTTQoSLevel) Number() protoreflect.EnumNumber
func (MQTTQoSLevel) String ¶ added in v0.0.46
func (x MQTTQoSLevel) String() string
func (MQTTQoSLevel) Type ¶ added in v0.0.181
func (MQTTQoSLevel) Type() protoreflect.EnumType
type MQTTReadArgs ¶ added in v0.0.47
type MQTTReadArgs struct { // @gotags: kong:"help='Topic to read message(s) from',env='PLUMBER_RELAY_MQTT_TOPIC',required" Topic string `` /* 147-byte string literal not displayed */ // @gotags: kong:"help='How long to attempt to read message(s)',default=0,env='PLUMBER_RELAY_MQTT_READ_TIMEOUT_SECONDS'" ReadTimeoutSeconds uint32 `` /* 227-byte string literal not displayed */ // contains filtered or unexported fields }
func (*MQTTReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*MQTTReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use MQTTReadArgs.ProtoReflect.Descriptor instead.
func (*MQTTReadArgs) GetReadTimeoutSeconds ¶ added in v0.0.47
func (x *MQTTReadArgs) GetReadTimeoutSeconds() uint32
func (*MQTTReadArgs) GetTopic ¶ added in v0.0.47
func (x *MQTTReadArgs) GetTopic() string
func (*MQTTReadArgs) ProtoMessage ¶ added in v0.0.47
func (*MQTTReadArgs) ProtoMessage()
func (*MQTTReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *MQTTReadArgs) ProtoReflect() protoreflect.Message
func (*MQTTReadArgs) Reset ¶ added in v0.0.47
func (x *MQTTReadArgs) Reset()
func (*MQTTReadArgs) String ¶ added in v0.0.47
func (x *MQTTReadArgs) String() string
type MQTTTLSOptions ¶ added in v0.0.46
type MQTTTLSOptions struct { // @gotags: kong:"help='CA cert (only needed if addr is ssl://)',env=PLUMBER_RELAY_MQTT_TLS_CA_CERT" TlsCaCert string `` /* 179-byte string literal not displayed */ // @gotags: kong:"help='Client cert file (only needed if addr is ssl://)',env=PLUMBER_RELAY_MQTT_TLS_CLIENT_CERT" TlsClientCert string `` /* 204-byte string literal not displayed */ // @gotags: kong:"help='Client key file (only needed if addr is ssl://)',env=PLUMBER_RELAY_MQTT_TLS_CLIENT_KEY" TlsClientKey string `` /* 199-byte string literal not displayed */ // @gotags: kong:"help='Whether to verify server certificate',env=PLUMBER_RELAY_MQTT_SKIP_VERIFY_TLS" TlsSkipVerify bool `` /* 193-byte string literal not displayed */ // contains filtered or unexported fields }
func (*MQTTTLSOptions) Descriptor
deprecated
added in
v0.0.46
func (*MQTTTLSOptions) Descriptor() ([]byte, []int)
Deprecated: Use MQTTTLSOptions.ProtoReflect.Descriptor instead.
func (*MQTTTLSOptions) GetTlsCaCert ¶ added in v0.0.114
func (x *MQTTTLSOptions) GetTlsCaCert() string
func (*MQTTTLSOptions) GetTlsClientCert ¶ added in v0.0.114
func (x *MQTTTLSOptions) GetTlsClientCert() string
func (*MQTTTLSOptions) GetTlsClientKey ¶ added in v0.0.114
func (x *MQTTTLSOptions) GetTlsClientKey() string
func (*MQTTTLSOptions) GetTlsSkipVerify ¶ added in v0.0.114
func (x *MQTTTLSOptions) GetTlsSkipVerify() bool
func (*MQTTTLSOptions) ProtoMessage ¶ added in v0.0.46
func (*MQTTTLSOptions) ProtoMessage()
func (*MQTTTLSOptions) ProtoReflect ¶ added in v0.0.181
func (x *MQTTTLSOptions) ProtoReflect() protoreflect.Message
func (*MQTTTLSOptions) Reset ¶ added in v0.0.46
func (x *MQTTTLSOptions) Reset()
func (*MQTTTLSOptions) String ¶ added in v0.0.46
func (x *MQTTTLSOptions) String() string
type MQTTWriteArgs ¶ added in v0.0.47
type MQTTWriteArgs struct { // @gotags: kong:"help='Topic to write message(s) to',required" Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic to write message(s) to',required"` // @gotags: kong:"help='How long to attempt to publish message(s)',default=5" WriteTimeoutSeconds uint32 `` /* 187-byte string literal not displayed */ // contains filtered or unexported fields }
func (*MQTTWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*MQTTWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use MQTTWriteArgs.ProtoReflect.Descriptor instead.
func (*MQTTWriteArgs) GetTopic ¶ added in v0.0.47
func (x *MQTTWriteArgs) GetTopic() string
func (*MQTTWriteArgs) GetWriteTimeoutSeconds ¶ added in v0.0.47
func (x *MQTTWriteArgs) GetWriteTimeoutSeconds() uint32
func (*MQTTWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*MQTTWriteArgs) ProtoMessage()
func (*MQTTWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *MQTTWriteArgs) ProtoReflect() protoreflect.Message
func (*MQTTWriteArgs) Reset ¶ added in v0.0.47
func (x *MQTTWriteArgs) Reset()
func (*MQTTWriteArgs) String ¶ added in v0.0.47
func (x *MQTTWriteArgs) String() string
type MemphisConn ¶ added in v0.0.177
type MemphisConn struct { // @gotags: kong:"help='Address of Memphis broker (Ex: localhost:6666)',default='localhost:6666'" Address string `` /* 153-byte string literal not displayed */ // @gotags: kong:"help='Broker username',default='plumber'" Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty" kong:"help='Broker username',default='plumber'"` // @gotags: kong:"help='Broker access token',default='memphis'" BrokerToken string `` /* 146-byte string literal not displayed */ // contains filtered or unexported fields }
func (*MemphisConn) Descriptor
deprecated
added in
v0.0.177
func (*MemphisConn) Descriptor() ([]byte, []int)
Deprecated: Use MemphisConn.ProtoReflect.Descriptor instead.
func (*MemphisConn) GetAddress ¶ added in v0.0.177
func (x *MemphisConn) GetAddress() string
func (*MemphisConn) GetBrokerToken ¶ added in v0.0.177
func (x *MemphisConn) GetBrokerToken() string
func (*MemphisConn) GetUsername ¶ added in v0.0.177
func (x *MemphisConn) GetUsername() string
func (*MemphisConn) ProtoMessage ¶ added in v0.0.177
func (*MemphisConn) ProtoMessage()
func (*MemphisConn) ProtoReflect ¶ added in v0.0.181
func (x *MemphisConn) ProtoReflect() protoreflect.Message
func (*MemphisConn) Reset ¶ added in v0.0.177
func (x *MemphisConn) Reset()
func (*MemphisConn) String ¶ added in v0.0.177
func (x *MemphisConn) String() string
type MemphisReadArgs ¶ added in v0.0.177
type MemphisReadArgs struct { // @gotags: kong:"help='Station name to consume from',required" Station string `protobuf:"bytes,1,opt,name=station,proto3" json:"station,omitempty" kong:"help='Station name to consume from',required"` // @gotags: kong:"help='Consumer Name',default='plumber'" ConsumerName string `` /* 143-byte string literal not displayed */ // @gotags: kong:"help='Consumer Group, defaults to consumer-name if not specified',env='PLUMBER_RELAY_MEMPHIS_CONSUMER_GROUP'" ConsumerGroup string `` /* 216-byte string literal not displayed */ // contains filtered or unexported fields }
func (*MemphisReadArgs) Descriptor
deprecated
added in
v0.0.177
func (*MemphisReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use MemphisReadArgs.ProtoReflect.Descriptor instead.
func (*MemphisReadArgs) GetConsumerGroup ¶ added in v0.0.177
func (x *MemphisReadArgs) GetConsumerGroup() string
func (*MemphisReadArgs) GetConsumerName ¶ added in v0.0.177
func (x *MemphisReadArgs) GetConsumerName() string
func (*MemphisReadArgs) GetStation ¶ added in v0.0.177
func (x *MemphisReadArgs) GetStation() string
func (*MemphisReadArgs) ProtoMessage ¶ added in v0.0.177
func (*MemphisReadArgs) ProtoMessage()
func (*MemphisReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *MemphisReadArgs) ProtoReflect() protoreflect.Message
func (*MemphisReadArgs) Reset ¶ added in v0.0.177
func (x *MemphisReadArgs) Reset()
func (*MemphisReadArgs) String ¶ added in v0.0.177
func (x *MemphisReadArgs) String() string
type MemphisWriteArgs ¶ added in v0.0.177
type MemphisWriteArgs struct { // @gotags: kong:"help='Station name to write to',required" Station string `protobuf:"bytes,1,opt,name=station,proto3" json:"station,omitempty" kong:"help='Station name to write to',required"` // @gotags: kong:"help='Producer name',default='plumber'" ProducerName string `` /* 143-byte string literal not displayed */ // @gotags: kong:"help='Add one or more headers (optional; repeat flags to specify multiple)'" Headers map[string]string `` /* 238-byte string literal not displayed */ // @gotags: kong:"help='ID to give message'" MessageId string `protobuf:"bytes,4,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty" kong:"help='ID to give message'"` // contains filtered or unexported fields }
func (*MemphisWriteArgs) Descriptor
deprecated
added in
v0.0.177
func (*MemphisWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use MemphisWriteArgs.ProtoReflect.Descriptor instead.
func (*MemphisWriteArgs) GetHeaders ¶ added in v0.0.177
func (x *MemphisWriteArgs) GetHeaders() map[string]string
func (*MemphisWriteArgs) GetMessageId ¶ added in v0.0.177
func (x *MemphisWriteArgs) GetMessageId() string
func (*MemphisWriteArgs) GetProducerName ¶ added in v0.0.177
func (x *MemphisWriteArgs) GetProducerName() string
func (*MemphisWriteArgs) GetStation ¶ added in v0.0.177
func (x *MemphisWriteArgs) GetStation() string
func (*MemphisWriteArgs) ProtoMessage ¶ added in v0.0.177
func (*MemphisWriteArgs) ProtoMessage()
func (*MemphisWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *MemphisWriteArgs) ProtoReflect() protoreflect.Message
func (*MemphisWriteArgs) Reset ¶ added in v0.0.177
func (x *MemphisWriteArgs) Reset()
func (*MemphisWriteArgs) String ¶ added in v0.0.177
func (x *MemphisWriteArgs) String() string
type MongoConn ¶ added in v0.0.46
type MongoConn struct { // @gotags: kong:"help='Dial string for mongo server (Ex: mongodb://localhost:27017)',env='PLUMBER_RELAY_CDCMONGO_DSN',default='mongodb://localhost:27017'" Dsn string `` /* 203-byte string literal not displayed */ // contains filtered or unexported fields }
func (*MongoConn) Descriptor
deprecated
added in
v0.0.46
func (*MongoConn) ProtoMessage ¶ added in v0.0.46
func (*MongoConn) ProtoMessage()
func (*MongoConn) ProtoReflect ¶ added in v0.0.181
func (x *MongoConn) ProtoReflect() protoreflect.Message
type MongoReadArgs ¶ added in v0.0.47
type MongoReadArgs struct { // @gotags: kong:"help='Database name',env='PLUMBER_RELAY_CDCMONGO_DATABASE'" Database string `` /* 135-byte string literal not displayed */ // @gotags: kong:"help='Collection name',env='PLUMBER_RELAY_CDCMONGO_COLLECTION'" Collection string `` /* 143-byte string literal not displayed */ // @gotags: kong:"help='Include full document in update in update changes (default - return deltas only)',env='PLUMBER_RELAY_CDCMONGO_INCLUDE_FULL_DOC'" IncludeFullDocument bool `` /* 262-byte string literal not displayed */ // contains filtered or unexported fields }
func (*MongoReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*MongoReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use MongoReadArgs.ProtoReflect.Descriptor instead.
func (*MongoReadArgs) GetCollection ¶ added in v0.0.47
func (x *MongoReadArgs) GetCollection() string
func (*MongoReadArgs) GetDatabase ¶ added in v0.0.47
func (x *MongoReadArgs) GetDatabase() string
func (*MongoReadArgs) GetIncludeFullDocument ¶ added in v0.0.47
func (x *MongoReadArgs) GetIncludeFullDocument() bool
func (*MongoReadArgs) ProtoMessage ¶ added in v0.0.47
func (*MongoReadArgs) ProtoMessage()
func (*MongoReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *MongoReadArgs) ProtoReflect() protoreflect.Message
func (*MongoReadArgs) Reset ¶ added in v0.0.47
func (x *MongoReadArgs) Reset()
func (*MongoReadArgs) String ¶ added in v0.0.47
func (x *MongoReadArgs) String() string
type NSQConn ¶ added in v0.0.46
type NSQConn struct { // @gotags: kong:"help='Address of NSQ server (Ex: localhost:4150)',env='PLUMBER_RELAY_NSQ_NSQD_ADDRESS',default='localhost:4150',xor=nsq_addressZ" NsqdAddress string `` /* 230-byte string literal not displayed */ // @gotags: kong:"help='Address of LookupD server (Ex: localhost:4161)',env='PLUMBER_RELAY_NSQ_LOOKUPD_ADDRESS',xor=nsq_address" LookupdAddress string `` /* 220-byte string literal not displayed */ // @gotags: kong:"help='Enable TLS usage',env='PLUMBER_RELAY_NSQ_USE_TLS'" UseTls bool `` /* 143-byte string literal not displayed */ // @gotags: kong:"help='Whether to verify server certificate',env='PLUMBER_RELAY_NSQ_SKIP_VERIFY_TLS'" TlsSkipVerify bool `` /* 194-byte string literal not displayed */ // @gotags: kong:"help='CA file',env='PLUMBER_RELAY_NSQ_TLS_CA_CERT'" TlsCaCert string `` /* 148-byte string literal not displayed */ // @gotags: kong:"help='Client cert file',env='PLUMBER_RELAY_NSQ_TLS_CLIENT_CERT'" TlsClientCert string `` /* 173-byte string literal not displayed */ // @gotags: kong:"help='Client key file',env='PLUMBER_RELAY_NSQ_TLS_CLIENT_KEY'" TlsClientKey string `` /* 168-byte string literal not displayed */ // @gotags: kong:"help='Authentication secret',env='PLUMBER_RELAY_NSQ_AUTH_SECRET'" AuthSecret string `` /* 163-byte string literal not displayed */ // @gotags: kong:"help='Client ID to identify as',env='PLUMBER_RELAY_NSQ_CLIENT_ID',default=plumber" ClientId string `` /* 174-byte string literal not displayed */ // contains filtered or unexported fields }
func (*NSQConn) Descriptor
deprecated
added in
v0.0.46
func (*NSQConn) 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) ProtoReflect ¶ added in v0.0.181
func (x *NSQConn) ProtoReflect() protoreflect.Message
type NSQReadArgs ¶ added in v0.0.47
type NSQReadArgs struct { // @gotags: kong:"help='NSQ topic to read from',env='PLUMBER_RELAY_NSQ_TOPIC',required" Topic string `` /* 139-byte string literal not displayed */ // @gotags: kong:"help='Output channel',env='PLUMBER_RELAY_NSQ_CHANNEL',required" Channel string `` /* 137-byte string literal not displayed */ // contains filtered or unexported fields }
func (*NSQReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*NSQReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use NSQReadArgs.ProtoReflect.Descriptor instead.
func (*NSQReadArgs) GetChannel ¶ added in v0.0.47
func (x *NSQReadArgs) GetChannel() string
func (*NSQReadArgs) GetTopic ¶ added in v0.0.47
func (x *NSQReadArgs) GetTopic() string
func (*NSQReadArgs) ProtoMessage ¶ added in v0.0.47
func (*NSQReadArgs) ProtoMessage()
func (*NSQReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *NSQReadArgs) ProtoReflect() protoreflect.Message
func (*NSQReadArgs) Reset ¶ added in v0.0.47
func (x *NSQReadArgs) Reset()
func (*NSQReadArgs) String ¶ added in v0.0.47
func (x *NSQReadArgs) String() string
type NSQWriteArgs ¶ added in v0.0.47
type NSQWriteArgs struct { // @gotags: kong:"help='NSQ topic to write to',required" Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='NSQ topic to write to',required"` // contains filtered or unexported fields }
func (*NSQWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*NSQWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use NSQWriteArgs.ProtoReflect.Descriptor instead.
func (*NSQWriteArgs) GetTopic ¶ added in v0.0.47
func (x *NSQWriteArgs) GetTopic() string
func (*NSQWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*NSQWriteArgs) ProtoMessage()
func (*NSQWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *NSQWriteArgs) ProtoReflect() protoreflect.Message
func (*NSQWriteArgs) Reset ¶ added in v0.0.47
func (x *NSQWriteArgs) Reset()
func (*NSQWriteArgs) String ¶ added in v0.0.47
func (x *NSQWriteArgs) String() string
type NatsConn ¶ added in v0.0.46
type NatsConn struct { // @gotags: kong:"help='Dial string for NATS server. Ex: nats://localhost:4222',default='nats://localhost:4222',env='PLUMBER_RELAY_NATS_DSN'" Dsn string `` /* 189-byte string literal not displayed */ // @gotags: kong:"help='NATS .creds file containing authentication credentials',env='PLUMBER_RELAY_NATS_CREDENTIALS'" UserCredentials string `` /* 212-byte string literal not displayed */ // @gotags: kong:"embed" TlsOptions *NatsTLSOptions `protobuf:"bytes,3,opt,name=tls_options,json=tlsOptions,proto3" json:"tls_options,omitempty" kong:"embed"` // @gotags: kong:"help='File containing NATS NKey',env='PLUMBER_RELAY_NATS_NKEY'" Nkey string `` /* 131-byte string literal not displayed */ // contains filtered or unexported fields }
func (*NatsConn) Descriptor
deprecated
added in
v0.0.46
func (*NatsConn) GetTlsOptions ¶ added in v0.0.125
func (x *NatsConn) GetTlsOptions() *NatsTLSOptions
func (*NatsConn) GetUserCredentials ¶ added in v0.0.46
func (*NatsConn) ProtoMessage ¶ added in v0.0.46
func (*NatsConn) ProtoMessage()
func (*NatsConn) ProtoReflect ¶ added in v0.0.181
func (x *NatsConn) ProtoReflect() protoreflect.Message
type NatsJetstreamConn ¶ added in v0.0.119
type NatsJetstreamConn struct { // @gotags: kong:"help='Dial string for NATS server. Ex: nats://localhost:4222',default='nats://localhost:4222',env='PLUMBER_RELAY_NATS_JETSTREAM_DSN'" Dsn string `` /* 199-byte string literal not displayed */ // @gotags: kong:"help='NATS .creds file containing authentication credentials',env='PLUMBER_RELAY_NATS_JETSTREAM_CREDENTIALS'" UserCredentials string `` /* 222-byte string literal not displayed */ // @gotags: kong:"help='User specified client ID to connect with',default=plumber,env='PLUMBER_RELAY_NATS_JETSTREAM_CLIENT_ID'" ClientId string `` /* 201-byte string literal not displayed */ // @gotags: kong:"embed" TlsOptions *NatsJetstreamTLSOptions `protobuf:"bytes,4,opt,name=tls_options,json=tlsOptions,proto3" json:"tls_options,omitempty" kong:"embed"` // @gotags: kong:"help='File containing NATS NKey',env='PLUMBER_RELAY_NATS_JETSTREAM_NKEY'" Nkey string `` /* 141-byte string literal not displayed */ // contains filtered or unexported fields }
func (*NatsJetstreamConn) Descriptor
deprecated
added in
v0.0.119
func (*NatsJetstreamConn) Descriptor() ([]byte, []int)
Deprecated: Use NatsJetstreamConn.ProtoReflect.Descriptor instead.
func (*NatsJetstreamConn) GetClientId ¶ added in v0.0.119
func (x *NatsJetstreamConn) GetClientId() string
func (*NatsJetstreamConn) GetDsn ¶ added in v0.0.119
func (x *NatsJetstreamConn) GetDsn() string
func (*NatsJetstreamConn) GetNkey ¶ added in v0.0.166
func (x *NatsJetstreamConn) GetNkey() string
func (*NatsJetstreamConn) GetTlsOptions ¶ added in v0.0.119
func (x *NatsJetstreamConn) GetTlsOptions() *NatsJetstreamTLSOptions
func (*NatsJetstreamConn) GetUserCredentials ¶ added in v0.0.119
func (x *NatsJetstreamConn) GetUserCredentials() string
func (*NatsJetstreamConn) ProtoMessage ¶ added in v0.0.119
func (*NatsJetstreamConn) ProtoMessage()
func (*NatsJetstreamConn) ProtoReflect ¶ added in v0.0.181
func (x *NatsJetstreamConn) ProtoReflect() protoreflect.Message
func (*NatsJetstreamConn) Reset ¶ added in v0.0.119
func (x *NatsJetstreamConn) Reset()
func (*NatsJetstreamConn) String ¶ added in v0.0.119
func (x *NatsJetstreamConn) String() string
type NatsJetstreamReadArgs ¶ added in v0.0.119
type NatsJetstreamReadArgs struct { // @gotags: kong:"help='NATS JetStream stream name. Ex: orders.>',env='PLUMBER_RELAY_NATS_JETSTREAM_STREAM'" Stream string `` /* 162-byte string literal not displayed */ // @gotags: kong:"help='Consumer name (default: random consumer name; has no effect if create_durable_consumer or existing_durable_consumer is not set)',env='PLUMBER_RELAY_NATS_JETSTREAM_CONSUMER_NAME'" ConsumerName string `` /* 288-byte string literal not displayed */ // @gotags: kong:"help='Create a new durable consumer (default: use ephemeral consumer)',env='PLUMBER_RELAY_NATS_JETSTREAM_CREATE_DURABLE_CONSUMER'" CreateDurableConsumer bool `` /* 264-byte string literal not displayed */ // @gotags: kong:"help='Use an existing durable consumer (default: use ephemeral consumer)',env='PLUMBER_RELAY_NATS_JETSTREAM_EXISTING_DURABLE_CONSUMER'" ExistingDurableConsumer bool `` /* 275-byte string literal not displayed */ // @gotags: kong:"help='Do not delete consumer after operation is done (default: delete on exit)',env='PLUMBER_RELAY_NATS_JETSTREAM_KEEP_CONSUMER'" KeepConsumer bool `` /* 234-byte string literal not displayed */ // @gotags: kong:"help='Where to start read in stream (default: from start)',env='PLUMBER_RELAY_NATS_JETSTREAM_CONSUMER_START_SEQUENCE'" ConsumerStartSequence int64 `` /* 252-byte string literal not displayed */ // @gotags: kong:"help='At what time to start stream (RFC3339 format, Ex: 2016-06-20T12:41:45.14Z)',env='PLUMBER_RELAY_NATS_JETSTREAM_CONSUMER_START_TIME'" ConsumerStartTime string `` /* 258-byte string literal not displayed */ // @gotags: kong:"help='Only receive a subset of messages from the Stream based on the subject',env='PLUMBER_RELAY_NATS_JETSTREAM_CONSUMER_FILTER_SUBJECT'" ConsumerFilterSubject string `` /* 270-byte string literal not displayed */ // contains filtered or unexported fields }
func (*NatsJetstreamReadArgs) Descriptor
deprecated
added in
v0.0.119
func (*NatsJetstreamReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use NatsJetstreamReadArgs.ProtoReflect.Descriptor instead.
func (*NatsJetstreamReadArgs) GetConsumerFilterSubject ¶ added in v0.0.161
func (x *NatsJetstreamReadArgs) GetConsumerFilterSubject() string
func (*NatsJetstreamReadArgs) GetConsumerName ¶ added in v0.0.161
func (x *NatsJetstreamReadArgs) GetConsumerName() string
func (*NatsJetstreamReadArgs) GetConsumerStartSequence ¶ added in v0.0.161
func (x *NatsJetstreamReadArgs) GetConsumerStartSequence() int64
func (*NatsJetstreamReadArgs) GetConsumerStartTime ¶ added in v0.0.161
func (x *NatsJetstreamReadArgs) GetConsumerStartTime() string
func (*NatsJetstreamReadArgs) GetCreateDurableConsumer ¶ added in v0.0.162
func (x *NatsJetstreamReadArgs) GetCreateDurableConsumer() bool
func (*NatsJetstreamReadArgs) GetExistingDurableConsumer ¶ added in v0.0.162
func (x *NatsJetstreamReadArgs) GetExistingDurableConsumer() bool
func (*NatsJetstreamReadArgs) GetKeepConsumer ¶ added in v0.0.161
func (x *NatsJetstreamReadArgs) GetKeepConsumer() bool
func (*NatsJetstreamReadArgs) GetStream ¶ added in v0.0.119
func (x *NatsJetstreamReadArgs) GetStream() string
func (*NatsJetstreamReadArgs) ProtoMessage ¶ added in v0.0.119
func (*NatsJetstreamReadArgs) ProtoMessage()
func (*NatsJetstreamReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *NatsJetstreamReadArgs) ProtoReflect() protoreflect.Message
func (*NatsJetstreamReadArgs) Reset ¶ added in v0.0.119
func (x *NatsJetstreamReadArgs) Reset()
func (*NatsJetstreamReadArgs) String ¶ added in v0.0.119
func (x *NatsJetstreamReadArgs) String() string
type NatsJetstreamTLSOptions ¶ added in v0.0.119
type NatsJetstreamTLSOptions struct { // @gotags: kong:"help='CA file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_JETSTREAM_TLS_CA_CERT'" TlsCaCert string `` /* 192-byte string literal not displayed */ // @gotags: kong:"help='Client cert file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_JETSTREAM_TLS_CLIENT_CERT'" TlsClientCert string `` /* 217-byte string literal not displayed */ // @gotags: kong:"help='Client key file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_JETSTREAM_TLS_CLIENT_KEY'" TlsClientKey string `` /* 212-byte string literal not displayed */ // @gotags: kong:"help='Whether to verify server certificate',env='PLUMBER_RELAY_NATS_JETSTREAM_SKIP_VERIFY_TLS'" TlsSkipVerify bool `` /* 205-byte string literal not displayed */ // @gotags: kong:"help='Enable TLS',env='PLUMBER_RELAY_NATS_JETSTREAM_USE_TLS'" UseTls bool `` /* 148-byte string literal not displayed */ // contains filtered or unexported fields }
func (*NatsJetstreamTLSOptions) Descriptor
deprecated
added in
v0.0.119
func (*NatsJetstreamTLSOptions) Descriptor() ([]byte, []int)
Deprecated: Use NatsJetstreamTLSOptions.ProtoReflect.Descriptor instead.
func (*NatsJetstreamTLSOptions) GetTlsCaCert ¶ added in v0.0.119
func (x *NatsJetstreamTLSOptions) GetTlsCaCert() string
func (*NatsJetstreamTLSOptions) GetTlsClientCert ¶ added in v0.0.119
func (x *NatsJetstreamTLSOptions) GetTlsClientCert() string
func (*NatsJetstreamTLSOptions) GetTlsClientKey ¶ added in v0.0.119
func (x *NatsJetstreamTLSOptions) GetTlsClientKey() string
func (*NatsJetstreamTLSOptions) GetTlsSkipVerify ¶ added in v0.0.119
func (x *NatsJetstreamTLSOptions) GetTlsSkipVerify() bool
func (*NatsJetstreamTLSOptions) GetUseTls ¶ added in v0.0.144
func (x *NatsJetstreamTLSOptions) GetUseTls() bool
func (*NatsJetstreamTLSOptions) ProtoMessage ¶ added in v0.0.119
func (*NatsJetstreamTLSOptions) ProtoMessage()
func (*NatsJetstreamTLSOptions) ProtoReflect ¶ added in v0.0.181
func (x *NatsJetstreamTLSOptions) ProtoReflect() protoreflect.Message
func (*NatsJetstreamTLSOptions) Reset ¶ added in v0.0.119
func (x *NatsJetstreamTLSOptions) Reset()
func (*NatsJetstreamTLSOptions) String ¶ added in v0.0.119
func (x *NatsJetstreamTLSOptions) String() string
type NatsJetstreamWriteArgs ¶ added in v0.0.119
type NatsJetstreamWriteArgs struct { // @gotags: kong:"help='NATS JetStream subject name to write to. Ex: orders.>'" Subject string `` /* 135-byte string literal not displayed */ // contains filtered or unexported fields }
func (*NatsJetstreamWriteArgs) Descriptor
deprecated
added in
v0.0.119
func (*NatsJetstreamWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use NatsJetstreamWriteArgs.ProtoReflect.Descriptor instead.
func (*NatsJetstreamWriteArgs) GetSubject ¶ added in v0.0.164
func (x *NatsJetstreamWriteArgs) GetSubject() string
func (*NatsJetstreamWriteArgs) ProtoMessage ¶ added in v0.0.119
func (*NatsJetstreamWriteArgs) ProtoMessage()
func (*NatsJetstreamWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *NatsJetstreamWriteArgs) ProtoReflect() protoreflect.Message
func (*NatsJetstreamWriteArgs) Reset ¶ added in v0.0.119
func (x *NatsJetstreamWriteArgs) Reset()
func (*NatsJetstreamWriteArgs) String ¶ added in v0.0.119
func (x *NatsJetstreamWriteArgs) String() string
type NatsReadArgs ¶ added in v0.0.47
type NatsReadArgs struct { // @gotags: kong:"help='NATS Subject. Ex: foo.bar.*',env='PLUMBER_RELAY_NATS_SUBJECT'" Subject string `` /* 142-byte string literal not displayed */ // contains filtered or unexported fields }
func (*NatsReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*NatsReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use NatsReadArgs.ProtoReflect.Descriptor instead.
func (*NatsReadArgs) GetSubject ¶ added in v0.0.47
func (x *NatsReadArgs) GetSubject() string
func (*NatsReadArgs) ProtoMessage ¶ added in v0.0.47
func (*NatsReadArgs) ProtoMessage()
func (*NatsReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *NatsReadArgs) ProtoReflect() protoreflect.Message
func (*NatsReadArgs) Reset ¶ added in v0.0.47
func (x *NatsReadArgs) Reset()
func (*NatsReadArgs) String ¶ added in v0.0.47
func (x *NatsReadArgs) String() string
type NatsStreamingConn ¶ added in v0.0.46
type NatsStreamingConn struct { // @gotags: kong:"help='Dial string for NATS server. Ex: nats://localhost:4222',default='nats://localhost:4222',env='PLUMBER_RELAY_NATS_STREAMING_DSN'" Dsn string `` /* 199-byte string literal not displayed */ // @gotags: kong:"help='NATS .creds file containing authentication credentials',env='PLUMBER_RELAY_NATS_STREAMING_CREDENTIALS'" UserCredentials string `` /* 222-byte string literal not displayed */ // @gotags: kong:"help='Cluster ID of the Nats server',required,env='PLUMBER_RELAY_NATS_STREAMING_CLUSTER_ID'" ClusterId string `` /* 187-byte string literal not displayed */ // @gotags: kong:"help='User specified client ID to connect with',default='plumber',env='PLUMBER_RELAY_NATS_STREAMING_CLIENT_ID'" ClientId string `` /* 203-byte string literal not displayed */ // @gotags: kong:"embed" TlsOptions *NatsStreamingTLSOptions `protobuf:"bytes,5,opt,name=tls_options,json=tlsOptions,proto3" json:"tls_options,omitempty" kong:"embed"` // contains filtered or unexported fields }
func (*NatsStreamingConn) Descriptor
deprecated
added in
v0.0.46
func (*NatsStreamingConn) Descriptor() ([]byte, []int)
Deprecated: Use NatsStreamingConn.ProtoReflect.Descriptor instead.
func (*NatsStreamingConn) GetClientId ¶ added in v0.0.46
func (x *NatsStreamingConn) GetClientId() string
func (*NatsStreamingConn) GetClusterId ¶ added in v0.0.46
func (x *NatsStreamingConn) GetClusterId() string
func (*NatsStreamingConn) GetDsn ¶ added in v0.0.46
func (x *NatsStreamingConn) GetDsn() string
func (*NatsStreamingConn) GetTlsOptions ¶ added in v0.0.106
func (x *NatsStreamingConn) GetTlsOptions() *NatsStreamingTLSOptions
func (*NatsStreamingConn) GetUserCredentials ¶ added in v0.0.46
func (x *NatsStreamingConn) GetUserCredentials() string
func (*NatsStreamingConn) ProtoMessage ¶ added in v0.0.46
func (*NatsStreamingConn) ProtoMessage()
func (*NatsStreamingConn) ProtoReflect ¶ added in v0.0.181
func (x *NatsStreamingConn) ProtoReflect() protoreflect.Message
func (*NatsStreamingConn) Reset ¶ added in v0.0.46
func (x *NatsStreamingConn) Reset()
func (*NatsStreamingConn) String ¶ added in v0.0.46
func (x *NatsStreamingConn) String() string
type NatsStreamingReadArgs ¶ added in v0.0.47
type NatsStreamingReadArgs struct { // @gotags: kong:"help='NATS stream channel. Ex: orders',env='PLUMBER_RELAY_NATS_STREAMING_CHANNEL'" Channel string `` /* 156-byte string literal not displayed */ // @gotags: kong:"help='Create a durable subscription with this name for the given channel',env='PLUMBER_RELAY_NATS_STREAMING_DURABLE_SUBSCRIPTION_NAME'" DurableName string `` /* 236-byte string literal not displayed */ // @gotags: kong:"help='Deliver starting with last published message',xor=nats_delivery_option,env='PLUMBER_RELAY_NATS_STREAMING_READ_LAST'" ReadLastAvailable bool `` /* 244-byte string literal not displayed */ // @gotags: kong:"help='Deliver messages starting at sequence number',xor=nats_delivery_option,env='PLUMBER_RELAY_NATS_STREAMING_READ_SEQUENCE'" ReadSequenceNumber uint32 `` /* 251-byte string literal not displayed */ // @gotags: kong:"help='Deliver messages in last interval (e.g. 1s, 1h)',xor=nats_delivery_option,env='PLUMBER_RELAY_NATS_STREAMING_READ_SINCE'" ReadSince string `` /* 221-byte string literal not displayed */ // @gotags: kong:"help='Deliver all available messages',xor=nats_delivery_option,env='PLUMBER_RELAY_NATS_STREAMING_READ_ALL'" ReadAll bool `` /* 197-byte string literal not displayed */ // contains filtered or unexported fields }
func (*NatsStreamingReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*NatsStreamingReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use NatsStreamingReadArgs.ProtoReflect.Descriptor instead.
func (*NatsStreamingReadArgs) GetChannel ¶ added in v0.0.47
func (x *NatsStreamingReadArgs) GetChannel() string
func (*NatsStreamingReadArgs) GetDurableName ¶ added in v0.0.47
func (x *NatsStreamingReadArgs) GetDurableName() string
func (*NatsStreamingReadArgs) GetReadAll ¶ added in v0.0.47
func (x *NatsStreamingReadArgs) GetReadAll() bool
func (*NatsStreamingReadArgs) GetReadLastAvailable ¶ added in v0.0.47
func (x *NatsStreamingReadArgs) GetReadLastAvailable() bool
func (*NatsStreamingReadArgs) GetReadSequenceNumber ¶ added in v0.0.47
func (x *NatsStreamingReadArgs) GetReadSequenceNumber() uint32
func (*NatsStreamingReadArgs) GetReadSince ¶ added in v0.0.47
func (x *NatsStreamingReadArgs) GetReadSince() string
func (*NatsStreamingReadArgs) ProtoMessage ¶ added in v0.0.47
func (*NatsStreamingReadArgs) ProtoMessage()
func (*NatsStreamingReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *NatsStreamingReadArgs) ProtoReflect() protoreflect.Message
func (*NatsStreamingReadArgs) Reset ¶ added in v0.0.47
func (x *NatsStreamingReadArgs) Reset()
func (*NatsStreamingReadArgs) String ¶ added in v0.0.47
func (x *NatsStreamingReadArgs) String() string
type NatsStreamingTLSOptions ¶ added in v0.0.106
type NatsStreamingTLSOptions struct { // @gotags: kong:"help='CA file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_STREAMING_TLS_CA_CERT'" TlsCaCert string `` /* 192-byte string literal not displayed */ // @gotags: kong:"help='Client cert file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_STREAMING_TLS_CLIENT_CERT'" TlsClientCert string `` /* 217-byte string literal not displayed */ // @gotags: kong:"help='Client key file (only needed if addr is tls://*)',env='PLUMBER_RELAY_NATS_STREAMING_TLS_CLIENT_KEY'" TlsClientKey string `` /* 212-byte string literal not displayed */ // @gotags: kong:"help='Whether to verify server certificate',env='PLUMBER_RELAY_NATS_STREAMING_SKIP_VERIFY_TLS'" TlsSkipVerify bool `` /* 205-byte string literal not displayed */ // @gotags: kong:"help='Enable TLS',env='PLUMBER_RELAY_NATS_STREAMING_USE_TLS'" UseTls bool `` /* 148-byte string literal not displayed */ // contains filtered or unexported fields }
func (*NatsStreamingTLSOptions) Descriptor
deprecated
added in
v0.0.106
func (*NatsStreamingTLSOptions) Descriptor() ([]byte, []int)
Deprecated: Use NatsStreamingTLSOptions.ProtoReflect.Descriptor instead.
func (*NatsStreamingTLSOptions) GetTlsCaCert ¶ added in v0.0.114
func (x *NatsStreamingTLSOptions) GetTlsCaCert() string
func (*NatsStreamingTLSOptions) GetTlsClientCert ¶ added in v0.0.114
func (x *NatsStreamingTLSOptions) GetTlsClientCert() string
func (*NatsStreamingTLSOptions) GetTlsClientKey ¶ added in v0.0.114
func (x *NatsStreamingTLSOptions) GetTlsClientKey() string
func (*NatsStreamingTLSOptions) GetTlsSkipVerify ¶ added in v0.0.114
func (x *NatsStreamingTLSOptions) GetTlsSkipVerify() bool
func (*NatsStreamingTLSOptions) GetUseTls ¶ added in v0.0.144
func (x *NatsStreamingTLSOptions) GetUseTls() bool
func (*NatsStreamingTLSOptions) ProtoMessage ¶ added in v0.0.106
func (*NatsStreamingTLSOptions) ProtoMessage()
func (*NatsStreamingTLSOptions) ProtoReflect ¶ added in v0.0.181
func (x *NatsStreamingTLSOptions) ProtoReflect() protoreflect.Message
func (*NatsStreamingTLSOptions) Reset ¶ added in v0.0.106
func (x *NatsStreamingTLSOptions) Reset()
func (*NatsStreamingTLSOptions) String ¶ added in v0.0.106
func (x *NatsStreamingTLSOptions) String() string
type NatsStreamingWriteArgs ¶ added in v0.0.47
type NatsStreamingWriteArgs struct { // @gotags: kong:"help='NATS stream channel. Ex: orders'" Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty" kong:"help='NATS stream channel. Ex: orders'"` // contains filtered or unexported fields }
func (*NatsStreamingWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*NatsStreamingWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use NatsStreamingWriteArgs.ProtoReflect.Descriptor instead.
func (*NatsStreamingWriteArgs) GetChannel ¶ added in v0.0.47
func (x *NatsStreamingWriteArgs) GetChannel() string
func (*NatsStreamingWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*NatsStreamingWriteArgs) ProtoMessage()
func (*NatsStreamingWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *NatsStreamingWriteArgs) ProtoReflect() protoreflect.Message
func (*NatsStreamingWriteArgs) Reset ¶ added in v0.0.47
func (x *NatsStreamingWriteArgs) Reset()
func (*NatsStreamingWriteArgs) String ¶ added in v0.0.47
func (x *NatsStreamingWriteArgs) String() string
type NatsTLSOptions ¶ added in v0.0.125
type NatsTLSOptions struct { // @gotags: kong:"help='Whether to verify server certificate',env='PLUMBER_RELAY_NATS_SKIP_VERIFY_TLS'" TlsSkipVerify bool `` /* 195-byte string literal not displayed */ // @gotags: kong:"help='CA file (only needed if addr is tls://)',env='PLUMBER_RELAY_NATS_TLS_CA_CERT'" TlsCaCert string `` /* 181-byte string literal not displayed */ // @gotags: kong:"help='Client cert file (only needed if addr is tls://)',env='PLUMBER_RELAY_NATS_TLS_CLIENT_CERT'" TlsClientCert string `` /* 206-byte string literal not displayed */ // @gotags: kong:"help='client key file (only needed if addr is tls://)',env='PLUMBER_RELAY_NATS_TLS_CLIENT_KEY'" TlsClientKey string `` /* 201-byte string literal not displayed */ // @gotags: kong:"help='Enable TLS',env='PLUMBER_RELAY_NATS_USE_TLS'" UseTls bool `` /* 138-byte string literal not displayed */ // contains filtered or unexported fields }
func (*NatsTLSOptions) Descriptor
deprecated
added in
v0.0.125
func (*NatsTLSOptions) Descriptor() ([]byte, []int)
Deprecated: Use NatsTLSOptions.ProtoReflect.Descriptor instead.
func (*NatsTLSOptions) GetTlsCaCert ¶ added in v0.0.125
func (x *NatsTLSOptions) GetTlsCaCert() string
func (*NatsTLSOptions) GetTlsClientCert ¶ added in v0.0.125
func (x *NatsTLSOptions) GetTlsClientCert() string
func (*NatsTLSOptions) GetTlsClientKey ¶ added in v0.0.125
func (x *NatsTLSOptions) GetTlsClientKey() string
func (*NatsTLSOptions) GetTlsSkipVerify ¶ added in v0.0.125
func (x *NatsTLSOptions) GetTlsSkipVerify() bool
func (*NatsTLSOptions) GetUseTls ¶ added in v0.0.144
func (x *NatsTLSOptions) GetUseTls() bool
func (*NatsTLSOptions) ProtoMessage ¶ added in v0.0.125
func (*NatsTLSOptions) ProtoMessage()
func (*NatsTLSOptions) ProtoReflect ¶ added in v0.0.181
func (x *NatsTLSOptions) ProtoReflect() protoreflect.Message
func (*NatsTLSOptions) Reset ¶ added in v0.0.125
func (x *NatsTLSOptions) Reset()
func (*NatsTLSOptions) String ¶ added in v0.0.125
func (x *NatsTLSOptions) String() string
type NatsWriteArgs ¶ added in v0.0.47
type NatsWriteArgs struct { // @gotags: kong:"help='NATS Subject. Ex: foo.bar.*'" Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty" kong:"help='NATS Subject. Ex: foo.bar.*'"` // contains filtered or unexported fields }
func (*NatsWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*NatsWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use NatsWriteArgs.ProtoReflect.Descriptor instead.
func (*NatsWriteArgs) GetSubject ¶ added in v0.0.47
func (x *NatsWriteArgs) GetSubject() string
func (*NatsWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*NatsWriteArgs) ProtoMessage()
func (*NatsWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *NatsWriteArgs) ProtoReflect() protoreflect.Message
func (*NatsWriteArgs) Reset ¶ added in v0.0.47
func (x *NatsWriteArgs) Reset()
func (*NatsWriteArgs) String ¶ added in v0.0.47
func (x *NatsWriteArgs) String() string
type OffsetStart ¶ added in v0.0.69
type OffsetStart int32
const ( OffsetStart_LATEST OffsetStart = 0 OffsetStart_OLDEST OffsetStart = 1 )
func (OffsetStart) Descriptor ¶ added in v0.0.181
func (OffsetStart) Descriptor() protoreflect.EnumDescriptor
func (OffsetStart) Enum ¶ added in v0.0.181
func (x OffsetStart) Enum() *OffsetStart
func (OffsetStart) EnumDescriptor
deprecated
added in
v0.0.69
func (OffsetStart) EnumDescriptor() ([]byte, []int)
Deprecated: Use OffsetStart.Descriptor instead.
func (OffsetStart) Number ¶ added in v0.0.181
func (x OffsetStart) Number() protoreflect.EnumNumber
func (OffsetStart) String ¶ added in v0.0.69
func (x OffsetStart) String() string
func (OffsetStart) Type ¶ added in v0.0.181
func (OffsetStart) Type() protoreflect.EnumType
type PostgresConn ¶ added in v0.0.46
type PostgresConn struct { // @gotags: kong:"help='Postgres server hostname',env='PLUMBER_RELAY_CDCPOSTGRES_HOSTNAME',required" Address string `` /* 156-byte string literal not displayed */ // @gotags: kong:"help='Postgres port',env='PLUMBER_RELAY_CDCPOSTGRES_PORT',default=5432,required" Port uint32 `` /* 149-byte string literal not displayed */ // @gotags: kong:"help='Postgres username',env='PLUMBER_RELAY_CDCPOSTGRES_USERNAME',required" Username string `` /* 151-byte string literal not displayed */ // @gotags: kong:"help='Postgres server password',env='PLUMBER_RELAY_CDCPOSTGRES_PASSWORD'" Password string `` /* 149-byte string literal not displayed */ // @gotags: kong:"help='Postgres server database name',env='PLUMBER_RELAY_CDCPOSTGRES_DATABASE',required" Database string `` /* 163-byte string literal not displayed */ // @gotags: kong:"help='Enable TLS usage',env='PLUMBER_RELAY_CDCPOSTGRES_USE_TLS'" UseTls bool `` /* 151-byte string literal not displayed */ // @gotags: kong:"help='Whether to verify server certificate',env='PLUMBER_RELAY_CDCPOSTGRES_SKIP_VERIFY_TLS'" TlsSkipVerify bool `` /* 202-byte string literal not displayed */ // contains filtered or unexported fields }
func (*PostgresConn) Descriptor
deprecated
added in
v0.0.46
func (*PostgresConn) Descriptor() ([]byte, []int)
Deprecated: Use PostgresConn.ProtoReflect.Descriptor instead.
func (*PostgresConn) GetAddress ¶ added in v0.0.46
func (x *PostgresConn) GetAddress() string
func (*PostgresConn) GetDatabase ¶ added in v0.0.46
func (x *PostgresConn) GetDatabase() string
func (*PostgresConn) GetPassword ¶ added in v0.0.46
func (x *PostgresConn) GetPassword() string
func (*PostgresConn) GetPort ¶ added in v0.0.46
func (x *PostgresConn) GetPort() uint32
func (*PostgresConn) GetTlsSkipVerify ¶ added in v0.0.114
func (x *PostgresConn) GetTlsSkipVerify() bool
func (*PostgresConn) GetUseTls ¶ added in v0.0.46
func (x *PostgresConn) GetUseTls() bool
func (*PostgresConn) GetUsername ¶ added in v0.0.46
func (x *PostgresConn) GetUsername() string
func (*PostgresConn) ProtoMessage ¶ added in v0.0.46
func (*PostgresConn) ProtoMessage()
func (*PostgresConn) ProtoReflect ¶ added in v0.0.181
func (x *PostgresConn) ProtoReflect() protoreflect.Message
func (*PostgresConn) Reset ¶ added in v0.0.46
func (x *PostgresConn) Reset()
func (*PostgresConn) String ¶ added in v0.0.46
func (x *PostgresConn) String() string
type PostgresReadArgs ¶ added in v0.0.47
type PostgresReadArgs struct { // @gotags: kong:"help='CDC replication slot name',env='PLUMBER_RELAY_CDCPOSTGRES_SLOT',required" ReplicationSlotName string `` /* 206-byte string literal not displayed */ // @gotags: kong:"help='CDC publisher name',env='PLUMBER_RELAY_CDCPOSTGRES_PUBLISHER',required" PublisherName string `` /* 184-byte string literal not displayed */ // contains filtered or unexported fields }
func (*PostgresReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*PostgresReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use PostgresReadArgs.ProtoReflect.Descriptor instead.
func (*PostgresReadArgs) GetPublisherName ¶ added in v0.0.47
func (x *PostgresReadArgs) GetPublisherName() string
func (*PostgresReadArgs) GetReplicationSlotName ¶ added in v0.0.47
func (x *PostgresReadArgs) GetReplicationSlotName() string
func (*PostgresReadArgs) ProtoMessage ¶ added in v0.0.47
func (*PostgresReadArgs) ProtoMessage()
func (*PostgresReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *PostgresReadArgs) ProtoReflect() protoreflect.Message
func (*PostgresReadArgs) Reset ¶ added in v0.0.47
func (x *PostgresReadArgs) Reset()
func (*PostgresReadArgs) String ¶ added in v0.0.47
func (x *PostgresReadArgs) String() string
type PulsarConn ¶ added in v0.0.46
type PulsarConn struct { // @gotags: kong:"help='Full DSN to connect to Pulsar',default='pulsar://localhost:6650',required" Dsn string `` /* 146-byte string literal not displayed */ // @gotags: kong:"help='Connection timeout',default=10" ConnectTimeoutSeconds uint32 `` /* 171-byte string literal not displayed */ // @gotags: kong:"help='Whether to verify server certificate'" TlsSkipVerify bool `` /* 154-byte string literal not displayed */ // @gotags: kong:"help='TLS client certificate file'" TlsClientCert string `` /* 144-byte string literal not displayed */ // @gotags: kong:"help='TLS client key file'" TlsClientKey string `` /* 133-byte string literal not displayed */ // @gotags: kong:"help='Authentication token file'" Token string `protobuf:"bytes,6,opt,name=token,proto3" json:"token,omitempty" kong:"help='Authentication token file'"` // @gotags: kong:"help='Listener name'" ListenerName string `protobuf:"bytes,7,opt,name=listener_name,json=listenerName,proto3" json:"listener_name,omitempty" kong:"help='Listener name'"` // contains filtered or unexported fields }
func (*PulsarConn) Descriptor
deprecated
added in
v0.0.46
func (*PulsarConn) Descriptor() ([]byte, []int)
Deprecated: Use PulsarConn.ProtoReflect.Descriptor instead.
func (*PulsarConn) GetConnectTimeoutSeconds ¶ added in v0.0.46
func (x *PulsarConn) GetConnectTimeoutSeconds() uint32
func (*PulsarConn) GetDsn ¶ added in v0.0.46
func (x *PulsarConn) GetDsn() string
func (*PulsarConn) GetListenerName ¶ added in v0.0.176
func (x *PulsarConn) GetListenerName() string
func (*PulsarConn) GetTlsClientCert ¶ added in v0.0.46
func (x *PulsarConn) GetTlsClientCert() string
func (*PulsarConn) GetTlsClientKey ¶ added in v0.0.46
func (x *PulsarConn) GetTlsClientKey() string
func (*PulsarConn) GetTlsSkipVerify ¶ added in v0.0.114
func (x *PulsarConn) GetTlsSkipVerify() bool
func (*PulsarConn) GetToken ¶ added in v0.0.176
func (x *PulsarConn) GetToken() string
func (*PulsarConn) ProtoMessage ¶ added in v0.0.46
func (*PulsarConn) ProtoMessage()
func (*PulsarConn) ProtoReflect ¶ added in v0.0.181
func (x *PulsarConn) ProtoReflect() protoreflect.Message
func (*PulsarConn) Reset ¶ added in v0.0.46
func (x *PulsarConn) Reset()
func (*PulsarConn) String ¶ added in v0.0.46
func (x *PulsarConn) String() string
type PulsarReadArgs ¶ added in v0.0.47
type PulsarReadArgs struct { // @gotags: kong:"help='Topic to read messages from',required" Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='Topic to read messages from',required"` // @gotags: kong:"help='Subscription name',required" SubscriptionName string `` /* 150-byte string literal not displayed */ // @gotags: kong:"help='Subscription type (options: shared exclusive failover keyshared)',default=shared,type=pbenum,pbenum_lowercase" SubscriptionType SubscriptionType `` /* 267-byte string literal not displayed */ // @gotags: kong:"help='Subscription initial position (options: latest earliest)',default=latest,type=pbenum,pbenum_lowercase,pbenum_strip_prefix=PULSAR_" InitialPosition SubscriptionInitialPosition `` /* 295-byte string literal not displayed */ // contains filtered or unexported fields }
func (*PulsarReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*PulsarReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use PulsarReadArgs.ProtoReflect.Descriptor instead.
func (*PulsarReadArgs) GetInitialPosition ¶ added in v0.0.176
func (x *PulsarReadArgs) GetInitialPosition() SubscriptionInitialPosition
func (*PulsarReadArgs) GetSubscriptionName ¶ added in v0.0.47
func (x *PulsarReadArgs) GetSubscriptionName() string
func (*PulsarReadArgs) GetSubscriptionType ¶ added in v0.0.47
func (x *PulsarReadArgs) GetSubscriptionType() SubscriptionType
func (*PulsarReadArgs) GetTopic ¶ added in v0.0.47
func (x *PulsarReadArgs) GetTopic() string
func (*PulsarReadArgs) ProtoMessage ¶ added in v0.0.47
func (*PulsarReadArgs) ProtoMessage()
func (*PulsarReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *PulsarReadArgs) ProtoReflect() protoreflect.Message
func (*PulsarReadArgs) Reset ¶ added in v0.0.47
func (x *PulsarReadArgs) Reset()
func (*PulsarReadArgs) String ¶ added in v0.0.47
func (x *PulsarReadArgs) String() string
type PulsarWriteArgs ¶ added in v0.0.47
type PulsarWriteArgs struct { // @gotags: kong:"help='topic to write messages to'" Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty" kong:"help='topic to write messages to'"` // contains filtered or unexported fields }
func (*PulsarWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*PulsarWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use PulsarWriteArgs.ProtoReflect.Descriptor instead.
func (*PulsarWriteArgs) GetTopic ¶ added in v0.0.47
func (x *PulsarWriteArgs) GetTopic() string
func (*PulsarWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*PulsarWriteArgs) ProtoMessage()
func (*PulsarWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *PulsarWriteArgs) ProtoReflect() protoreflect.Message
func (*PulsarWriteArgs) Reset ¶ added in v0.0.47
func (x *PulsarWriteArgs) Reset()
func (*PulsarWriteArgs) String ¶ added in v0.0.47
func (x *PulsarWriteArgs) String() string
type RabbitConn ¶ added in v0.0.46
type RabbitConn struct { // @gotags: kong:"help='Destination host address (full DSN)',env='PLUMBER_RELAY_RABBIT_ADDRESS',default='amqp://localhost',required" Address string `` /* 188-byte string literal not displayed */ // @gotags: kong:"help='Force TLS usage (regardless of DSN)',env='PLUMBER_RELAY_RABBIT_USE_TLS'" UseTls bool `` /* 165-byte string literal not displayed */ // @gotags: kong:"help='Whether to verify server TLS certificate',env='PLUMBER_RELAY_RABBIT_SKIP_VERIFY_TLS'" TlsSkipVerify bool `` /* 201-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RabbitConn) Descriptor
deprecated
added in
v0.0.46
func (*RabbitConn) Descriptor() ([]byte, []int)
Deprecated: Use RabbitConn.ProtoReflect.Descriptor instead.
func (*RabbitConn) GetAddress ¶ added in v0.0.46
func (x *RabbitConn) GetAddress() string
func (*RabbitConn) GetTlsSkipVerify ¶ added in v0.0.114
func (x *RabbitConn) GetTlsSkipVerify() bool
func (*RabbitConn) GetUseTls ¶ added in v0.0.46
func (x *RabbitConn) GetUseTls() bool
func (*RabbitConn) ProtoMessage ¶ added in v0.0.46
func (*RabbitConn) ProtoMessage()
func (*RabbitConn) ProtoReflect ¶ added in v0.0.181
func (x *RabbitConn) ProtoReflect() protoreflect.Message
func (*RabbitConn) Reset ¶ added in v0.0.46
func (x *RabbitConn) Reset()
func (*RabbitConn) String ¶ added in v0.0.46
func (x *RabbitConn) String() string
type RabbitReadArgs ¶ added in v0.0.47
type RabbitReadArgs struct { // @gotags: kong:"help='Name of the exchange',env='PLUMBER_RELAY_RABBIT_EXCHANGE',required" ExchangeName string `` /* 177-byte string literal not displayed */ // @gotags: kong:"help='Name of the queue where messages will be routed to',env='PLUMBER_RELAY_RABBIT_QUEUE',required" QueueName string `` /* 195-byte string literal not displayed */ // @gotags: kong:"help='Binding key for topic based exchanges',env='PLUMBER_RELAY_RABBIT_ROUTING_KEY',required" BindingKey string `` /* 191-byte string literal not displayed */ // @gotags: kong:"help='Whether plumber should be the only one using the queue',env='PLUMBER_RELAY_RABBIT_QUEUE_EXCLUSIVE'" QueueExclusive bool `` /* 216-byte string literal not displayed */ // @gotags: kong:"help='Whether to create/declare the queue (if it does not exist)',env='PLUMBER_RELAY_RABBIT_QUEUE_DECLARE',default=true" QueueDeclare bool `` /* 225-byte string literal not displayed */ // @gotags: kong:"help='Whether the queue should survive after disconnect',env='PLUMBER_RELAY_RABBIT_QUEUE_DURABLE'" QueueDurable bool `` /* 203-byte string literal not displayed */ // @gotags: kong:"help='Automatically acknowledge receipt of read/received messages',env='PLUMBER_RELAY_RABBIT_AUTOACK',default=true" AutoAck bool `` /* 205-byte string literal not displayed */ // @gotags: kong:"help='How to identify the consumer to RabbitMQ',env='PLUMBER_RELAY_CONSUMER_TAG',default=plumber" ConsumerTag string `` /* 198-byte string literal not displayed */ // @gotags: kong:"help='Whether to auto-delete the queue after plumber has disconnected',env='PLUMBER_RELAY_RABBIT_QUEUE_AUTO_DELETE',default=true" QueueDelete bool `` /* 231-byte string literal not displayed */ // @gotags: kong:"help='Key=Value pair for sending additional queue argument to RabbitMQ. Example: --queue-arg x-dead-letter-exchange=mydlexchange --queue-arg x-queue-mode=lazy',env='PLUMBER_RELAY_RABBIT_QUEUE_ARGS'" QueueArg map[string]string `` /* 379-byte string literal not displayed */ // @gotags: kong:"help='Exclude messages with routing key matching regex',env='PLUMBER_RELAY_RABBIT_BINDING_KEY_EXCLUDE_REGEX'" ExcludeBindingKeyRegex string `` /* 248-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RabbitReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*RabbitReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use RabbitReadArgs.ProtoReflect.Descriptor instead.
func (*RabbitReadArgs) GetAutoAck ¶ added in v0.0.47
func (x *RabbitReadArgs) GetAutoAck() bool
func (*RabbitReadArgs) GetBindingKey ¶ added in v0.0.47
func (x *RabbitReadArgs) GetBindingKey() string
func (*RabbitReadArgs) GetConsumerTag ¶ added in v0.0.47
func (x *RabbitReadArgs) GetConsumerTag() string
func (*RabbitReadArgs) GetExchangeName ¶ added in v0.0.47
func (x *RabbitReadArgs) GetExchangeName() string
func (*RabbitReadArgs) GetExcludeBindingKeyRegex ¶ added in v0.0.172
func (x *RabbitReadArgs) GetExcludeBindingKeyRegex() string
func (*RabbitReadArgs) GetQueueArg ¶ added in v0.0.118
func (x *RabbitReadArgs) GetQueueArg() map[string]string
func (*RabbitReadArgs) GetQueueDeclare ¶ added in v0.0.47
func (x *RabbitReadArgs) GetQueueDeclare() bool
func (*RabbitReadArgs) GetQueueDelete ¶ added in v0.0.47
func (x *RabbitReadArgs) GetQueueDelete() bool
func (*RabbitReadArgs) GetQueueDurable ¶ added in v0.0.47
func (x *RabbitReadArgs) GetQueueDurable() bool
func (*RabbitReadArgs) GetQueueExclusive ¶ added in v0.0.47
func (x *RabbitReadArgs) GetQueueExclusive() bool
func (*RabbitReadArgs) GetQueueName ¶ added in v0.0.47
func (x *RabbitReadArgs) GetQueueName() string
func (*RabbitReadArgs) ProtoMessage ¶ added in v0.0.47
func (*RabbitReadArgs) ProtoMessage()
func (*RabbitReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *RabbitReadArgs) ProtoReflect() protoreflect.Message
func (*RabbitReadArgs) Reset ¶ added in v0.0.47
func (x *RabbitReadArgs) Reset()
func (*RabbitReadArgs) String ¶ added in v0.0.47
func (x *RabbitReadArgs) String() string
type RabbitStreamsConn ¶ added in v0.0.46
type RabbitStreamsConn struct { // @gotags: kong:"help='DSN used to connect to RabbitMQ',default='rabbitmq-stream://guest:guest@localhost:5552',required" Dsn string `` /* 169-byte string literal not displayed */ // @gotags: kong:"help='Enable TLS usage (regardless of DSN)'" UseTls bool `` /* 131-byte string literal not displayed */ // @gotags: kong:"help='Whether to verify server certificate'" TlsSkipVerify bool `` /* 154-byte string literal not displayed */ // @gotags: kong:"help='Username to authenticate to server with',default=guest" Username string `` /* 137-byte string literal not displayed */ // @gotags: kong:"help='Password used to authenticate to server with',default=guest" Password string `` /* 142-byte string literal not displayed */ // @gotags: kong:"help='Consumer or producer name to identify as to RabbitMQ',default=plumber,required" ClientName string `` /* 183-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RabbitStreamsConn) Descriptor
deprecated
added in
v0.0.46
func (*RabbitStreamsConn) Descriptor() ([]byte, []int)
Deprecated: Use RabbitStreamsConn.ProtoReflect.Descriptor instead.
func (*RabbitStreamsConn) GetClientName ¶ added in v0.0.46
func (x *RabbitStreamsConn) GetClientName() string
func (*RabbitStreamsConn) GetDsn ¶ added in v0.0.46
func (x *RabbitStreamsConn) GetDsn() string
func (*RabbitStreamsConn) GetPassword ¶ added in v0.0.46
func (x *RabbitStreamsConn) GetPassword() string
func (*RabbitStreamsConn) GetTlsSkipVerify ¶ added in v0.0.114
func (x *RabbitStreamsConn) GetTlsSkipVerify() bool
func (*RabbitStreamsConn) GetUseTls ¶ added in v0.0.46
func (x *RabbitStreamsConn) GetUseTls() bool
func (*RabbitStreamsConn) GetUsername ¶ added in v0.0.46
func (x *RabbitStreamsConn) GetUsername() string
func (*RabbitStreamsConn) ProtoMessage ¶ added in v0.0.46
func (*RabbitStreamsConn) ProtoMessage()
func (*RabbitStreamsConn) ProtoReflect ¶ added in v0.0.181
func (x *RabbitStreamsConn) ProtoReflect() protoreflect.Message
func (*RabbitStreamsConn) Reset ¶ added in v0.0.46
func (x *RabbitStreamsConn) Reset()
func (*RabbitStreamsConn) String ¶ added in v0.0.46
func (x *RabbitStreamsConn) String() string
type RabbitStreamsOffsetOptions ¶ added in v0.0.46
type RabbitStreamsOffsetOptions struct { // @gotags: kong:"group=offset,xor=offset" SpecificOffset int64 `` /* 135-byte string literal not displayed */ // @gotags: kong:"group=offset,xor=offset" LastOffset bool `protobuf:"varint,2,opt,name=last_offset,json=lastOffset,proto3" json:"last_offset,omitempty" kong:"group=offset,xor=offset"` // @gotags: kong:"group=offset,xor=offset" LastConsumed bool `` /* 129-byte string literal not displayed */ // @gotags: kong:"group=offset,xor=offset" FirstOffset bool `` /* 126-byte string literal not displayed */ // @gotags: kong:"group=offset,xor=offset" NextOffset bool `protobuf:"varint,5,opt,name=next_offset,json=nextOffset,proto3" json:"next_offset,omitempty" kong:"group=offset,xor=offset"` // contains filtered or unexported fields }
func (*RabbitStreamsOffsetOptions) Descriptor
deprecated
added in
v0.0.46
func (*RabbitStreamsOffsetOptions) Descriptor() ([]byte, []int)
Deprecated: Use RabbitStreamsOffsetOptions.ProtoReflect.Descriptor instead.
func (*RabbitStreamsOffsetOptions) GetFirstOffset ¶ added in v0.0.46
func (x *RabbitStreamsOffsetOptions) GetFirstOffset() bool
func (*RabbitStreamsOffsetOptions) GetLastConsumed ¶ added in v0.0.46
func (x *RabbitStreamsOffsetOptions) GetLastConsumed() bool
func (*RabbitStreamsOffsetOptions) GetLastOffset ¶ added in v0.0.46
func (x *RabbitStreamsOffsetOptions) GetLastOffset() bool
func (*RabbitStreamsOffsetOptions) GetNextOffset ¶ added in v0.0.46
func (x *RabbitStreamsOffsetOptions) GetNextOffset() bool
func (*RabbitStreamsOffsetOptions) GetSpecificOffset ¶ added in v0.0.46
func (x *RabbitStreamsOffsetOptions) GetSpecificOffset() int64
func (*RabbitStreamsOffsetOptions) ProtoMessage ¶ added in v0.0.46
func (*RabbitStreamsOffsetOptions) ProtoMessage()
func (*RabbitStreamsOffsetOptions) ProtoReflect ¶ added in v0.0.181
func (x *RabbitStreamsOffsetOptions) ProtoReflect() protoreflect.Message
func (*RabbitStreamsOffsetOptions) Reset ¶ added in v0.0.46
func (x *RabbitStreamsOffsetOptions) Reset()
func (*RabbitStreamsOffsetOptions) String ¶ added in v0.0.46
func (x *RabbitStreamsOffsetOptions) String() string
type RabbitStreamsReadArgs ¶ added in v0.0.47
type RabbitStreamsReadArgs struct { // @gotags: kong:"help='Stream name',required" Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty" kong:"help='Stream name',required"` // @gotags: kong:"help='Declare the stream if it does not exist'" DeclareStream bool `` /* 155-byte string literal not displayed */ // @gotags: kong:"help='Stream capacity to declare (required if declare_stream is true; ex: 1024k; 10mb; 3gb)'" DeclareStreamSize string `` /* 214-byte string literal not displayed */ // TODO: Will this break? Might just need to be a string. // @gotags: kong:"help='Offset to start reading at',embed" OffsetOptions *RabbitStreamsOffsetOptions `` /* 147-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RabbitStreamsReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*RabbitStreamsReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use RabbitStreamsReadArgs.ProtoReflect.Descriptor instead.
func (*RabbitStreamsReadArgs) GetDeclareStream ¶ added in v0.0.47
func (x *RabbitStreamsReadArgs) GetDeclareStream() bool
func (*RabbitStreamsReadArgs) GetDeclareStreamSize ¶ added in v0.0.47
func (x *RabbitStreamsReadArgs) GetDeclareStreamSize() string
func (*RabbitStreamsReadArgs) GetOffsetOptions ¶ added in v0.0.47
func (x *RabbitStreamsReadArgs) GetOffsetOptions() *RabbitStreamsOffsetOptions
func (*RabbitStreamsReadArgs) GetStream ¶ added in v0.0.47
func (x *RabbitStreamsReadArgs) GetStream() string
func (*RabbitStreamsReadArgs) ProtoMessage ¶ added in v0.0.47
func (*RabbitStreamsReadArgs) ProtoMessage()
func (*RabbitStreamsReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *RabbitStreamsReadArgs) ProtoReflect() protoreflect.Message
func (*RabbitStreamsReadArgs) Reset ¶ added in v0.0.47
func (x *RabbitStreamsReadArgs) Reset()
func (*RabbitStreamsReadArgs) String ¶ added in v0.0.47
func (x *RabbitStreamsReadArgs) String() string
type RabbitStreamsWriteArgs ¶ added in v0.0.47
type RabbitStreamsWriteArgs struct { // @gotags: kong:"help='Stream name',required" Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty" kong:"help='Stream name',required"` // @gotags: kong:"help='Declare the stream if it does not exist'" DeclareStream bool `` /* 155-byte string literal not displayed */ // @gotags: kong:"help='Stream capacity to declare (required if declare_stream is true; ex: 1024k, 10mb, 3gb',default=10mb" DeclareStreamSize string `` /* 226-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RabbitStreamsWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*RabbitStreamsWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use RabbitStreamsWriteArgs.ProtoReflect.Descriptor instead.
func (*RabbitStreamsWriteArgs) GetDeclareStream ¶ added in v0.0.47
func (x *RabbitStreamsWriteArgs) GetDeclareStream() bool
func (*RabbitStreamsWriteArgs) GetDeclareStreamSize ¶ added in v0.0.47
func (x *RabbitStreamsWriteArgs) GetDeclareStreamSize() string
func (*RabbitStreamsWriteArgs) GetStream ¶ added in v0.0.47
func (x *RabbitStreamsWriteArgs) GetStream() string
func (*RabbitStreamsWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*RabbitStreamsWriteArgs) ProtoMessage()
func (*RabbitStreamsWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *RabbitStreamsWriteArgs) ProtoReflect() protoreflect.Message
func (*RabbitStreamsWriteArgs) Reset ¶ added in v0.0.47
func (x *RabbitStreamsWriteArgs) Reset()
func (*RabbitStreamsWriteArgs) String ¶ added in v0.0.47
func (x *RabbitStreamsWriteArgs) String() string
type RabbitWriteArgs ¶ added in v0.0.47
type RabbitWriteArgs struct { // @gotags: kong:"help='Exchange to write message(s) to',required" ExchangeName string `` /* 152-byte string literal not displayed */ // @gotags: kong:"help='Routing key to write message(s) to',required" RoutingKey string `` /* 149-byte string literal not displayed */ // @gotags: kong:"help='Fills message properties $app_id with this value',default=plumber" AppId string `` /* 148-byte string literal not displayed */ // @gotags: kong:"help='The type of exchange we are working with',enum='direct,topic,headers,fanout',default=topic,group=exchange" ExchangeType string `` /* 216-byte string literal not displayed */ // @gotags: kong:"help='Whether to declare an exchange (if it does not exist)',group=exchange" ExchangeDeclare bool `` /* 190-byte string literal not displayed */ // @gotags: kong:"help='Whether to make a declared exchange durable',group=exchange" ExchangeDurable bool `` /* 180-byte string literal not displayed */ // @gotags: kong:"help='Whether to auto-delete the exchange (after writes)',group=exchange" ExchangeAutoDelete bool `` /* 198-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RabbitWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*RabbitWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use RabbitWriteArgs.ProtoReflect.Descriptor instead.
func (*RabbitWriteArgs) GetAppId ¶ added in v0.0.47
func (x *RabbitWriteArgs) GetAppId() string
func (*RabbitWriteArgs) GetExchangeAutoDelete ¶ added in v0.0.54
func (x *RabbitWriteArgs) GetExchangeAutoDelete() bool
func (*RabbitWriteArgs) GetExchangeDeclare ¶ added in v0.0.54
func (x *RabbitWriteArgs) GetExchangeDeclare() bool
func (*RabbitWriteArgs) GetExchangeDurable ¶ added in v0.0.54
func (x *RabbitWriteArgs) GetExchangeDurable() bool
func (*RabbitWriteArgs) GetExchangeName ¶ added in v0.0.47
func (x *RabbitWriteArgs) GetExchangeName() string
func (*RabbitWriteArgs) GetExchangeType ¶ added in v0.0.54
func (x *RabbitWriteArgs) GetExchangeType() string
func (*RabbitWriteArgs) GetRoutingKey ¶ added in v0.0.47
func (x *RabbitWriteArgs) GetRoutingKey() string
func (*RabbitWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*RabbitWriteArgs) ProtoMessage()
func (*RabbitWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *RabbitWriteArgs) ProtoReflect() protoreflect.Message
func (*RabbitWriteArgs) Reset ¶ added in v0.0.47
func (x *RabbitWriteArgs) Reset()
func (*RabbitWriteArgs) String ¶ added in v0.0.47
func (x *RabbitWriteArgs) String() string
type RedisPubSubConn ¶ added in v0.0.46
type RedisPubSubConn struct { // @gotags: kong:"help='Address of redis server',env='PLUMBER_RELAY_REDIS_PUBSUB_ADDRESS',default=localhost:6379" Address string `` /* 169-byte string literal not displayed */ // @gotags: kong:"help='Optional username to auth with (redis >= v6.0.0)',env='PLUMBER_RELAY_REDIS_PUBSUB_USERNAME'" Username string `` /* 174-byte string literal not displayed */ // @gotags: kong:"help='Optional password to auth with (redis >= v6.0.0)',env='PLUMBER_RELAY_REDIS_PUBSUB_PASSWORD'" Password string `` /* 174-byte string literal not displayed */ // @gotags: kong:"help='Database (0-16)',env='PLUMBER_RELAY_REDIS_PUBSUB_DATABASE'" Database uint32 `` /* 142-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RedisPubSubConn) Descriptor
deprecated
added in
v0.0.46
func (*RedisPubSubConn) Descriptor() ([]byte, []int)
Deprecated: Use RedisPubSubConn.ProtoReflect.Descriptor instead.
func (*RedisPubSubConn) GetAddress ¶ added in v0.0.46
func (x *RedisPubSubConn) GetAddress() string
func (*RedisPubSubConn) GetDatabase ¶ added in v0.0.96
func (x *RedisPubSubConn) GetDatabase() uint32
func (*RedisPubSubConn) GetPassword ¶ added in v0.0.46
func (x *RedisPubSubConn) GetPassword() string
func (*RedisPubSubConn) GetUsername ¶ added in v0.0.46
func (x *RedisPubSubConn) GetUsername() string
func (*RedisPubSubConn) ProtoMessage ¶ added in v0.0.46
func (*RedisPubSubConn) ProtoMessage()
func (*RedisPubSubConn) ProtoReflect ¶ added in v0.0.181
func (x *RedisPubSubConn) ProtoReflect() protoreflect.Message
func (*RedisPubSubConn) Reset ¶ added in v0.0.46
func (x *RedisPubSubConn) Reset()
func (*RedisPubSubConn) String ¶ added in v0.0.46
func (x *RedisPubSubConn) String() string
type RedisPubSubReadArgs ¶ added in v0.0.47
type RedisPubSubReadArgs struct { // @gotags: kong:"help='Comma separated list of channels to read from',env='PLUMBER_RELAY_REDIS_PUBSUB_CHANNELS',required" Channels []string `` /* 180-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RedisPubSubReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*RedisPubSubReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use RedisPubSubReadArgs.ProtoReflect.Descriptor instead.
func (*RedisPubSubReadArgs) GetChannels ¶ added in v0.0.114
func (x *RedisPubSubReadArgs) GetChannels() []string
func (*RedisPubSubReadArgs) ProtoMessage ¶ added in v0.0.47
func (*RedisPubSubReadArgs) ProtoMessage()
func (*RedisPubSubReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *RedisPubSubReadArgs) ProtoReflect() protoreflect.Message
func (*RedisPubSubReadArgs) Reset ¶ added in v0.0.47
func (x *RedisPubSubReadArgs) Reset()
func (*RedisPubSubReadArgs) String ¶ added in v0.0.47
func (x *RedisPubSubReadArgs) String() string
type RedisPubSubWriteArgs ¶ added in v0.0.47
type RedisPubSubWriteArgs struct { // @gotags: kong:"help='Comma separated list of channels to write to',required" Channels []string `` /* 137-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RedisPubSubWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*RedisPubSubWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use RedisPubSubWriteArgs.ProtoReflect.Descriptor instead.
func (*RedisPubSubWriteArgs) GetChannels ¶ added in v0.0.114
func (x *RedisPubSubWriteArgs) GetChannels() []string
func (*RedisPubSubWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*RedisPubSubWriteArgs) ProtoMessage()
func (*RedisPubSubWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *RedisPubSubWriteArgs) ProtoReflect() protoreflect.Message
func (*RedisPubSubWriteArgs) Reset ¶ added in v0.0.47
func (x *RedisPubSubWriteArgs) Reset()
func (*RedisPubSubWriteArgs) String ¶ added in v0.0.47
func (x *RedisPubSubWriteArgs) String() string
type RedisStreamsConn ¶ added in v0.0.46
type RedisStreamsConn struct { // @gotags: kong:"help='Address of redis server',default=localhost:6379,required,env='PLUMBER_RELAY_REDIS_STREAMS_ADDRESS'" Address string `` /* 179-byte string literal not displayed */ // @gotags: kong:"help='Username (redis >= v6.0.0)',env='PLUMBER_RELAY_REDIS_STREAMS_USERNAME'" Username string `` /* 153-byte string literal not displayed */ // @gotags: kong:"help='Password (redis >= v6.0.0)',env='PLUMBER_RELAY_REDIS_STREAMS_PASSWORD'" Password string `` /* 153-byte string literal not displayed */ // @gotags: kong:"help='Database (0-16)',env='PLUMBER_RELAY_REDIS_PUBSUB_DATABASE'" Database uint32 `` /* 142-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RedisStreamsConn) Descriptor
deprecated
added in
v0.0.46
func (*RedisStreamsConn) Descriptor() ([]byte, []int)
Deprecated: Use RedisStreamsConn.ProtoReflect.Descriptor instead.
func (*RedisStreamsConn) GetAddress ¶ added in v0.0.46
func (x *RedisStreamsConn) GetAddress() string
func (*RedisStreamsConn) GetDatabase ¶ added in v0.0.96
func (x *RedisStreamsConn) GetDatabase() uint32
func (*RedisStreamsConn) GetPassword ¶ added in v0.0.46
func (x *RedisStreamsConn) GetPassword() string
func (*RedisStreamsConn) GetUsername ¶ added in v0.0.46
func (x *RedisStreamsConn) GetUsername() string
func (*RedisStreamsConn) ProtoMessage ¶ added in v0.0.46
func (*RedisStreamsConn) ProtoMessage()
func (*RedisStreamsConn) ProtoReflect ¶ added in v0.0.181
func (x *RedisStreamsConn) ProtoReflect() protoreflect.Message
func (*RedisStreamsConn) Reset ¶ added in v0.0.46
func (x *RedisStreamsConn) Reset()
func (*RedisStreamsConn) String ¶ added in v0.0.46
func (x *RedisStreamsConn) String() string
type RedisStreamsReadArgs ¶ added in v0.0.47
type RedisStreamsReadArgs struct { // @gotags: kong:"help='Streams to read from',required,env='PLUMBER_RELAY_REDIS_STREAMS_STREAMS'" Streams []string `` /* 153-byte string literal not displayed */ // @gotags: kong:"help='Consumer group name',env='PLUMBER_RELAY_REDIS_STREAMS_CONSUMER_GROUP',default=plumber" ConsumerGroup string `` /* 199-byte string literal not displayed */ // @gotags: kong:"help='Consumer name',env='PLUMBER_RELAY_REDIS_STREAMS_CONSUMER_NAME',default=plumber-consumer-1" ConsumerName string `` /* 200-byte string literal not displayed */ // @gotags: kong:"help='Number of records to read from stream(s) per read',env='PLUMBER_RELAY_REDIS_STREAMS_COUNT',default=10" Count uint32 `` /* 179-byte string literal not displayed */ // @gotags: kong:"embed" CreateConsumerConfig *CreateConsumerConfig `` /* 136-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RedisStreamsReadArgs) Descriptor
deprecated
added in
v0.0.47
func (*RedisStreamsReadArgs) Descriptor() ([]byte, []int)
Deprecated: Use RedisStreamsReadArgs.ProtoReflect.Descriptor instead.
func (*RedisStreamsReadArgs) GetConsumerGroup ¶ added in v0.0.47
func (x *RedisStreamsReadArgs) GetConsumerGroup() string
func (*RedisStreamsReadArgs) GetConsumerName ¶ added in v0.0.47
func (x *RedisStreamsReadArgs) GetConsumerName() string
func (*RedisStreamsReadArgs) GetCount ¶ added in v0.0.47
func (x *RedisStreamsReadArgs) GetCount() uint32
func (*RedisStreamsReadArgs) GetCreateConsumerConfig ¶ added in v0.0.47
func (x *RedisStreamsReadArgs) GetCreateConsumerConfig() *CreateConsumerConfig
func (*RedisStreamsReadArgs) GetStreams ¶ added in v0.0.114
func (x *RedisStreamsReadArgs) GetStreams() []string
func (*RedisStreamsReadArgs) ProtoMessage ¶ added in v0.0.47
func (*RedisStreamsReadArgs) ProtoMessage()
func (*RedisStreamsReadArgs) ProtoReflect ¶ added in v0.0.181
func (x *RedisStreamsReadArgs) ProtoReflect() protoreflect.Message
func (*RedisStreamsReadArgs) Reset ¶ added in v0.0.47
func (x *RedisStreamsReadArgs) Reset()
func (*RedisStreamsReadArgs) String ¶ added in v0.0.47
func (x *RedisStreamsReadArgs) String() string
type RedisStreamsWriteArgs ¶ added in v0.0.47
type RedisStreamsWriteArgs struct { // @gotags: kong:"help='What redis ID to use for input data (* = auto-generate)',default='*'" WriteId string `` /* 164-byte string literal not displayed */ // @gotags: kong:"help='Streams to write to'" Streams []string `protobuf:"bytes,2,rep,name=streams,proto3" json:"streams,omitempty" kong:"help='Streams to write to'"` // @gotags: kong:"help='Key name to write input data to'" Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty" kong:"help='Key name to write input data to'"` // contains filtered or unexported fields }
func (*RedisStreamsWriteArgs) Descriptor
deprecated
added in
v0.0.47
func (*RedisStreamsWriteArgs) Descriptor() ([]byte, []int)
Deprecated: Use RedisStreamsWriteArgs.ProtoReflect.Descriptor instead.
func (*RedisStreamsWriteArgs) GetKey ¶ added in v0.0.47
func (x *RedisStreamsWriteArgs) GetKey() string
func (*RedisStreamsWriteArgs) GetStreams ¶ added in v0.0.47
func (x *RedisStreamsWriteArgs) GetStreams() []string
func (*RedisStreamsWriteArgs) GetWriteId ¶ added in v0.0.47
func (x *RedisStreamsWriteArgs) GetWriteId() string
func (*RedisStreamsWriteArgs) ProtoMessage ¶ added in v0.0.47
func (*RedisStreamsWriteArgs) ProtoMessage()
func (*RedisStreamsWriteArgs) ProtoReflect ¶ added in v0.0.181
func (x *RedisStreamsWriteArgs) ProtoReflect() protoreflect.Message
func (*RedisStreamsWriteArgs) Reset ¶ added in v0.0.47
func (x *RedisStreamsWriteArgs) Reset()
func (*RedisStreamsWriteArgs) String ¶ added in v0.0.47
func (x *RedisStreamsWriteArgs) String() string
type SASLType ¶ added in v0.0.69
type SASLType int32
func (SASLType) Descriptor ¶ added in v0.0.181
func (SASLType) Descriptor() protoreflect.EnumDescriptor
func (SASLType) EnumDescriptor
deprecated
added in
v0.0.69
func (SASLType) Number ¶ added in v0.0.181
func (x SASLType) Number() protoreflect.EnumNumber
func (SASLType) Type ¶ added in v0.0.181
func (SASLType) Type() protoreflect.EnumType
type SubscriptionInitialPosition ¶ added in v0.0.176
type SubscriptionInitialPosition int32
const ( SubscriptionInitialPosition_PULSAR_LATEST SubscriptionInitialPosition = 0 SubscriptionInitialPosition_PULSAR_EARLIEST SubscriptionInitialPosition = 1 )
func (SubscriptionInitialPosition) Descriptor ¶ added in v0.0.181
func (SubscriptionInitialPosition) Descriptor() protoreflect.EnumDescriptor
func (SubscriptionInitialPosition) Enum ¶ added in v0.0.181
func (x SubscriptionInitialPosition) Enum() *SubscriptionInitialPosition
func (SubscriptionInitialPosition) EnumDescriptor
deprecated
added in
v0.0.176
func (SubscriptionInitialPosition) EnumDescriptor() ([]byte, []int)
Deprecated: Use SubscriptionInitialPosition.Descriptor instead.
func (SubscriptionInitialPosition) Number ¶ added in v0.0.181
func (x SubscriptionInitialPosition) Number() protoreflect.EnumNumber
func (SubscriptionInitialPosition) String ¶ added in v0.0.176
func (x SubscriptionInitialPosition) String() string
func (SubscriptionInitialPosition) Type ¶ added in v0.0.181
func (SubscriptionInitialPosition) Type() protoreflect.EnumType
type SubscriptionType ¶ added in v0.0.46
type SubscriptionType int32
const ( SubscriptionType_SHARED SubscriptionType = 0 SubscriptionType_EXCLUSIVE SubscriptionType = 1 SubscriptionType_FAILOVER SubscriptionType = 2 SubscriptionType_KEYSHARED SubscriptionType = 3 )
func (SubscriptionType) Descriptor ¶ added in v0.0.181
func (SubscriptionType) Descriptor() protoreflect.EnumDescriptor
func (SubscriptionType) Enum ¶ added in v0.0.181
func (x SubscriptionType) Enum() *SubscriptionType
func (SubscriptionType) EnumDescriptor
deprecated
added in
v0.0.46
func (SubscriptionType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SubscriptionType.Descriptor instead.
func (SubscriptionType) Number ¶ added in v0.0.181
func (x SubscriptionType) Number() protoreflect.EnumNumber
func (SubscriptionType) String ¶ added in v0.0.46
func (x SubscriptionType) String() string
func (SubscriptionType) Type ¶ added in v0.0.181
func (SubscriptionType) Type() protoreflect.EnumType
Source Files ¶
- 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