backends

package

Go to main page

Versions in this module

v0

v0.0.45

Sep 2, 2021

v0.0.44

Sep 1, 2021

v0.0.43

Sep 1, 2021

v0.0.42

Sep 1, 2021

Changes in this version

+ var KafkaConn_SASLType_name = map[int32]string

+ var KafkaConn_SASLType_value = map[string]int32

+ var MQTTQoSLevel_name = map[int32]string

+ var MQTTQoSLevel_value = map[string]int32

+ var Type_name = map[int32]string

+ var Type_value = map[string]int32

+ type AWSSNSConn struct

+ AwsAccessKeyId string

+ AwsRegion string

+ AwsSecretAccessKey string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AWSSNSConn) ProtoMessage()

+ func (m *AWSSNSConn) GetAwsAccessKeyId() string

+ func (m *AWSSNSConn) GetAwsRegion() string

+ func (m *AWSSNSConn) GetAwsSecretAccessKey() string

+ func (m *AWSSNSConn) Reset()

+ func (m *AWSSNSConn) String() string

+ func (m *AWSSNSConn) XXX_DiscardUnknown()

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

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

+ func (m *AWSSNSConn) XXX_Size() int

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

+ type AWSSNSWriteArgs struct

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AWSSNSWriteArgs) ProtoMessage()

+ func (m *AWSSNSWriteArgs) GetTopic() string

+ func (m *AWSSNSWriteArgs) Reset()

+ func (m *AWSSNSWriteArgs) String() string

+ func (m *AWSSNSWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *AWSSNSWriteArgs) XXX_Size() int

+ func (m *AWSSNSWriteArgs) XXX_Unmarshal(b []byte) error

+ type AWSSQSConn struct

+ AwsAccessKeyId string

+ AwsRegion string

+ AwsSecretAccessKey string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AWSSQSConn) ProtoMessage()

+ func (m *AWSSQSConn) GetAwsAccessKeyId() string

+ func (m *AWSSQSConn) GetAwsRegion() string

+ func (m *AWSSQSConn) GetAwsSecretAccessKey() string

+ func (m *AWSSQSConn) Reset()

+ func (m *AWSSQSConn) String() string

+ func (m *AWSSQSConn) XXX_DiscardUnknown()

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

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

+ func (m *AWSSQSConn) XXX_Size() int

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

+ type AWSSQSReadArgs struct

+ AutoDelete bool

+ MaxNumMessages uint32

+ QueueName string

+ ReceiveRequestAttemptId string

+ RemoteAccountId string

+ WaitTimeSeconds uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AWSSQSReadArgs) ProtoMessage()

+ func (m *AWSSQSReadArgs) GetAutoDelete() bool

+ func (m *AWSSQSReadArgs) GetMaxNumMessages() uint32

+ func (m *AWSSQSReadArgs) GetQueueName() string

+ func (m *AWSSQSReadArgs) GetReceiveRequestAttemptId() string

+ func (m *AWSSQSReadArgs) GetRemoteAccountId() string

+ func (m *AWSSQSReadArgs) GetWaitTimeSeconds() uint32

+ func (m *AWSSQSReadArgs) Reset()

+ func (m *AWSSQSReadArgs) String() string

+ func (m *AWSSQSReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *AWSSQSReadArgs) XXX_Size() int

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

+ type AWSSQSRelayArgs struct

+ AutoDelete bool

+ MaxNumMessages uint32

+ QueueName string

+ ReceiveRequestAttemptId string

+ RemoteAccountId string

+ WaitTimeSeconds int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AWSSQSRelayArgs) ProtoMessage()

+ func (m *AWSSQSRelayArgs) GetAutoDelete() bool

+ func (m *AWSSQSRelayArgs) GetMaxNumMessages() uint32

+ func (m *AWSSQSRelayArgs) GetQueueName() string

+ func (m *AWSSQSRelayArgs) GetReceiveRequestAttemptId() string

+ func (m *AWSSQSRelayArgs) GetRemoteAccountId() string

+ func (m *AWSSQSRelayArgs) GetWaitTimeSeconds() int32

+ func (m *AWSSQSRelayArgs) Reset()

+ func (m *AWSSQSRelayArgs) String() string

+ func (m *AWSSQSRelayArgs) XXX_DiscardUnknown()

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

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

+ func (m *AWSSQSRelayArgs) XXX_Size() int

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

+ type AWSSQSWriteArgs struct

+ Attributes map[string]string

+ DelaySeconds uint32

+ MessageDeduplicationId string

+ MessageGroupId string

+ QueueName string

+ RemoteAccountId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AWSSQSWriteArgs) ProtoMessage()

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

+ func (m *AWSSQSWriteArgs) GetDelaySeconds() uint32

+ func (m *AWSSQSWriteArgs) GetMessageDeduplicationId() string

+ func (m *AWSSQSWriteArgs) GetMessageGroupId() string

+ func (m *AWSSQSWriteArgs) GetQueueName() string

+ func (m *AWSSQSWriteArgs) GetRemoteAccountId() string

+ func (m *AWSSQSWriteArgs) Reset()

+ func (m *AWSSQSWriteArgs) String() string

+ func (m *AWSSQSWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *AWSSQSWriteArgs) XXX_Size() int

+ func (m *AWSSQSWriteArgs) XXX_Unmarshal(b []byte) error

+ type ActiveMQConn struct

+ Address string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ActiveMQConn) ProtoMessage()

+ func (m *ActiveMQConn) GetAddress() string

+ func (m *ActiveMQConn) Reset()

+ func (m *ActiveMQConn) String() string

+ func (m *ActiveMQConn) XXX_DiscardUnknown()

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

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

+ func (m *ActiveMQConn) XXX_Size() int

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

+ type ActiveMQReadArgs struct

+ Queue string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ActiveMQReadArgs) ProtoMessage()

+ func (m *ActiveMQReadArgs) GetQueue() string

+ func (m *ActiveMQReadArgs) GetTopic() string

+ func (m *ActiveMQReadArgs) Reset()

+ func (m *ActiveMQReadArgs) String() string

+ func (m *ActiveMQReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *ActiveMQReadArgs) XXX_Size() int

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

+ type ActiveMQWriteArgs struct

+ Queue string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ActiveMQWriteArgs) ProtoMessage()

+ func (m *ActiveMQWriteArgs) GetQueue() string

+ func (m *ActiveMQWriteArgs) GetTopic() string

+ func (m *ActiveMQWriteArgs) Reset()

+ func (m *ActiveMQWriteArgs) String() string

+ func (m *ActiveMQWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *ActiveMQWriteArgs) XXX_Size() int

+ func (m *ActiveMQWriteArgs) XXX_Unmarshal(b []byte) error

+ type AzureEventHubConn struct

+ ConnectionString string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AzureEventHubConn) ProtoMessage()

+ func (m *AzureEventHubConn) GetConnectionString() string

+ func (m *AzureEventHubConn) Reset()

+ func (m *AzureEventHubConn) String() string

+ func (m *AzureEventHubConn) XXX_DiscardUnknown()

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

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

+ func (m *AzureEventHubConn) XXX_Size() int

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

+ type AzureEventHubReadArgs struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AzureEventHubReadArgs) ProtoMessage()

+ func (m *AzureEventHubReadArgs) Reset()

+ func (m *AzureEventHubReadArgs) String() string

+ func (m *AzureEventHubReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *AzureEventHubReadArgs) XXX_Size() int

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

+ type AzureEventHubWriteArgs struct

+ MessageId string

+ PartitionKey string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AzureEventHubWriteArgs) ProtoMessage()

+ func (m *AzureEventHubWriteArgs) GetMessageId() string

+ func (m *AzureEventHubWriteArgs) GetPartitionKey() string

+ func (m *AzureEventHubWriteArgs) Reset()

+ func (m *AzureEventHubWriteArgs) String() string

+ func (m *AzureEventHubWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *AzureEventHubWriteArgs) XXX_Size() int

+ func (m *AzureEventHubWriteArgs) XXX_Unmarshal(b []byte) error

+ type AzureServiceBusConn struct

+ ConnectionString string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AzureServiceBusConn) ProtoMessage()

+ func (m *AzureServiceBusConn) GetConnectionString() string

+ func (m *AzureServiceBusConn) Reset()

+ func (m *AzureServiceBusConn) String() string

+ func (m *AzureServiceBusConn) XXX_DiscardUnknown()

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

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

+ func (m *AzureServiceBusConn) XXX_Size() int

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

+ type AzureServiceBusReadArgs struct

+ Queue string

+ SubscriptionName string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AzureServiceBusReadArgs) ProtoMessage()

+ func (m *AzureServiceBusReadArgs) GetQueue() string

+ func (m *AzureServiceBusReadArgs) GetSubscriptionName() string

+ func (m *AzureServiceBusReadArgs) GetTopic() string

+ func (m *AzureServiceBusReadArgs) Reset()

+ func (m *AzureServiceBusReadArgs) String() string

+ func (m *AzureServiceBusReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *AzureServiceBusReadArgs) XXX_Size() int

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

+ type AzureServiceBusWriteArgs struct

+ Queue string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AzureServiceBusWriteArgs) ProtoMessage()

+ func (m *AzureServiceBusWriteArgs) GetQueue() string

+ func (m *AzureServiceBusWriteArgs) GetTopic() string

+ func (m *AzureServiceBusWriteArgs) Reset()

+ func (m *AzureServiceBusWriteArgs) String() string

+ func (m *AzureServiceBusWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *AzureServiceBusWriteArgs) XXX_Size() int

+ func (m *AzureServiceBusWriteArgs) XXX_Unmarshal(b []byte) error

+ type GCPPubSubConn struct

+ ProjectId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GCPPubSubConn) ProtoMessage()

+ func (m *GCPPubSubConn) GetProjectId() string

+ func (m *GCPPubSubConn) Reset()

+ func (m *GCPPubSubConn) String() string

+ func (m *GCPPubSubConn) XXX_DiscardUnknown()

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

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

+ func (m *GCPPubSubConn) XXX_Size() int

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

+ type GCPPubSubReadArgs struct

+ AckMessages bool

+ SubscriptionId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GCPPubSubReadArgs) ProtoMessage()

+ func (m *GCPPubSubReadArgs) GetAckMessages() bool

+ func (m *GCPPubSubReadArgs) GetSubscriptionId() string

+ func (m *GCPPubSubReadArgs) Reset()

+ func (m *GCPPubSubReadArgs) String() string

+ func (m *GCPPubSubReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *GCPPubSubReadArgs) XXX_Size() int

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

+ type GCPPubSubWriteArgs struct

+ TopicId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GCPPubSubWriteArgs) ProtoMessage()

+ func (m *GCPPubSubWriteArgs) GetTopicId() string

+ func (m *GCPPubSubWriteArgs) Reset()

+ func (m *GCPPubSubWriteArgs) String() string

+ func (m *GCPPubSubWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *GCPPubSubWriteArgs) XXX_Size() int

+ func (m *GCPPubSubWriteArgs) XXX_Unmarshal(b []byte) error

+ type KafkaConn struct

+ Address []string

+ InsecureTls bool

+ SaslPassword string

+ SaslType KafkaConn_SASLType

+ SaslUsername string

+ TimeoutSeconds int32

+ UseTls bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*KafkaConn) ProtoMessage()

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

+ func (m *KafkaConn) GetInsecureTls() bool

+ func (m *KafkaConn) GetSaslPassword() string

+ func (m *KafkaConn) GetSaslType() KafkaConn_SASLType

+ func (m *KafkaConn) GetSaslUsername() string

+ func (m *KafkaConn) GetTimeoutSeconds() int32

+ func (m *KafkaConn) GetUseTls() bool

+ func (m *KafkaConn) Reset()

+ func (m *KafkaConn) String() string

+ func (m *KafkaConn) XXX_DiscardUnknown()

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

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

+ func (m *KafkaConn) XXX_Size() int

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

+ type KafkaConn_SASLType int32

+ const KafkaConn_NONE

+ const KafkaConn_PLAIN

+ const KafkaConn_SCRAM

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

+ func (x KafkaConn_SASLType) String() string

+ type KafkaLagArgs struct

+ GroupId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*KafkaLagArgs) ProtoMessage()

+ func (m *KafkaLagArgs) GetGroupId() string

+ func (m *KafkaLagArgs) Reset()

+ func (m *KafkaLagArgs) String() string

+ func (m *KafkaLagArgs) XXX_DiscardUnknown()

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

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

+ func (m *KafkaLagArgs) XXX_Size() int

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

+ type KafkaReadArgs struct

+ CommitIntervalSeconds int32

+ ConsumerGroupName string

+ MaxBytes int32

+ MaxWaitSeconds int32

+ MinBytes int32

+ QueueCapacity int32

+ ReadOffset int64

+ RebalanceTimeoutSeconds int32

+ Topics []string

+ UseConsumerGroup bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*KafkaReadArgs) ProtoMessage()

+ func (m *KafkaReadArgs) GetCommitIntervalSeconds() int32

+ func (m *KafkaReadArgs) GetConsumerGroupName() string

+ func (m *KafkaReadArgs) GetMaxBytes() int32

+ func (m *KafkaReadArgs) GetMaxWaitSeconds() int32

+ func (m *KafkaReadArgs) GetMinBytes() int32

+ func (m *KafkaReadArgs) GetQueueCapacity() int32

+ func (m *KafkaReadArgs) GetReadOffset() int64

+ func (m *KafkaReadArgs) GetRebalanceTimeoutSeconds() int32

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

+ func (m *KafkaReadArgs) GetUseConsumerGroup() bool

+ func (m *KafkaReadArgs) Reset()

+ func (m *KafkaReadArgs) String() string

+ func (m *KafkaReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *KafkaReadArgs) XXX_Size() int

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

+ type KafkaRelayArgs struct

+ CommitIntervalSeconds int32

+ ConsumerGroupName string

+ MaxBytes int32

+ MaxWaitSeconds int32

+ MinBytes int32

+ QueueCapacity int32

+ ReadOffset int64

+ RebalanceTimeoutSeconds int32

+ Topics []string

+ UseConsumerGroup bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*KafkaRelayArgs) ProtoMessage()

+ func (m *KafkaRelayArgs) GetCommitIntervalSeconds() int32

+ func (m *KafkaRelayArgs) GetConsumerGroupName() string

+ func (m *KafkaRelayArgs) GetMaxBytes() int32

+ func (m *KafkaRelayArgs) GetMaxWaitSeconds() int32

+ func (m *KafkaRelayArgs) GetMinBytes() int32

+ func (m *KafkaRelayArgs) GetQueueCapacity() int32

+ func (m *KafkaRelayArgs) GetReadOffset() int64

+ func (m *KafkaRelayArgs) GetRebalanceTimeoutSeconds() int32

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

+ func (m *KafkaRelayArgs) GetUseConsumerGroup() bool

+ func (m *KafkaRelayArgs) Reset()

+ func (m *KafkaRelayArgs) String() string

+ func (m *KafkaRelayArgs) XXX_DiscardUnknown()

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

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

+ func (m *KafkaRelayArgs) XXX_Size() int

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

+ type KafkaWriteArgs struct

+ Headers map[string]string

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*KafkaWriteArgs) ProtoMessage()

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

+ func (m *KafkaWriteArgs) GetKey() string

+ func (m *KafkaWriteArgs) Reset()

+ func (m *KafkaWriteArgs) String() string

+ func (m *KafkaWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *KafkaWriteArgs) XXX_Size() int

+ func (m *KafkaWriteArgs) XXX_Unmarshal(b []byte) error

+ type KubeMQQueueConn struct

+ Address string

+ AuthToken string

+ TlsCertFile string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*KubeMQQueueConn) ProtoMessage()

+ func (m *KubeMQQueueConn) GetAddress() string

+ func (m *KubeMQQueueConn) GetAuthToken() string

+ func (m *KubeMQQueueConn) GetTlsCertFile() string

+ func (m *KubeMQQueueConn) Reset()

+ func (m *KubeMQQueueConn) String() string

+ func (m *KubeMQQueueConn) XXX_DiscardUnknown()

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

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

+ func (m *KubeMQQueueConn) XXX_Size() int

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

+ type KubeMQQueueReadArgs struct

+ ClientId string

+ QueueName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*KubeMQQueueReadArgs) ProtoMessage()

+ func (m *KubeMQQueueReadArgs) GetClientId() string

+ func (m *KubeMQQueueReadArgs) GetQueueName() string

+ func (m *KubeMQQueueReadArgs) Reset()

+ func (m *KubeMQQueueReadArgs) String() string

+ func (m *KubeMQQueueReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *KubeMQQueueReadArgs) XXX_Size() int

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

+ type KubeMQQueueWriteArgs struct

+ ClientId string

+ QueueName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*KubeMQQueueWriteArgs) ProtoMessage()

+ func (m *KubeMQQueueWriteArgs) GetClientId() string

+ func (m *KubeMQQueueWriteArgs) GetQueueName() string

+ func (m *KubeMQQueueWriteArgs) Reset()

+ func (m *KubeMQQueueWriteArgs) String() string

+ func (m *KubeMQQueueWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *KubeMQQueueWriteArgs) XXX_Size() int

+ func (m *KubeMQQueueWriteArgs) XXX_Unmarshal(b []byte) error

+ type MQTTConn struct

+ Address string

+ ClientId string

+ ConnTimeoutSeconds uint32

+ QosLevel MQTTQoSLevel

+ TlsOptions *MQTTTLSOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MQTTConn) ProtoMessage()

+ func (m *MQTTConn) GetAddress() string

+ func (m *MQTTConn) GetClientId() string

+ func (m *MQTTConn) GetConnTimeoutSeconds() uint32

+ func (m *MQTTConn) GetQosLevel() MQTTQoSLevel

+ func (m *MQTTConn) GetTlsOptions() *MQTTTLSOptions

+ func (m *MQTTConn) Reset()

+ func (m *MQTTConn) String() string

+ func (m *MQTTConn) XXX_DiscardUnknown()

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

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

+ func (m *MQTTConn) XXX_Size() int

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

+ type MQTTQoSLevel int32

+ const MQTTQoSLevel_AT_LEAST_ONCE

+ const MQTTQoSLevel_AT_MOST_ONCE

+ const MQTTQoSLevel_EXACTLY_ONCE

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

+ func (x MQTTQoSLevel) String() string

+ type MQTTReadArgs struct

+ ReadTimeoutSeconds uint32

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MQTTReadArgs) ProtoMessage()

+ func (m *MQTTReadArgs) GetReadTimeoutSeconds() uint32

+ func (m *MQTTReadArgs) GetTopic() string

+ func (m *MQTTReadArgs) Reset()

+ func (m *MQTTReadArgs) String() string

+ func (m *MQTTReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *MQTTReadArgs) XXX_Size() int

+ func (m *MQTTReadArgs) XXX_Unmarshal(b []byte) error

+ type MQTTTLSOptions struct

+ CaFile string

+ CertFile string

+ KeyFile string

+ SkipVerify bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MQTTTLSOptions) ProtoMessage()

+ func (m *MQTTTLSOptions) GetCaFile() string

+ func (m *MQTTTLSOptions) GetCertFile() string

+ func (m *MQTTTLSOptions) GetKeyFile() string

+ func (m *MQTTTLSOptions) GetSkipVerify() bool

+ func (m *MQTTTLSOptions) Reset()

+ func (m *MQTTTLSOptions) String() string

+ func (m *MQTTTLSOptions) XXX_DiscardUnknown()

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

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

+ func (m *MQTTTLSOptions) XXX_Size() int

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

+ type MQTTWriteArgs struct

+ Topic string

+ WriteTimeoutSeconds uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MQTTWriteArgs) ProtoMessage()

+ func (m *MQTTWriteArgs) GetTopic() string

+ func (m *MQTTWriteArgs) GetWriteTimeoutSeconds() uint32

+ func (m *MQTTWriteArgs) Reset()

+ func (m *MQTTWriteArgs) String() string

+ func (m *MQTTWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *MQTTWriteArgs) XXX_Size() int

+ func (m *MQTTWriteArgs) XXX_Unmarshal(b []byte) error

+ type MongoConn struct

+ Dsn string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MongoConn) ProtoMessage()

+ func (m *MongoConn) GetDsn() string

+ func (m *MongoConn) Reset()

+ func (m *MongoConn) String() string

+ func (m *MongoConn) XXX_DiscardUnknown()

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

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

+ func (m *MongoConn) XXX_Size() int

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

+ type MongoReadArgs struct

+ Collection string

+ Database string

+ IncludeFullDocument bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MongoReadArgs) ProtoMessage()

+ func (m *MongoReadArgs) GetCollection() string

+ func (m *MongoReadArgs) GetDatabase() string

+ func (m *MongoReadArgs) GetIncludeFullDocument() bool

+ func (m *MongoReadArgs) Reset()

+ func (m *MongoReadArgs) String() string

+ func (m *MongoReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *MongoReadArgs) XXX_Size() int

+ func (m *MongoReadArgs) XXX_Unmarshal(b []byte) error

+ type NSQConn struct

+ AuthSecret string

+ ClientId string

+ InsecureTls bool

+ LookupdAddress string

+ NsqdAddress string

+ TlsCaCert []byte

+ TlsClientCert []byte

+ TlsClientKey []byte

+ UseTls bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NSQConn) ProtoMessage()

+ func (m *NSQConn) GetAuthSecret() string

+ func (m *NSQConn) GetClientId() string

+ func (m *NSQConn) GetInsecureTls() bool

+ func (m *NSQConn) GetLookupdAddress() string

+ func (m *NSQConn) GetNsqdAddress() string

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

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

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

+ func (m *NSQConn) GetUseTls() bool

+ func (m *NSQConn) Reset()

+ func (m *NSQConn) String() string

+ func (m *NSQConn) XXX_DiscardUnknown()

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

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

+ func (m *NSQConn) XXX_Size() int

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

+ type NSQReadArgs struct

+ Channel string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NSQReadArgs) ProtoMessage()

+ func (m *NSQReadArgs) GetChannel() string

+ func (m *NSQReadArgs) GetTopic() string

+ func (m *NSQReadArgs) Reset()

+ func (m *NSQReadArgs) String() string

+ func (m *NSQReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *NSQReadArgs) XXX_Size() int

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

+ type NSQWriteArgs struct

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NSQWriteArgs) ProtoMessage()

+ func (m *NSQWriteArgs) GetTopic() string

+ func (m *NSQWriteArgs) Reset()

+ func (m *NSQWriteArgs) String() string

+ func (m *NSQWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *NSQWriteArgs) XXX_Size() int

+ func (m *NSQWriteArgs) XXX_Unmarshal(b []byte) error

+ type NatsConn struct

+ Dsn string

+ InsecureTls bool

+ TlsCaCert []byte

+ TlsClientCert []byte

+ TlsClientKey []byte

+ UserCredentials []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsConn) ProtoMessage()

+ func (m *NatsConn) GetDsn() string

+ func (m *NatsConn) GetInsecureTls() bool

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

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

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

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

+ func (m *NatsConn) Reset()

+ func (m *NatsConn) String() string

+ func (m *NatsConn) XXX_DiscardUnknown()

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

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

+ func (m *NatsConn) XXX_Size() int

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

+ type NatsReadArgs struct

+ Subject string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsReadArgs) ProtoMessage()

+ func (m *NatsReadArgs) GetSubject() string

+ func (m *NatsReadArgs) Reset()

+ func (m *NatsReadArgs) String() string

+ func (m *NatsReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *NatsReadArgs) XXX_Size() int

+ func (m *NatsReadArgs) XXX_Unmarshal(b []byte) error

+ type NatsStreamingConn struct

+ ClientId string

+ ClusterId string

+ Dsn string

+ InsecureTls bool

+ TlsCaCert []byte

+ TlsClientCert []byte

+ TlsClientKey []byte

+ UserCredentials []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsStreamingConn) ProtoMessage()

+ func (m *NatsStreamingConn) GetClientId() string

+ func (m *NatsStreamingConn) GetClusterId() string

+ func (m *NatsStreamingConn) GetDsn() string

+ func (m *NatsStreamingConn) GetInsecureTls() bool

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

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

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

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

+ func (m *NatsStreamingConn) Reset()

+ func (m *NatsStreamingConn) String() string

+ func (m *NatsStreamingConn) XXX_DiscardUnknown()

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

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

+ func (m *NatsStreamingConn) XXX_Size() int

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

+ type NatsStreamingReadArgs struct

+ Channel string

+ DurableName string

+ ReadAll bool

+ ReadLastAvailable bool

+ ReadSequenceNumber uint32

+ ReadSince string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsStreamingReadArgs) ProtoMessage()

+ func (m *NatsStreamingReadArgs) GetChannel() string

+ func (m *NatsStreamingReadArgs) GetDurableName() string

+ func (m *NatsStreamingReadArgs) GetReadAll() bool

+ func (m *NatsStreamingReadArgs) GetReadLastAvailable() bool

+ func (m *NatsStreamingReadArgs) GetReadSequenceNumber() uint32

+ func (m *NatsStreamingReadArgs) GetReadSince() string

+ func (m *NatsStreamingReadArgs) Reset()

+ func (m *NatsStreamingReadArgs) String() string

+ func (m *NatsStreamingReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *NatsStreamingReadArgs) XXX_Size() int

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

+ type NatsStreamingWriteArgs struct

+ Channel string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsStreamingWriteArgs) ProtoMessage()

+ func (m *NatsStreamingWriteArgs) GetChannel() string

+ func (m *NatsStreamingWriteArgs) Reset()

+ func (m *NatsStreamingWriteArgs) String() string

+ func (m *NatsStreamingWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *NatsStreamingWriteArgs) XXX_Size() int

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

+ type NatsWriteArgs struct

+ Subject string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsWriteArgs) ProtoMessage()

+ func (m *NatsWriteArgs) GetSubject() string

+ func (m *NatsWriteArgs) Reset()

+ func (m *NatsWriteArgs) String() string

+ func (m *NatsWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *NatsWriteArgs) XXX_Size() int

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

+ type PostgresConn struct

+ Address string

+ Database string

+ InsecureTls bool

+ Password string

+ Port uint32

+ UseTls bool

+ Username string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PostgresConn) ProtoMessage()

+ func (m *PostgresConn) GetAddress() string

+ func (m *PostgresConn) GetDatabase() string

+ func (m *PostgresConn) GetInsecureTls() bool

+ func (m *PostgresConn) GetPassword() string

+ func (m *PostgresConn) GetPort() uint32

+ func (m *PostgresConn) GetUseTls() bool

+ func (m *PostgresConn) GetUsername() string

+ func (m *PostgresConn) Reset()

+ func (m *PostgresConn) String() string

+ func (m *PostgresConn) XXX_DiscardUnknown()

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

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

+ func (m *PostgresConn) XXX_Size() int

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

+ type PostgresReadArgs struct

+ PublisherName string

+ ReplicationSlotName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PostgresReadArgs) ProtoMessage()

+ func (m *PostgresReadArgs) GetPublisherName() string

+ func (m *PostgresReadArgs) GetReplicationSlotName() string

+ func (m *PostgresReadArgs) Reset()

+ func (m *PostgresReadArgs) String() string

+ func (m *PostgresReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *PostgresReadArgs) XXX_Size() int

+ func (m *PostgresReadArgs) XXX_Unmarshal(b []byte) error

+ type PulsarConn struct

+ ConnectTimeoutSeconds uint32

+ Dsn string

+ InsecureTls bool

+ TlsClientCert []byte

+ TlsClientKey []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PulsarConn) ProtoMessage()

+ func (m *PulsarConn) GetConnectTimeoutSeconds() uint32

+ func (m *PulsarConn) GetDsn() string

+ func (m *PulsarConn) GetInsecureTls() bool

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

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

+ func (m *PulsarConn) Reset()

+ func (m *PulsarConn) String() string

+ func (m *PulsarConn) XXX_DiscardUnknown()

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

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

+ func (m *PulsarConn) XXX_Size() int

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

+ type PulsarReadArgs struct

+ SubscriptionName string

+ SubscriptionType SubscriptionType

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PulsarReadArgs) ProtoMessage()

+ func (m *PulsarReadArgs) GetSubscriptionName() string

+ func (m *PulsarReadArgs) GetSubscriptionType() SubscriptionType

+ func (m *PulsarReadArgs) GetTopic() string

+ func (m *PulsarReadArgs) Reset()

+ func (m *PulsarReadArgs) String() string

+ func (m *PulsarReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *PulsarReadArgs) XXX_Size() int

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

+ type PulsarWriteArgs struct

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PulsarWriteArgs) ProtoMessage()

+ func (m *PulsarWriteArgs) GetTopic() string

+ func (m *PulsarWriteArgs) Reset()

+ func (m *PulsarWriteArgs) String() string

+ func (m *PulsarWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *PulsarWriteArgs) XXX_Size() int

+ func (m *PulsarWriteArgs) XXX_Unmarshal(b []byte) error

+ type RabbitConn struct

+ Address string

+ InsecureTls bool

+ UseTls bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RabbitConn) ProtoMessage()

+ func (m *RabbitConn) GetAddress() string

+ func (m *RabbitConn) GetInsecureTls() bool

+ func (m *RabbitConn) GetUseTls() bool

+ func (m *RabbitConn) Reset()

+ func (m *RabbitConn) String() string

+ func (m *RabbitConn) XXX_DiscardUnknown()

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

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

+ func (m *RabbitConn) XXX_Size() int

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

+ type RabbitReadArgs struct

+ AutoAck bool

+ BindingKey string

+ ConsumerTag string

+ ExchangeName string

+ QueueDeclare bool

+ QueueDelete bool

+ QueueDurable bool

+ QueueExclusive bool

+ QueueName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RabbitReadArgs) ProtoMessage()

+ func (m *RabbitReadArgs) GetAutoAck() bool

+ func (m *RabbitReadArgs) GetBindingKey() string

+ func (m *RabbitReadArgs) GetConsumerTag() string

+ func (m *RabbitReadArgs) GetExchangeName() string

+ func (m *RabbitReadArgs) GetQueueDeclare() bool

+ func (m *RabbitReadArgs) GetQueueDelete() bool

+ func (m *RabbitReadArgs) GetQueueDurable() bool

+ func (m *RabbitReadArgs) GetQueueExclusive() bool

+ func (m *RabbitReadArgs) GetQueueName() string

+ func (m *RabbitReadArgs) Reset()

+ func (m *RabbitReadArgs) String() string

+ func (m *RabbitReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *RabbitReadArgs) XXX_Size() int

+ func (m *RabbitReadArgs) XXX_Unmarshal(b []byte) error

+ type RabbitStreamsConn struct

+ ClientName string

+ Dsn string

+ InsecureTls bool

+ Password string

+ UseTls bool

+ Username string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RabbitStreamsConn) ProtoMessage()

+ func (m *RabbitStreamsConn) GetClientName() string

+ func (m *RabbitStreamsConn) GetDsn() string

+ func (m *RabbitStreamsConn) GetInsecureTls() bool

+ func (m *RabbitStreamsConn) GetPassword() string

+ func (m *RabbitStreamsConn) GetUseTls() bool

+ func (m *RabbitStreamsConn) GetUsername() string

+ func (m *RabbitStreamsConn) Reset()

+ func (m *RabbitStreamsConn) String() string

+ func (m *RabbitStreamsConn) XXX_DiscardUnknown()

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

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

+ func (m *RabbitStreamsConn) XXX_Size() int

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

+ type RabbitStreamsOffsetOptions struct

+ FirstOffset bool

+ LastConsumed bool

+ LastOffset uint64

+ NextOffset bool

+ SpecificOffset uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RabbitStreamsOffsetOptions) ProtoMessage()

+ func (m *RabbitStreamsOffsetOptions) GetFirstOffset() bool

+ func (m *RabbitStreamsOffsetOptions) GetLastConsumed() bool

+ func (m *RabbitStreamsOffsetOptions) GetLastOffset() uint64

+ func (m *RabbitStreamsOffsetOptions) GetNextOffset() bool

+ func (m *RabbitStreamsOffsetOptions) GetSpecificOffset() uint64

+ func (m *RabbitStreamsOffsetOptions) Reset()

+ func (m *RabbitStreamsOffsetOptions) String() string

+ func (m *RabbitStreamsOffsetOptions) XXX_DiscardUnknown()

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

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

+ func (m *RabbitStreamsOffsetOptions) XXX_Size() int

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

+ type RabbitStreamsReadArgs struct

+ DeclareStream bool

+ DeclareStreamSize string

+ OffsetOptions *RabbitStreamsOffsetOptions

+ Stream string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RabbitStreamsReadArgs) ProtoMessage()

+ func (m *RabbitStreamsReadArgs) GetDeclareStream() bool

+ func (m *RabbitStreamsReadArgs) GetDeclareStreamSize() string

+ func (m *RabbitStreamsReadArgs) GetOffsetOptions() *RabbitStreamsOffsetOptions

+ func (m *RabbitStreamsReadArgs) GetStream() string

+ func (m *RabbitStreamsReadArgs) Reset()

+ func (m *RabbitStreamsReadArgs) String() string

+ func (m *RabbitStreamsReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *RabbitStreamsReadArgs) XXX_Size() int

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

+ type RabbitStreamsWriteArgs struct

+ DeclareStream bool

+ DeclareStreamSize string

+ Stream string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RabbitStreamsWriteArgs) ProtoMessage()

+ func (m *RabbitStreamsWriteArgs) GetDeclareStream() bool

+ func (m *RabbitStreamsWriteArgs) GetDeclareStreamSize() string

+ func (m *RabbitStreamsWriteArgs) GetStream() string

+ func (m *RabbitStreamsWriteArgs) Reset()

+ func (m *RabbitStreamsWriteArgs) String() string

+ func (m *RabbitStreamsWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *RabbitStreamsWriteArgs) XXX_Size() int

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

+ type RabbitWriteArgs struct

+ AppId string

+ ExchangeName string

+ RoutingKey string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RabbitWriteArgs) ProtoMessage()

+ func (m *RabbitWriteArgs) GetAppId() string

+ func (m *RabbitWriteArgs) GetExchangeName() string

+ func (m *RabbitWriteArgs) GetRoutingKey() string

+ func (m *RabbitWriteArgs) Reset()

+ func (m *RabbitWriteArgs) String() string

+ func (m *RabbitWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *RabbitWriteArgs) XXX_Size() int

+ func (m *RabbitWriteArgs) XXX_Unmarshal(b []byte) error

+ type RedisPubSubConn struct

+ Address string

+ Password string

+ Username string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RedisPubSubConn) ProtoMessage()

+ func (m *RedisPubSubConn) GetAddress() string

+ func (m *RedisPubSubConn) GetPassword() string

+ func (m *RedisPubSubConn) GetUsername() string

+ func (m *RedisPubSubConn) Reset()

+ func (m *RedisPubSubConn) String() string

+ func (m *RedisPubSubConn) XXX_DiscardUnknown()

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

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

+ func (m *RedisPubSubConn) XXX_Size() int

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

+ type RedisPubSubReadArgs struct

+ Channel []string

+ Database uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RedisPubSubReadArgs) ProtoMessage()

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

+ func (m *RedisPubSubReadArgs) GetDatabase() uint32

+ func (m *RedisPubSubReadArgs) Reset()

+ func (m *RedisPubSubReadArgs) String() string

+ func (m *RedisPubSubReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *RedisPubSubReadArgs) XXX_Size() int

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

+ type RedisPubSubWriteArgs struct

+ Channel []string

+ Database uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RedisPubSubWriteArgs) ProtoMessage()

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

+ func (m *RedisPubSubWriteArgs) GetDatabase() uint32

+ func (m *RedisPubSubWriteArgs) Reset()

+ func (m *RedisPubSubWriteArgs) String() string

+ func (m *RedisPubSubWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *RedisPubSubWriteArgs) XXX_Size() int

+ func (m *RedisPubSubWriteArgs) XXX_Unmarshal(b []byte) error

+ type RedisStreamsConn struct

+ Address string

+ Password string

+ Username string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RedisStreamsConn) ProtoMessage()

+ func (m *RedisStreamsConn) GetAddress() string

+ func (m *RedisStreamsConn) GetPassword() string

+ func (m *RedisStreamsConn) GetUsername() string

+ func (m *RedisStreamsConn) Reset()

+ func (m *RedisStreamsConn) String() string

+ func (m *RedisStreamsConn) XXX_DiscardUnknown()

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

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

+ func (m *RedisStreamsConn) XXX_Size() int

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

+ type RedisStreamsReadArgs struct

+ ConsumerGroup string

+ ConsumerName string

+ Count uint32

+ CreateConsumerConfig *CreateConsumerConfig

+ Database uint32

+ Stream []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RedisStreamsReadArgs) ProtoMessage()

+ func (m *RedisStreamsReadArgs) GetConsumerGroup() string

+ func (m *RedisStreamsReadArgs) GetConsumerName() string

+ func (m *RedisStreamsReadArgs) GetCount() uint32

+ func (m *RedisStreamsReadArgs) GetCreateConsumerConfig() *CreateConsumerConfig

+ func (m *RedisStreamsReadArgs) GetDatabase() uint32

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

+ func (m *RedisStreamsReadArgs) Reset()

+ func (m *RedisStreamsReadArgs) String() string

+ func (m *RedisStreamsReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *RedisStreamsReadArgs) XXX_Size() int

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

+ type RedisStreamsWriteArgs struct

+ Key string

+ Streams []string

+ WriteId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RedisStreamsWriteArgs) ProtoMessage()

+ func (m *RedisStreamsWriteArgs) GetKey() string

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

+ func (m *RedisStreamsWriteArgs) GetWriteId() string

+ func (m *RedisStreamsWriteArgs) Reset()

+ func (m *RedisStreamsWriteArgs) String() string

+ func (m *RedisStreamsWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *RedisStreamsWriteArgs) XXX_Size() int

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

type SubscriptionType

+ const SubscriptionType_EXCLUSIVE

+ const SubscriptionType_FAILOVER

+ const SubscriptionType_KEYSHARED

+ const SubscriptionType_SHARED

+ type Type int32

+ const Type_ACTIVEMQ

+ const Type_AWS_SNS

+ const Type_AWS_SQS

+ const Type_AZURE_EVENT_HUB

+ const Type_AZURE_SERVICE_BUS

+ const Type_GCP_PUBSUB

+ const Type_KAFKA

+ const Type_KUBE_MQ

+ const Type_MONGODB_CDC

+ const Type_MQTT

+ const Type_NATS

+ const Type_NATS_STREAMING

+ const Type_NSQ

+ const Type_POSTGRES_CDC

+ const Type_PULSAR

+ const Type_RABBIT

+ const Type_RABBIT_STREAMS

+ const Type_REDIS_PUBSUB

+ const Type_REDIS_STREAMS

+ const Type_UNSET

+ func (Type) EnumDescriptor() ([]byte, []int)

+ func (x Type) String() string

v0.0.41

Sep 1, 2021

v0.0.40

Aug 27, 2021

v0.0.39

Aug 23, 2021

v0.0.38

Aug 22, 2021

v0.0.37

Aug 22, 2021

v0.0.36

Aug 22, 2021

v0.0.35

Aug 22, 2021

v0.0.34

Aug 22, 2021

v0.0.33

Aug 22, 2021

v0.0.32

Aug 22, 2021

Changes in this version

+ var CreateConsumerConfig_OffsetStart_name = map[int32]string

+ var CreateConsumerConfig_OffsetStart_value = map[string]int32

+ var SubscriptionType_name = map[int32]string

+ var SubscriptionType_value = map[string]int32

+ type AWSSNS struct

+ TopicArn string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AWSSNS) Descriptor() ([]byte, []int)

+ func (*AWSSNS) ProtoMessage()

+ func (m *AWSSNS) GetTopicArn() string

+ func (m *AWSSNS) Reset()

+ func (m *AWSSNS) String() string

+ func (m *AWSSNS) XXX_DiscardUnknown()

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

+ func (m *AWSSNS) XXX_Merge(src proto.Message)

+ func (m *AWSSNS) XXX_Size() int

+ func (m *AWSSNS) XXX_Unmarshal(b []byte) error

+ type AWSSQS struct

+ QueueName string

+ RemoteAccountId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AWSSQS) Descriptor() ([]byte, []int)

+ func (*AWSSQS) ProtoMessage()

+ func (m *AWSSQS) GetQueueName() string

+ func (m *AWSSQS) GetRemoteAccountId() string

+ func (m *AWSSQS) Reset()

+ func (m *AWSSQS) String() string

+ func (m *AWSSQS) XXX_DiscardUnknown()

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

+ func (m *AWSSQS) XXX_Merge(src proto.Message)

+ func (m *AWSSQS) XXX_Size() int

+ func (m *AWSSQS) XXX_Unmarshal(b []byte) error

+ type ActiveMQ struct

+ Queue string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ActiveMQ) Descriptor() ([]byte, []int)

+ func (*ActiveMQ) ProtoMessage()

+ func (m *ActiveMQ) GetQueue() string

+ func (m *ActiveMQ) GetTopic() string

+ func (m *ActiveMQ) Reset()

+ func (m *ActiveMQ) String() string

+ func (m *ActiveMQ) XXX_DiscardUnknown()

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

+ func (m *ActiveMQ) XXX_Merge(src proto.Message)

+ func (m *ActiveMQ) XXX_Size() int

+ func (m *ActiveMQ) XXX_Unmarshal(b []byte) error

+ type AzureEventHub struct

+ MessageId string

+ PartitionKey string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AzureEventHub) Descriptor() ([]byte, []int)

+ func (*AzureEventHub) ProtoMessage()

+ func (m *AzureEventHub) GetMessageId() string

+ func (m *AzureEventHub) GetPartitionKey() string

+ func (m *AzureEventHub) Reset()

+ func (m *AzureEventHub) String() string

+ func (m *AzureEventHub) XXX_DiscardUnknown()

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

+ func (m *AzureEventHub) XXX_Merge(src proto.Message)

+ func (m *AzureEventHub) XXX_Size() int

+ func (m *AzureEventHub) XXX_Unmarshal(b []byte) error

+ type AzureServiceBus struct

+ Queue string

+ SubscriptionName string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AzureServiceBus) Descriptor() ([]byte, []int)

+ func (*AzureServiceBus) ProtoMessage()

+ func (m *AzureServiceBus) GetQueue() string

+ func (m *AzureServiceBus) GetSubscriptionName() string

+ func (m *AzureServiceBus) GetTopic() string

+ func (m *AzureServiceBus) Reset()

+ func (m *AzureServiceBus) String() string

+ func (m *AzureServiceBus) XXX_DiscardUnknown()

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

+ func (m *AzureServiceBus) XXX_Merge(src proto.Message)

+ func (m *AzureServiceBus) XXX_Size() int

+ func (m *AzureServiceBus) XXX_Unmarshal(b []byte) error

+ type CreateConsumerConfig struct

+ CreateStreams bool

+ OffsetStart CreateConsumerConfig_OffsetStart

+ RecreateConsumerGroup bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateConsumerConfig) ProtoMessage()

+ func (m *CreateConsumerConfig) GetCreateStreams() bool

+ func (m *CreateConsumerConfig) GetOffsetStart() CreateConsumerConfig_OffsetStart

+ func (m *CreateConsumerConfig) GetRecreateConsumerGroup() bool

+ func (m *CreateConsumerConfig) Reset()

+ func (m *CreateConsumerConfig) String() string

+ func (m *CreateConsumerConfig) XXX_DiscardUnknown()

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

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

+ func (m *CreateConsumerConfig) XXX_Size() int

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

+ type CreateConsumerConfig_OffsetStart int32

+ const CreateConsumerConfig_Latest

+ const CreateConsumerConfig_Oldest

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

+ func (x CreateConsumerConfig_OffsetStart) String() string

+ type DeclareStream struct

+ Size string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeclareStream) Descriptor() ([]byte, []int)

+ func (*DeclareStream) ProtoMessage()

+ func (m *DeclareStream) GetSize() string

+ func (m *DeclareStream) Reset()

+ func (m *DeclareStream) String() string

+ func (m *DeclareStream) XXX_DiscardUnknown()

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

+ func (m *DeclareStream) XXX_Merge(src proto.Message)

+ func (m *DeclareStream) XXX_Size() int

+ func (m *DeclareStream) XXX_Unmarshal(b []byte) error

+ type FirstOffset struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FirstOffset) Descriptor() ([]byte, []int)

+ func (*FirstOffset) ProtoMessage()

+ func (m *FirstOffset) Reset()

+ func (m *FirstOffset) String() string

+ func (m *FirstOffset) XXX_DiscardUnknown()

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

+ func (m *FirstOffset) XXX_Merge(src proto.Message)

+ func (m *FirstOffset) XXX_Size() int

+ func (m *FirstOffset) XXX_Unmarshal(b []byte) error

+ type LastConsumed struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LastConsumed) Descriptor() ([]byte, []int)

+ func (*LastConsumed) ProtoMessage()

+ func (m *LastConsumed) Reset()

+ func (m *LastConsumed) String() string

+ func (m *LastConsumed) XXX_DiscardUnknown()

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

+ func (m *LastConsumed) XXX_Merge(src proto.Message)

+ func (m *LastConsumed) XXX_Size() int

+ func (m *LastConsumed) XXX_Unmarshal(b []byte) error

+ type LastOffset struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LastOffset) Descriptor() ([]byte, []int)

+ func (*LastOffset) ProtoMessage()

+ func (m *LastOffset) Reset()

+ func (m *LastOffset) String() string

+ func (m *LastOffset) XXX_DiscardUnknown()

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

+ func (m *LastOffset) XXX_Merge(src proto.Message)

+ func (m *LastOffset) XXX_Size() int

+ func (m *LastOffset) XXX_Unmarshal(b []byte) error

+ type Mongo struct

+ Collection string

+ Database string

+ IncludeFullDocument bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Mongo) Descriptor() ([]byte, []int)

+ func (*Mongo) ProtoMessage()

+ func (m *Mongo) GetCollection() string

+ func (m *Mongo) GetDatabase() string

+ func (m *Mongo) GetIncludeFullDocument() bool

+ func (m *Mongo) Reset()

+ func (m *Mongo) String() string

+ func (m *Mongo) XXX_DiscardUnknown()

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

+ func (m *Mongo) XXX_Merge(src proto.Message)

+ func (m *Mongo) XXX_Size() int

+ func (m *Mongo) XXX_Unmarshal(b []byte) error

+ type NSQ struct

+ Channel string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NSQ) Descriptor() ([]byte, []int)

+ func (*NSQ) ProtoMessage()

+ func (m *NSQ) GetChannel() string

+ func (m *NSQ) GetTopic() string

+ func (m *NSQ) Reset()

+ func (m *NSQ) String() string

+ func (m *NSQ) XXX_DiscardUnknown()

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

+ func (m *NSQ) XXX_Merge(src proto.Message)

+ func (m *NSQ) XXX_Size() int

+ func (m *NSQ) XXX_Unmarshal(b []byte) error

+ type Nats struct

+ Subject string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Nats) Descriptor() ([]byte, []int)

+ func (*Nats) ProtoMessage()

+ func (m *Nats) GetSubject() string

+ func (m *Nats) Reset()

+ func (m *Nats) String() string

+ func (m *Nats) XXX_DiscardUnknown()

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

+ func (m *Nats) XXX_Merge(src proto.Message)

+ func (m *Nats) XXX_Size() int

+ func (m *Nats) XXX_Unmarshal(b []byte) error

+ type NatsStreaming struct

+ Channel string

+ DurableName string

+ ReadOption isNatsStreaming_ReadOption

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NatsStreaming) Descriptor() ([]byte, []int)

+ func (*NatsStreaming) ProtoMessage()

+ func (*NatsStreaming) XXX_OneofWrappers() []interface{}

+ func (m *NatsStreaming) GetAll() *ReadAll

+ func (m *NatsStreaming) GetChannel() string

+ func (m *NatsStreaming) GetDurableName() string

+ func (m *NatsStreaming) GetLastAvailable() *ReadLastAvailable

+ func (m *NatsStreaming) GetReadOption() isNatsStreaming_ReadOption

+ func (m *NatsStreaming) GetReadSequenceNumber() *ReadSequenceNumber

+ func (m *NatsStreaming) GetReadSince() *ReadSince

+ func (m *NatsStreaming) Reset()

+ func (m *NatsStreaming) String() string

+ func (m *NatsStreaming) XXX_DiscardUnknown()

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

+ func (m *NatsStreaming) XXX_Merge(src proto.Message)

+ func (m *NatsStreaming) XXX_Size() int

+ func (m *NatsStreaming) XXX_Unmarshal(b []byte) error

+ type NatsStreaming_All struct

+ All *ReadAll

+ type NatsStreaming_LastAvailable struct

+ LastAvailable *ReadLastAvailable

+ type NatsStreaming_ReadSequenceNumber struct

+ ReadSequenceNumber *ReadSequenceNumber

+ type NatsStreaming_ReadSince struct

+ ReadSince *ReadSince

+ type NextOffset struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NextOffset) Descriptor() ([]byte, []int)

+ func (*NextOffset) ProtoMessage()

+ func (m *NextOffset) Reset()

+ func (m *NextOffset) String() string

+ func (m *NextOffset) XXX_DiscardUnknown()

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

+ func (m *NextOffset) XXX_Merge(src proto.Message)

+ func (m *NextOffset) XXX_Size() int

+ func (m *NextOffset) XXX_Unmarshal(b []byte) error

+ type Postgres struct

+ PublisherName string

+ ReplicationSlotName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Postgres) Descriptor() ([]byte, []int)

+ func (*Postgres) ProtoMessage()

+ func (m *Postgres) GetPublisherName() string

+ func (m *Postgres) GetReplicationSlotName() string

+ func (m *Postgres) Reset()

+ func (m *Postgres) String() string

+ func (m *Postgres) XXX_DiscardUnknown()

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

+ func (m *Postgres) XXX_Merge(src proto.Message)

+ func (m *Postgres) XXX_Size() int

+ func (m *Postgres) XXX_Unmarshal(b []byte) error

+ type Pulsar struct

+ SubscriptionName string

+ SubscriptionType SubscriptionType

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Pulsar) Descriptor() ([]byte, []int)

+ func (*Pulsar) ProtoMessage()

+ func (m *Pulsar) GetSubscriptionName() string

+ func (m *Pulsar) GetSubscriptionType() SubscriptionType

+ func (m *Pulsar) GetTopic() string

+ func (m *Pulsar) Reset()

+ func (m *Pulsar) String() string

+ func (m *Pulsar) XXX_DiscardUnknown()

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

+ func (m *Pulsar) XXX_Merge(src proto.Message)

+ func (m *Pulsar) XXX_Size() int

+ func (m *Pulsar) XXX_Unmarshal(b []byte) error

+ type Rabbit struct

+ AppId string

+ AutoAck bool

+ ExchangeName string

+ QueueDeclare bool

+ QueueDurable bool

+ QueueExclusive bool

+ QueueName string

+ RoutingKey string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Rabbit) Descriptor() ([]byte, []int)

+ func (*Rabbit) ProtoMessage()

+ func (m *Rabbit) GetAppId() string

+ func (m *Rabbit) GetAutoAck() bool

+ func (m *Rabbit) GetExchangeName() string

+ func (m *Rabbit) GetQueueDeclare() bool

+ func (m *Rabbit) GetQueueDurable() bool

+ func (m *Rabbit) GetQueueExclusive() bool

+ func (m *Rabbit) GetQueueName() string

+ func (m *Rabbit) GetRoutingKey() string

+ func (m *Rabbit) Reset()

+ func (m *Rabbit) String() string

+ func (m *Rabbit) XXX_DiscardUnknown()

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

+ func (m *Rabbit) XXX_Merge(src proto.Message)

+ func (m *Rabbit) XXX_Size() int

+ func (m *Rabbit) XXX_Unmarshal(b []byte) error

+ type RabbitStreams struct

+ DeclareStream *DeclareStream

+ OffsetOption isRabbitStreams_OffsetOption

+ Stream string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RabbitStreams) Descriptor() ([]byte, []int)

+ func (*RabbitStreams) ProtoMessage()

+ func (*RabbitStreams) XXX_OneofWrappers() []interface{}

+ func (m *RabbitStreams) GetDeclareStream() *DeclareStream

+ func (m *RabbitStreams) GetFirstOffset() *FirstOffset

+ func (m *RabbitStreams) GetLastConsumed() *LastConsumed

+ func (m *RabbitStreams) GetLastOffset() *LastOffset

+ func (m *RabbitStreams) GetNextOffset() *NextOffset

+ func (m *RabbitStreams) GetOffset() *SpecificOffset

+ func (m *RabbitStreams) GetOffsetOption() isRabbitStreams_OffsetOption

+ func (m *RabbitStreams) GetStream() string

+ func (m *RabbitStreams) Reset()

+ func (m *RabbitStreams) String() string

+ func (m *RabbitStreams) XXX_DiscardUnknown()

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

+ func (m *RabbitStreams) XXX_Merge(src proto.Message)

+ func (m *RabbitStreams) XXX_Size() int

+ func (m *RabbitStreams) XXX_Unmarshal(b []byte) error

+ type RabbitStreams_FirstOffset struct

+ FirstOffset *FirstOffset

+ type RabbitStreams_LastConsumed struct

+ LastConsumed *LastConsumed

+ type RabbitStreams_LastOffset struct

+ LastOffset *LastOffset

+ type RabbitStreams_NextOffset struct

+ NextOffset *NextOffset

+ type RabbitStreams_Offset struct

+ Offset *SpecificOffset

+ type ReadAll struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadAll) Descriptor() ([]byte, []int)

+ func (*ReadAll) ProtoMessage()

+ func (m *ReadAll) Reset()

+ func (m *ReadAll) String() string

+ func (m *ReadAll) XXX_DiscardUnknown()

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

+ func (m *ReadAll) XXX_Merge(src proto.Message)

+ func (m *ReadAll) XXX_Size() int

+ func (m *ReadAll) XXX_Unmarshal(b []byte) error

+ type ReadLastAvailable struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadLastAvailable) Descriptor() ([]byte, []int)

+ func (*ReadLastAvailable) ProtoMessage()

+ func (m *ReadLastAvailable) Reset()

+ func (m *ReadLastAvailable) String() string

+ func (m *ReadLastAvailable) XXX_DiscardUnknown()

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

+ func (m *ReadLastAvailable) XXX_Merge(src proto.Message)

+ func (m *ReadLastAvailable) XXX_Size() int

+ func (m *ReadLastAvailable) XXX_Unmarshal(b []byte) error

+ type ReadSequenceNumber struct

+ SequenceNumber uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadSequenceNumber) Descriptor() ([]byte, []int)

+ func (*ReadSequenceNumber) ProtoMessage()

+ func (m *ReadSequenceNumber) GetSequenceNumber() uint32

+ func (m *ReadSequenceNumber) Reset()

+ func (m *ReadSequenceNumber) String() string

+ func (m *ReadSequenceNumber) XXX_DiscardUnknown()

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

+ func (m *ReadSequenceNumber) XXX_Merge(src proto.Message)

+ func (m *ReadSequenceNumber) XXX_Size() int

+ func (m *ReadSequenceNumber) XXX_Unmarshal(b []byte) error

+ type ReadSince struct

+ Since string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadSince) Descriptor() ([]byte, []int)

+ func (*ReadSince) ProtoMessage()

+ func (m *ReadSince) GetSince() string

+ func (m *ReadSince) Reset()

+ func (m *ReadSince) String() string

+ func (m *ReadSince) XXX_DiscardUnknown()

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

+ func (m *ReadSince) XXX_Merge(src proto.Message)

+ func (m *ReadSince) XXX_Size() int

+ func (m *ReadSince) XXX_Unmarshal(b []byte) error

+ type RedisPubsub struct

+ Channel []string

+ Database uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RedisPubsub) Descriptor() ([]byte, []int)

+ func (*RedisPubsub) ProtoMessage()

+ func (m *RedisPubsub) GetChannel() []string

+ func (m *RedisPubsub) GetDatabase() uint32

+ func (m *RedisPubsub) Reset()

+ func (m *RedisPubsub) String() string

+ func (m *RedisPubsub) XXX_DiscardUnknown()

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

+ func (m *RedisPubsub) XXX_Merge(src proto.Message)

+ func (m *RedisPubsub) XXX_Size() int

+ func (m *RedisPubsub) XXX_Unmarshal(b []byte) error

+ type RedisStreams struct

+ ConsumerGroup string

+ ConsumerName string

+ CreateConsumerConfig *CreateConsumerConfig

+ Database uint32

+ Id string

+ Key string

+ Stream []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RedisStreams) Descriptor() ([]byte, []int)

+ func (*RedisStreams) ProtoMessage()

+ func (m *RedisStreams) GetConsumerGroup() string

+ func (m *RedisStreams) GetConsumerName() string

+ func (m *RedisStreams) GetCreateConsumerConfig() *CreateConsumerConfig

+ func (m *RedisStreams) GetDatabase() uint32

+ func (m *RedisStreams) GetId() string

+ func (m *RedisStreams) GetKey() string

+ func (m *RedisStreams) GetStream() []string

+ func (m *RedisStreams) Reset()

+ func (m *RedisStreams) String() string

+ func (m *RedisStreams) XXX_DiscardUnknown()

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

+ func (m *RedisStreams) XXX_Merge(src proto.Message)

+ func (m *RedisStreams) XXX_Size() int

+ func (m *RedisStreams) XXX_Unmarshal(b []byte) error

+ type SpecificOffset struct

+ Offset uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SpecificOffset) Descriptor() ([]byte, []int)

+ func (*SpecificOffset) ProtoMessage()

+ func (m *SpecificOffset) GetOffset() uint64

+ func (m *SpecificOffset) Reset()

+ func (m *SpecificOffset) String() string

+ func (m *SpecificOffset) XXX_DiscardUnknown()

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

+ func (m *SpecificOffset) XXX_Merge(src proto.Message)

+ func (m *SpecificOffset) XXX_Size() int

+ func (m *SpecificOffset) XXX_Unmarshal(b []byte) error

+ type SubscriptionType int32

+ const SubscriptionType_Exclusive

+ const SubscriptionType_Failover

+ const SubscriptionType_Keyshared

+ const SubscriptionType_Shared

+ const SubscriptionType_Unset

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

+ func (x SubscriptionType) String() string

v0.0.31

Aug 20, 2021

Changes in this version

+ type Kafka struct

+ CommitIntervalSeconds int32

+ ConsumerGroupName string

+ MaxBytes int32

+ MaxWaitSeconds int32

+ MinBytes int32

+ ReadOffset int64

+ RebalanceTimeoutSeconds int32

+ Topics []string

+ UseConsumerGroup bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Kafka) Descriptor() ([]byte, []int)

+ func (*Kafka) ProtoMessage()

+ func (m *Kafka) GetCommitIntervalSeconds() int32

+ func (m *Kafka) GetConsumerGroupName() string

+ func (m *Kafka) GetMaxBytes() int32

+ func (m *Kafka) GetMaxWaitSeconds() int32

+ func (m *Kafka) GetMinBytes() int32

+ func (m *Kafka) GetReadOffset() int64

+ func (m *Kafka) GetRebalanceTimeoutSeconds() int32

+ func (m *Kafka) GetTopics() []string

+ func (m *Kafka) GetUseConsumerGroup() bool

+ func (m *Kafka) Reset()

+ func (m *Kafka) String() string

+ func (m *Kafka) XXX_DiscardUnknown()

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

+ func (m *Kafka) XXX_Merge(src proto.Message)

+ func (m *Kafka) XXX_Size() int

+ func (m *Kafka) XXX_Unmarshal(b []byte) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL