args

Apr 26, 2023

Changes in this version

+ 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

type AWSKinesisConn

+ func (x *AWSKinesisConn) ProtoReflect() protoreflect.Message

type AWSKinesisReadArgs

+ func (x *AWSKinesisReadArgs) ProtoReflect() protoreflect.Message

type AWSKinesisWriteArgs

+ func (x *AWSKinesisWriteArgs) ProtoReflect() protoreflect.Message

type AWSSNSConn

+ func (x *AWSSNSConn) ProtoReflect() protoreflect.Message

type AWSSNSWriteArgs

+ func (x *AWSSNSWriteArgs) ProtoReflect() protoreflect.Message

type AWSSQSConn

+ func (x *AWSSQSConn) ProtoReflect() protoreflect.Message

type AWSSQSReadArgs

+ func (x *AWSSQSReadArgs) ProtoReflect() protoreflect.Message

type AWSSQSRelayArgs

+ func (x *AWSSQSRelayArgs) ProtoReflect() protoreflect.Message

type AWSSQSWriteArgs

+ func (x *AWSSQSWriteArgs) ProtoReflect() protoreflect.Message

type ActiveMQConn

+ func (x *ActiveMQConn) ProtoReflect() protoreflect.Message

type ActiveMQReadArgs

+ func (x *ActiveMQReadArgs) ProtoReflect() protoreflect.Message

type ActiveMQWriteArgs

+ func (x *ActiveMQWriteArgs) ProtoReflect() protoreflect.Message

type AzureEventHubConn

+ func (x *AzureEventHubConn) ProtoReflect() protoreflect.Message

type AzureEventHubReadArgs

+ func (x *AzureEventHubReadArgs) ProtoReflect() protoreflect.Message

type AzureEventHubWriteArgs

+ func (x *AzureEventHubWriteArgs) ProtoReflect() protoreflect.Message

type AzureServiceBusConn

+ func (x *AzureServiceBusConn) ProtoReflect() protoreflect.Message

type AzureServiceBusReadArgs

+ func (x *AzureServiceBusReadArgs) ProtoReflect() protoreflect.Message

type AzureServiceBusWriteArgs

+ func (x *AzureServiceBusWriteArgs) ProtoReflect() protoreflect.Message

type CreateConsumerConfig

+ func (x *CreateConsumerConfig) ProtoReflect() protoreflect.Message

type GCPPubSubConn

+ func (x *GCPPubSubConn) ProtoReflect() protoreflect.Message

type GCPPubSubReadArgs

+ func (x *GCPPubSubReadArgs) ProtoReflect() protoreflect.Message

type GCPPubSubWriteArgs

+ func (x *GCPPubSubWriteArgs) ProtoReflect() protoreflect.Message

type KafkaConn

+ func (x *KafkaConn) ProtoReflect() protoreflect.Message

type KafkaReadArgs

+ func (x *KafkaReadArgs) ProtoReflect() protoreflect.Message

type KafkaRelayArgs

+ func (x *KafkaRelayArgs) ProtoReflect() protoreflect.Message

type KafkaWriteArgs

+ func (x *KafkaWriteArgs) ProtoReflect() protoreflect.Message

type KubeMQQueueConn

+ func (x *KubeMQQueueConn) ProtoReflect() protoreflect.Message

type KubeMQQueueReadArgs

+ func (x *KubeMQQueueReadArgs) ProtoReflect() protoreflect.Message

type KubeMQQueueWriteArgs

+ func (x *KubeMQQueueWriteArgs) ProtoReflect() protoreflect.Message

type MQTTConn

+ func (x *MQTTConn) ProtoReflect() protoreflect.Message

type MQTTQoSLevel

+ func (MQTTQoSLevel) Descriptor() protoreflect.EnumDescriptor

+ func (MQTTQoSLevel) Type() protoreflect.EnumType

+ func (x MQTTQoSLevel) Enum() *MQTTQoSLevel

+ func (x MQTTQoSLevel) Number() protoreflect.EnumNumber

type MQTTReadArgs

+ func (x *MQTTReadArgs) ProtoReflect() protoreflect.Message

type MQTTTLSOptions

+ func (x *MQTTTLSOptions) ProtoReflect() protoreflect.Message

type MQTTWriteArgs

+ func (x *MQTTWriteArgs) ProtoReflect() protoreflect.Message

type MemphisConn

+ func (x *MemphisConn) ProtoReflect() protoreflect.Message

type MemphisReadArgs

+ func (x *MemphisReadArgs) ProtoReflect() protoreflect.Message

type MemphisWriteArgs

+ func (x *MemphisWriteArgs) ProtoReflect() protoreflect.Message

type MongoConn

+ func (x *MongoConn) ProtoReflect() protoreflect.Message

type MongoReadArgs

+ func (x *MongoReadArgs) ProtoReflect() protoreflect.Message

type NSQConn

+ func (x *NSQConn) ProtoReflect() protoreflect.Message

type NSQReadArgs

+ func (x *NSQReadArgs) ProtoReflect() protoreflect.Message

type NSQWriteArgs

+ func (x *NSQWriteArgs) ProtoReflect() protoreflect.Message

type NatsConn

+ func (x *NatsConn) ProtoReflect() protoreflect.Message

type NatsJetstreamConn

+ func (x *NatsJetstreamConn) ProtoReflect() protoreflect.Message

type NatsJetstreamReadArgs

+ func (x *NatsJetstreamReadArgs) ProtoReflect() protoreflect.Message

type NatsJetstreamTLSOptions

+ func (x *NatsJetstreamTLSOptions) ProtoReflect() protoreflect.Message

type NatsJetstreamWriteArgs

+ func (x *NatsJetstreamWriteArgs) ProtoReflect() protoreflect.Message

type NatsReadArgs

+ func (x *NatsReadArgs) ProtoReflect() protoreflect.Message

type NatsStreamingConn

+ func (x *NatsStreamingConn) ProtoReflect() protoreflect.Message

type NatsStreamingReadArgs

+ func (x *NatsStreamingReadArgs) ProtoReflect() protoreflect.Message

type NatsStreamingTLSOptions

+ func (x *NatsStreamingTLSOptions) ProtoReflect() protoreflect.Message

type NatsStreamingWriteArgs

+ func (x *NatsStreamingWriteArgs) ProtoReflect() protoreflect.Message

type NatsTLSOptions

+ func (x *NatsTLSOptions) ProtoReflect() protoreflect.Message

type NatsWriteArgs

+ func (x *NatsWriteArgs) ProtoReflect() protoreflect.Message

type OffsetStart

+ func (OffsetStart) Descriptor() protoreflect.EnumDescriptor

+ func (OffsetStart) Type() protoreflect.EnumType

+ func (x OffsetStart) Enum() *OffsetStart

+ func (x OffsetStart) Number() protoreflect.EnumNumber

type PostgresConn

+ func (x *PostgresConn) ProtoReflect() protoreflect.Message

type PostgresReadArgs

+ func (x *PostgresReadArgs) ProtoReflect() protoreflect.Message

type PulsarConn

+ func (x *PulsarConn) ProtoReflect() protoreflect.Message

type PulsarReadArgs

+ func (x *PulsarReadArgs) ProtoReflect() protoreflect.Message

type PulsarWriteArgs

+ func (x *PulsarWriteArgs) ProtoReflect() protoreflect.Message

type RabbitConn

+ func (x *RabbitConn) ProtoReflect() protoreflect.Message

type RabbitReadArgs

+ func (x *RabbitReadArgs) ProtoReflect() protoreflect.Message

type RabbitStreamsConn

+ func (x *RabbitStreamsConn) ProtoReflect() protoreflect.Message

type RabbitStreamsOffsetOptions

+ func (x *RabbitStreamsOffsetOptions) ProtoReflect() protoreflect.Message

type RabbitStreamsReadArgs

+ func (x *RabbitStreamsReadArgs) ProtoReflect() protoreflect.Message

type RabbitStreamsWriteArgs

+ func (x *RabbitStreamsWriteArgs) ProtoReflect() protoreflect.Message

type RabbitWriteArgs

+ func (x *RabbitWriteArgs) ProtoReflect() protoreflect.Message

type RedisPubSubConn

+ func (x *RedisPubSubConn) ProtoReflect() protoreflect.Message

type RedisPubSubReadArgs

+ func (x *RedisPubSubReadArgs) ProtoReflect() protoreflect.Message

type RedisPubSubWriteArgs

+ func (x *RedisPubSubWriteArgs) ProtoReflect() protoreflect.Message

type RedisStreamsConn

+ func (x *RedisStreamsConn) ProtoReflect() protoreflect.Message

type RedisStreamsReadArgs

+ func (x *RedisStreamsReadArgs) ProtoReflect() protoreflect.Message

type RedisStreamsWriteArgs

+ func (x *RedisStreamsWriteArgs) ProtoReflect() protoreflect.Message

type SASLType

+ func (SASLType) Descriptor() protoreflect.EnumDescriptor

+ func (SASLType) Type() protoreflect.EnumType

+ func (x SASLType) Enum() *SASLType

+ func (x SASLType) Number() protoreflect.EnumNumber

type SubscriptionInitialPosition

+ func (SubscriptionInitialPosition) Descriptor() protoreflect.EnumDescriptor

+ func (SubscriptionInitialPosition) Type() protoreflect.EnumType

+ func (x SubscriptionInitialPosition) Enum() *SubscriptionInitialPosition

+ func (x SubscriptionInitialPosition) Number() protoreflect.EnumNumber

type SubscriptionType

+ func (SubscriptionType) Descriptor() protoreflect.EnumDescriptor

+ func (SubscriptionType) Type() protoreflect.EnumType

+ func (x SubscriptionType) Enum() *SubscriptionType

+ func (x SubscriptionType) Number() protoreflect.EnumNumber

Feb 15, 2023

Changes in this version

+ type MemphisConn struct

+ Address string

+ BrokerToken string

+ Username string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MemphisConn) ProtoMessage()

+ func (m *MemphisConn) GetAddress() string

+ func (m *MemphisConn) GetBrokerToken() string

+ func (m *MemphisConn) GetUsername() string

+ func (m *MemphisConn) Reset()

+ func (m *MemphisConn) String() string

+ func (m *MemphisConn) XXX_DiscardUnknown()

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

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

+ func (m *MemphisConn) XXX_Size() int

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

+ type MemphisReadArgs struct

+ ConsumerGroup string

+ ConsumerName string

+ Station string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MemphisReadArgs) ProtoMessage()

+ func (m *MemphisReadArgs) GetConsumerGroup() string

+ func (m *MemphisReadArgs) GetConsumerName() string

+ func (m *MemphisReadArgs) GetStation() string

+ func (m *MemphisReadArgs) Reset()

+ func (m *MemphisReadArgs) String() string

+ func (m *MemphisReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *MemphisReadArgs) XXX_Size() int

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

+ type MemphisWriteArgs struct

+ Headers map[string]string

+ MessageId string

+ ProducerName string

+ Station string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MemphisWriteArgs) ProtoMessage()

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

+ func (m *MemphisWriteArgs) GetMessageId() string

+ func (m *MemphisWriteArgs) GetProducerName() string

+ func (m *MemphisWriteArgs) GetStation() string

+ func (m *MemphisWriteArgs) Reset()

+ func (m *MemphisWriteArgs) String() string

+ func (m *MemphisWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *MemphisWriteArgs) XXX_Size() int

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

Feb 15, 2023

Changes in this version

+ var SubscriptionInitialPosition_name = map[int32]string

+ var SubscriptionInitialPosition_value = map[string]int32

type PulsarConn

+ ListenerName string

+ Token string

+ func (m *PulsarConn) GetListenerName() string

+ func (m *PulsarConn) GetToken() string

type PulsarReadArgs

+ InitialPosition SubscriptionInitialPosition

+ func (m *PulsarReadArgs) GetInitialPosition() SubscriptionInitialPosition

+ type SubscriptionInitialPosition int32

+ const SubscriptionInitialPosition_PULSAR_EARLIEST

+ const SubscriptionInitialPosition_PULSAR_LATEST

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

+ func (x SubscriptionInitialPosition) String() string

Jan 10, 2023

Changes in this version

type RabbitReadArgs

+ DeadLetter bool

+ func (m *RabbitReadArgs) GetDeadLetter() bool

Nov 30, 2022

Changes in this version

type RabbitReadArgs

+ ExcludeBindingKeyRegex string

+ func (m *RabbitReadArgs) GetExcludeBindingKeyRegex() string

Nov 24, 2022

Changes in this version

type RabbitReadArgs

+ ExcludeRoutingKeyRegex string

+ func (m *RabbitReadArgs) GetExcludeRoutingKeyRegex() string

Aug 15, 2022

Changes in this version

type NatsConn

+ Nkey string

+ func (m *NatsConn) GetNkey() string

type NatsJetstreamConn

+ Nkey string

+ func (m *NatsJetstreamConn) GetNkey() string

Jun 22, 2022

Changes in this version

type NatsJetstreamWriteArgs

+ Subject string

+ func (m *NatsJetstreamWriteArgs) GetSubject() string

Jun 21, 2022

Changes in this version

type NatsJetstreamReadArgs

+ CreateDurableConsumer bool

+ ExistingDurableConsumer bool

+ func (m *NatsJetstreamReadArgs) GetCreateDurableConsumer() bool

+ func (m *NatsJetstreamReadArgs) GetExistingDurableConsumer() bool

Jun 21, 2022

Changes in this version

type NatsJetstreamReadArgs

+ ConsumerFilterSubject string

+ ConsumerName string

+ ConsumerStartSequence int64

+ ConsumerStartTime string

+ KeepConsumer bool

+ UseDurableConsumer bool

+ func (m *NatsJetstreamReadArgs) GetConsumerFilterSubject() string

+ func (m *NatsJetstreamReadArgs) GetConsumerName() string

+ func (m *NatsJetstreamReadArgs) GetConsumerStartSequence() int64

+ func (m *NatsJetstreamReadArgs) GetConsumerStartTime() string

+ func (m *NatsJetstreamReadArgs) GetKeepConsumer() bool

+ func (m *NatsJetstreamReadArgs) GetUseDurableConsumer() bool

Feb 21, 2022

Changes in this version

type NatsJetstreamTLSOptions

+ UseTls bool

+ func (m *NatsJetstreamTLSOptions) GetUseTls() bool

type NatsStreamingTLSOptions

+ UseTls bool

+ func (m *NatsStreamingTLSOptions) GetUseTls() bool

type NatsTLSOptions

+ UseTls bool

+ func (m *NatsTLSOptions) GetUseTls() bool

Jan 25, 2022

Changes in this version

type KafkaConn

+ Addresses []string

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

type OffsetStart

+ const OffsetStart_LATEST

+ const OffsetStart_OLDEST

Jan 25, 2022

Changes in this version

type NatsConn

+ TlsOptions *NatsTLSOptions

+ func (m *NatsConn) GetTlsOptions() *NatsTLSOptions

+ type NatsTLSOptions struct

+ TlsCaCert []byte

+ TlsClientCert []byte

+ TlsClientKey []byte

+ TlsSkipVerify bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsTLSOptions) ProtoMessage()

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

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

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

+ func (m *NatsTLSOptions) GetTlsSkipVerify() bool

+ func (m *NatsTLSOptions) Reset()

+ func (m *NatsTLSOptions) String() string

+ func (m *NatsTLSOptions) XXX_DiscardUnknown()

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

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

+ func (m *NatsTLSOptions) XXX_Size() int

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

Jan 4, 2022

Changes in this version

type AWSKinesisConn

+ AwsProfile string

+ func (m *AWSKinesisConn) GetAwsProfile() string

type AWSSNSConn

+ AwsProfile string

+ func (m *AWSSNSConn) GetAwsProfile() string

type AWSSQSConn

+ AwsProfile string

+ func (m *AWSSQSConn) GetAwsProfile() string

Dec 21, 2021

Changes in this version

+ type AWSKinesisConn struct

+ AwsAccessKeyId string

+ AwsRegion string

+ AwsSecretAccessKey string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AWSKinesisConn) ProtoMessage()

+ func (m *AWSKinesisConn) GetAwsAccessKeyId() string

+ func (m *AWSKinesisConn) GetAwsRegion() string

+ func (m *AWSKinesisConn) GetAwsSecretAccessKey() string

+ func (m *AWSKinesisConn) Reset()

+ func (m *AWSKinesisConn) String() string

+ func (m *AWSKinesisConn) XXX_DiscardUnknown()

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

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

+ func (m *AWSKinesisConn) XXX_Size() int

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

+ type AWSKinesisReadArgs struct

+ MaxRecords int64

+ ReadAfterSequenceNumber string

+ ReadFromTimestamp int64

+ ReadLatest bool

+ ReadSequenceNumber string

+ ReadTrimHorizon bool

+ Shard string

+ Stream string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AWSKinesisReadArgs) ProtoMessage()

+ func (m *AWSKinesisReadArgs) GetMaxRecords() int64

+ func (m *AWSKinesisReadArgs) GetReadAfterSequenceNumber() string

+ func (m *AWSKinesisReadArgs) GetReadFromTimestamp() int64

+ func (m *AWSKinesisReadArgs) GetReadLatest() bool

+ func (m *AWSKinesisReadArgs) GetReadSequenceNumber() string

+ func (m *AWSKinesisReadArgs) GetReadTrimHorizon() bool

+ func (m *AWSKinesisReadArgs) GetShard() string

+ func (m *AWSKinesisReadArgs) GetStream() string

+ func (m *AWSKinesisReadArgs) Reset()

+ func (m *AWSKinesisReadArgs) String() string

+ func (m *AWSKinesisReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *AWSKinesisReadArgs) XXX_Size() int

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

+ type AWSKinesisWriteArgs struct

+ PartitionKey string

+ SequenceNumber string

+ Stream string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AWSKinesisWriteArgs) ProtoMessage()

+ func (m *AWSKinesisWriteArgs) GetPartitionKey() string

+ func (m *AWSKinesisWriteArgs) GetSequenceNumber() string

+ func (m *AWSKinesisWriteArgs) GetStream() string

+ func (m *AWSKinesisWriteArgs) Reset()

+ func (m *AWSKinesisWriteArgs) String() string

+ func (m *AWSKinesisWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *AWSKinesisWriteArgs) XXX_Size() int

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

Dec 16, 2021

Changes in this version

+ type NatsJetstreamConn struct

+ ClientId string

+ Dsn string

+ TlsOptions *NatsJetstreamTLSOptions

+ UserCredentials []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsJetstreamConn) ProtoMessage()

+ func (m *NatsJetstreamConn) GetClientId() string

+ func (m *NatsJetstreamConn) GetDsn() string

+ func (m *NatsJetstreamConn) GetTlsOptions() *NatsJetstreamTLSOptions

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

+ func (m *NatsJetstreamConn) Reset()

+ func (m *NatsJetstreamConn) String() string

+ func (m *NatsJetstreamConn) XXX_DiscardUnknown()

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

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

+ func (m *NatsJetstreamConn) XXX_Size() int

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

+ type NatsJetstreamReadArgs struct

+ Stream string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsJetstreamReadArgs) ProtoMessage()

+ func (m *NatsJetstreamReadArgs) GetStream() string

+ func (m *NatsJetstreamReadArgs) Reset()

+ func (m *NatsJetstreamReadArgs) String() string

+ func (m *NatsJetstreamReadArgs) XXX_DiscardUnknown()

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

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

+ func (m *NatsJetstreamReadArgs) XXX_Size() int

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

+ type NatsJetstreamTLSOptions struct

+ TlsCaCert []byte

+ TlsClientCert []byte

+ TlsClientKey []byte

+ TlsSkipVerify bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsJetstreamTLSOptions) ProtoMessage()

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

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

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

+ func (m *NatsJetstreamTLSOptions) GetTlsSkipVerify() bool

+ func (m *NatsJetstreamTLSOptions) Reset()

+ func (m *NatsJetstreamTLSOptions) String() string

+ func (m *NatsJetstreamTLSOptions) XXX_DiscardUnknown()

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

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

+ func (m *NatsJetstreamTLSOptions) XXX_Size() int

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

+ type NatsJetstreamWriteArgs struct

+ Stream string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsJetstreamWriteArgs) ProtoMessage()

+ func (m *NatsJetstreamWriteArgs) GetStream() string

+ func (m *NatsJetstreamWriteArgs) Reset()

+ func (m *NatsJetstreamWriteArgs) String() string

+ func (m *NatsJetstreamWriteArgs) XXX_DiscardUnknown()

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

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

+ func (m *NatsJetstreamWriteArgs) XXX_Size() int

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

Dec 15, 2021

Changes in this version

type RabbitReadArgs

+ QueueArg map[string]string

+ func (m *RabbitReadArgs) GetQueueArg() map[string]string

Dec 3, 2021

Changes in this version

type KafkaConn

+ TlsSkipVerify bool

+ func (m *KafkaConn) GetTlsSkipVerify() bool

type KubeMQQueueConn

+ TlsClientCert string

+ func (m *KubeMQQueueConn) GetTlsClientCert() string

type MQTTTLSOptions

+ TlsCaCert []byte

+ TlsClientCert []byte

+ TlsClientKey []byte

+ TlsSkipVerify bool

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

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

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

+ func (m *MQTTTLSOptions) GetTlsSkipVerify() bool

type NSQConn

+ TlsSkipVerify bool

+ func (m *NSQConn) GetTlsSkipVerify() bool

type NatsConn

+ TlsSkipVerify bool

+ func (m *NatsConn) GetTlsSkipVerify() bool

type NatsStreamingTLSOptions

+ TlsCaCert []byte

+ TlsClientCert []byte

+ TlsClientKey []byte

+ TlsSkipVerify bool

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

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

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

+ func (m *NatsStreamingTLSOptions) GetTlsSkipVerify() bool

type PostgresConn

+ TlsSkipVerify bool

+ func (m *PostgresConn) GetTlsSkipVerify() bool

type PulsarConn

+ TlsSkipVerify bool

+ func (m *PulsarConn) GetTlsSkipVerify() bool

type RabbitConn

+ TlsSkipVerify bool

+ func (m *RabbitConn) GetTlsSkipVerify() bool

type RabbitStreamsConn

+ TlsSkipVerify bool

+ func (m *RabbitStreamsConn) GetTlsSkipVerify() bool

type RedisPubSubReadArgs

+ Channels []string

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

type RedisPubSubWriteArgs

+ Channels []string

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

type RedisStreamsReadArgs

+ Streams []string

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

Nov 30, 2021

Changes in this version

type KafkaWriteArgs

+ Topic []string

+ func (m *KafkaWriteArgs) GetTopic() []string

Nov 30, 2021

Changes in this version

type KafkaRelayArgs

+ Topic []string

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

Nov 30, 2021

Changes in this version

type KafkaReadArgs

+ Topic []string

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

Nov 29, 2021

Changes in this version

type RedisStreamsWriteArgs

+ Stream []string

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

Nov 23, 2021

Changes in this version

type NatsStreamingConn

+ TlsOptions *NatsStreamingTLSOptions

+ func (m *NatsStreamingConn) GetTlsOptions() *NatsStreamingTLSOptions

+ type NatsStreamingTLSOptions struct

+ CaFile []byte

+ ClientCert []byte

+ ClientKey []byte

+ SkipVerify bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsStreamingTLSOptions) ProtoMessage()

+ func (m *NatsStreamingTLSOptions) GetCaFile() []byte

+ func (m *NatsStreamingTLSOptions) GetClientCert() []byte

+ func (m *NatsStreamingTLSOptions) GetClientKey() []byte

+ func (m *NatsStreamingTLSOptions) GetSkipVerify() bool

+ func (m *NatsStreamingTLSOptions) Reset()

+ func (m *NatsStreamingTLSOptions) String() string

+ func (m *NatsStreamingTLSOptions) XXX_DiscardUnknown()

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

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

+ func (m *NatsStreamingTLSOptions) XXX_Size() int

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

Nov 21, 2021

Changes in this version

type MQTTTLSOptions

+ ClientCert []byte

+ ClientKey []byte

+ func (m *MQTTTLSOptions) GetClientCert() []byte

+ func (m *MQTTTLSOptions) GetClientKey() []byte

Nov 16, 2021

Changes in this version

type KubeMQQueueConn

+ ClientId string

+ func (m *KubeMQQueueConn) GetClientId() string

Nov 15, 2021

Changes in this version

type GCPPubSubConn

+ CredentialsFile string

+ CredentialsJson string

+ func (m *GCPPubSubConn) GetCredentialsFile() string

+ func (m *GCPPubSubConn) GetCredentialsJson() string

Nov 12, 2021

Changes in this version

type RedisPubSubConn

+ Database uint32

+ func (m *RedisPubSubConn) GetDatabase() uint32

type RedisStreamsConn

+ Database uint32

+ func (m *RedisStreamsConn) GetDatabase() uint32

Sep 28, 2021

Changes in this version

+ var OffsetStart_name = map[int32]string

+ var OffsetStart_value = map[string]int32

+ var SASLType_name = map[int32]string

+ var SASLType_value = map[string]int32

+ type OffsetStart int32

+ const OffsetStart_Latest

+ const OffsetStart_Oldest

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

+ func (x OffsetStart) String() string

+ type SASLType int32

+ const SASLType_NONE

+ const SASLType_PLAIN

+ const SASLType_SCRAM

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

+ func (x SASLType) String() string

Sep 15, 2021

Changes in this version

type RabbitWriteArgs

+ ExchangeAutoDelete bool

+ ExchangeDeclare bool

+ ExchangeDurable bool

+ ExchangeType string

+ func (m *RabbitWriteArgs) GetExchangeAutoDelete() bool

+ func (m *RabbitWriteArgs) GetExchangeDeclare() bool

+ func (m *RabbitWriteArgs) GetExchangeDurable() bool

+ func (m *RabbitWriteArgs) GetExchangeType() string

Sep 11, 2021

Changes in this version

type KafkaWriteArgs

+ Topics []string

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

Sep 11, 2021

Changes in this version

type KafkaReadArgs

+ IncludeOffsetInfo bool

+ Lag bool

+ LagConsumerGroup string

+ func (m *KafkaReadArgs) GetIncludeOffsetInfo() bool

+ func (m *KafkaReadArgs) GetLag() bool

+ func (m *KafkaReadArgs) GetLagConsumerGroup() string

Sep 8, 2021

Changes in this version

+ 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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

Sep 8, 2021

Changes in this version

+ var CreateConsumerConfig_OffsetStart_name = map[int32]string

+ var CreateConsumerConfig_OffsetStart_value = map[string]int32

+ 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 SubscriptionType_name = map[int32]string

+ var SubscriptionType_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 AWSSNSWriteOpts struct

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AWSSNSWriteOpts) ProtoMessage()

+ func (m *AWSSNSWriteOpts) GetTopic() string

+ func (m *AWSSNSWriteOpts) Reset()

+ func (m *AWSSNSWriteOpts) String() string

+ func (m *AWSSNSWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *AWSSNSWriteOpts) XXX_Size() int

+ func (m *AWSSNSWriteOpts) 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 AWSSQSReadOpts struct

+ AutoDelete bool

+ MaxNumMessages uint32

+ QueueName string

+ ReceiveRequestAttemptId string

+ RemoteAccountId string

+ WaitTimeSeconds uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AWSSQSReadOpts) ProtoMessage()

+ func (m *AWSSQSReadOpts) GetAutoDelete() bool

+ func (m *AWSSQSReadOpts) GetMaxNumMessages() uint32

+ func (m *AWSSQSReadOpts) GetQueueName() string

+ func (m *AWSSQSReadOpts) GetReceiveRequestAttemptId() string

+ func (m *AWSSQSReadOpts) GetRemoteAccountId() string

+ func (m *AWSSQSReadOpts) GetWaitTimeSeconds() uint32

+ func (m *AWSSQSReadOpts) Reset()

+ func (m *AWSSQSReadOpts) String() string

+ func (m *AWSSQSReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *AWSSQSReadOpts) XXX_Size() int

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

+ type AWSSQSRelayOpts struct

+ AutoDelete bool

+ MaxNumMessages uint32

+ QueueName string

+ ReceiveRequestAttemptId string

+ RemoteAccountId string

+ WaitTimeSeconds int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AWSSQSRelayOpts) ProtoMessage()

+ func (m *AWSSQSRelayOpts) GetAutoDelete() bool

+ func (m *AWSSQSRelayOpts) GetMaxNumMessages() uint32

+ func (m *AWSSQSRelayOpts) GetQueueName() string

+ func (m *AWSSQSRelayOpts) GetReceiveRequestAttemptId() string

+ func (m *AWSSQSRelayOpts) GetRemoteAccountId() string

+ func (m *AWSSQSRelayOpts) GetWaitTimeSeconds() int32

+ func (m *AWSSQSRelayOpts) Reset()

+ func (m *AWSSQSRelayOpts) String() string

+ func (m *AWSSQSRelayOpts) XXX_DiscardUnknown()

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

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

+ func (m *AWSSQSRelayOpts) XXX_Size() int

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

+ type AWSSQSWriteOpts 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 (*AWSSQSWriteOpts) Descriptor() ([]byte, []int)

+ func (*AWSSQSWriteOpts) ProtoMessage()

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

+ func (m *AWSSQSWriteOpts) GetDelaySeconds() uint32

+ func (m *AWSSQSWriteOpts) GetMessageDeduplicationId() string

+ func (m *AWSSQSWriteOpts) GetMessageGroupId() string

+ func (m *AWSSQSWriteOpts) GetQueueName() string

+ func (m *AWSSQSWriteOpts) GetRemoteAccountId() string

+ func (m *AWSSQSWriteOpts) Reset()

+ func (m *AWSSQSWriteOpts) String() string

+ func (m *AWSSQSWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *AWSSQSWriteOpts) XXX_Size() int

+ func (m *AWSSQSWriteOpts) 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 ActiveMQReadOpts struct

+ Queue string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ActiveMQReadOpts) ProtoMessage()

+ func (m *ActiveMQReadOpts) GetQueue() string

+ func (m *ActiveMQReadOpts) GetTopic() string

+ func (m *ActiveMQReadOpts) Reset()

+ func (m *ActiveMQReadOpts) String() string

+ func (m *ActiveMQReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *ActiveMQReadOpts) XXX_Size() int

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

+ type ActiveMQWriteOpts struct

+ Queue string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ActiveMQWriteOpts) ProtoMessage()

+ func (m *ActiveMQWriteOpts) GetQueue() string

+ func (m *ActiveMQWriteOpts) GetTopic() string

+ func (m *ActiveMQWriteOpts) Reset()

+ func (m *ActiveMQWriteOpts) String() string

+ func (m *ActiveMQWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *ActiveMQWriteOpts) XXX_Size() int

+ func (m *ActiveMQWriteOpts) 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 AzureEventHubReadOpts struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AzureEventHubReadOpts) ProtoMessage()

+ func (m *AzureEventHubReadOpts) Reset()

+ func (m *AzureEventHubReadOpts) String() string

+ func (m *AzureEventHubReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *AzureEventHubReadOpts) XXX_Size() int

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

+ type AzureEventHubWriteOpts struct

+ MessageId string

+ PartitionKey string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AzureEventHubWriteOpts) ProtoMessage()

+ func (m *AzureEventHubWriteOpts) GetMessageId() string

+ func (m *AzureEventHubWriteOpts) GetPartitionKey() string

+ func (m *AzureEventHubWriteOpts) Reset()

+ func (m *AzureEventHubWriteOpts) String() string

+ func (m *AzureEventHubWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *AzureEventHubWriteOpts) XXX_Size() int

+ func (m *AzureEventHubWriteOpts) 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 AzureServiceBusReadOpts struct

+ Queue string

+ SubscriptionName string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AzureServiceBusReadOpts) ProtoMessage()

+ func (m *AzureServiceBusReadOpts) GetQueue() string

+ func (m *AzureServiceBusReadOpts) GetSubscriptionName() string

+ func (m *AzureServiceBusReadOpts) GetTopic() string

+ func (m *AzureServiceBusReadOpts) Reset()

+ func (m *AzureServiceBusReadOpts) String() string

+ func (m *AzureServiceBusReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *AzureServiceBusReadOpts) XXX_Size() int

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

+ type AzureServiceBusWriteOpts struct

+ Queue string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AzureServiceBusWriteOpts) ProtoMessage()

+ func (m *AzureServiceBusWriteOpts) GetQueue() string

+ func (m *AzureServiceBusWriteOpts) GetTopic() string

+ func (m *AzureServiceBusWriteOpts) Reset()

+ func (m *AzureServiceBusWriteOpts) String() string

+ func (m *AzureServiceBusWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *AzureServiceBusWriteOpts) XXX_Size() int

+ func (m *AzureServiceBusWriteOpts) 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 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 GCPPubSubReadOpts struct

+ AckMessages bool

+ SubscriptionId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GCPPubSubReadOpts) ProtoMessage()

+ func (m *GCPPubSubReadOpts) GetAckMessages() bool

+ func (m *GCPPubSubReadOpts) GetSubscriptionId() string

+ func (m *GCPPubSubReadOpts) Reset()

+ func (m *GCPPubSubReadOpts) String() string

+ func (m *GCPPubSubReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *GCPPubSubReadOpts) XXX_Size() int

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

+ type GCPPubSubWriteOpts struct

+ TopicId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GCPPubSubWriteOpts) ProtoMessage()

+ func (m *GCPPubSubWriteOpts) GetTopicId() string

+ func (m *GCPPubSubWriteOpts) Reset()

+ func (m *GCPPubSubWriteOpts) String() string

+ func (m *GCPPubSubWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *GCPPubSubWriteOpts) XXX_Size() int

+ func (m *GCPPubSubWriteOpts) 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 KafkaReadOpts 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 (*KafkaReadOpts) Descriptor() ([]byte, []int)

+ func (*KafkaReadOpts) ProtoMessage()

+ func (m *KafkaReadOpts) GetCommitIntervalSeconds() int32

+ func (m *KafkaReadOpts) GetConsumerGroupName() string

+ func (m *KafkaReadOpts) GetMaxBytes() int32

+ func (m *KafkaReadOpts) GetMaxWaitSeconds() int32

+ func (m *KafkaReadOpts) GetMinBytes() int32

+ func (m *KafkaReadOpts) GetQueueCapacity() int32

+ func (m *KafkaReadOpts) GetReadOffset() int64

+ func (m *KafkaReadOpts) GetRebalanceTimeoutSeconds() int32

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

+ func (m *KafkaReadOpts) GetUseConsumerGroup() bool

+ func (m *KafkaReadOpts) Reset()

+ func (m *KafkaReadOpts) String() string

+ func (m *KafkaReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *KafkaReadOpts) XXX_Size() int

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

+ type KafkaRelayOpts 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 (*KafkaRelayOpts) Descriptor() ([]byte, []int)

+ func (*KafkaRelayOpts) ProtoMessage()

+ func (m *KafkaRelayOpts) GetCommitIntervalSeconds() int32

+ func (m *KafkaRelayOpts) GetConsumerGroupName() string

+ func (m *KafkaRelayOpts) GetMaxBytes() int32

+ func (m *KafkaRelayOpts) GetMaxWaitSeconds() int32

+ func (m *KafkaRelayOpts) GetMinBytes() int32

+ func (m *KafkaRelayOpts) GetQueueCapacity() int32

+ func (m *KafkaRelayOpts) GetReadOffset() int64

+ func (m *KafkaRelayOpts) GetRebalanceTimeoutSeconds() int32

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

+ func (m *KafkaRelayOpts) GetUseConsumerGroup() bool

+ func (m *KafkaRelayOpts) Reset()

+ func (m *KafkaRelayOpts) String() string

+ func (m *KafkaRelayOpts) XXX_DiscardUnknown()

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

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

+ func (m *KafkaRelayOpts) XXX_Size() int

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

+ type KafkaWriteOpts struct

+ Headers map[string]string

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*KafkaWriteOpts) ProtoMessage()

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

+ func (m *KafkaWriteOpts) GetKey() string

+ func (m *KafkaWriteOpts) Reset()

+ func (m *KafkaWriteOpts) String() string

+ func (m *KafkaWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *KafkaWriteOpts) XXX_Size() int

+ func (m *KafkaWriteOpts) 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 KubeMQQueueReadOpts struct

+ ClientId string

+ QueueName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*KubeMQQueueReadOpts) ProtoMessage()

+ func (m *KubeMQQueueReadOpts) GetClientId() string

+ func (m *KubeMQQueueReadOpts) GetQueueName() string

+ func (m *KubeMQQueueReadOpts) Reset()

+ func (m *KubeMQQueueReadOpts) String() string

+ func (m *KubeMQQueueReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *KubeMQQueueReadOpts) XXX_Size() int

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

+ type KubeMQQueueWriteOpts struct

+ ClientId string

+ QueueName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*KubeMQQueueWriteOpts) ProtoMessage()

+ func (m *KubeMQQueueWriteOpts) GetClientId() string

+ func (m *KubeMQQueueWriteOpts) GetQueueName() string

+ func (m *KubeMQQueueWriteOpts) Reset()

+ func (m *KubeMQQueueWriteOpts) String() string

+ func (m *KubeMQQueueWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *KubeMQQueueWriteOpts) XXX_Size() int

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

+ type MQTTConn struct

+ Address string

+ ClientId string

+ ConnTimeoutSeconds uint32

+ QosLevel uint32

+ 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() uint32

+ 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_MQTT_QOS_LEVEL_AT_LEAST_ONCE

+ const MQTTQoSLevel_MQTT_QOS_LEVEL_AT_MOST_ONCE

+ const MQTTQoSLevel_MQTT_QOS_LEVEL_EXACTLY_ONCE

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

+ func (x MQTTQoSLevel) String() string

+ type MQTTReadOpts struct

+ ReadTimeoutSeconds uint32

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MQTTReadOpts) ProtoMessage()

+ func (m *MQTTReadOpts) GetReadTimeoutSeconds() uint32

+ func (m *MQTTReadOpts) GetTopic() string

+ func (m *MQTTReadOpts) Reset()

+ func (m *MQTTReadOpts) String() string

+ func (m *MQTTReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *MQTTReadOpts) XXX_Size() int

+ func (m *MQTTReadOpts) 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 MQTTWriteOpts struct

+ Topic string

+ WriteTimeoutSeconds uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MQTTWriteOpts) ProtoMessage()

+ func (m *MQTTWriteOpts) GetTopic() string

+ func (m *MQTTWriteOpts) GetWriteTimeoutSeconds() uint32

+ func (m *MQTTWriteOpts) Reset()

+ func (m *MQTTWriteOpts) String() string

+ func (m *MQTTWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *MQTTWriteOpts) XXX_Size() int

+ func (m *MQTTWriteOpts) 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 MongoReadOpts struct

+ Collection string

+ Database string

+ IncludeFullDocument bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MongoReadOpts) ProtoMessage()

+ func (m *MongoReadOpts) GetCollection() string

+ func (m *MongoReadOpts) GetDatabase() string

+ func (m *MongoReadOpts) GetIncludeFullDocument() bool

+ func (m *MongoReadOpts) Reset()

+ func (m *MongoReadOpts) String() string

+ func (m *MongoReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *MongoReadOpts) XXX_Size() int

+ func (m *MongoReadOpts) 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 NSQReadOpts struct

+ Channel string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NSQReadOpts) ProtoMessage()

+ func (m *NSQReadOpts) GetChannel() string

+ func (m *NSQReadOpts) GetTopic() string

+ func (m *NSQReadOpts) Reset()

+ func (m *NSQReadOpts) String() string

+ func (m *NSQReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *NSQReadOpts) XXX_Size() int

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

+ type NSQWriteOpts struct

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NSQWriteOpts) ProtoMessage()

+ func (m *NSQWriteOpts) GetTopic() string

+ func (m *NSQWriteOpts) Reset()

+ func (m *NSQWriteOpts) String() string

+ func (m *NSQWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *NSQWriteOpts) XXX_Size() int

+ func (m *NSQWriteOpts) 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 NatsReadOpts struct

+ Subject string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsReadOpts) ProtoMessage()

+ func (m *NatsReadOpts) GetSubject() string

+ func (m *NatsReadOpts) Reset()

+ func (m *NatsReadOpts) String() string

+ func (m *NatsReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *NatsReadOpts) XXX_Size() int

+ func (m *NatsReadOpts) 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 NatsStreamingReadOpts struct

+ Channel string

+ DurableName string

+ ReadAll bool

+ ReadLastAvailable bool

+ ReadSequenceNumber uint32

+ ReadSince string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsStreamingReadOpts) ProtoMessage()

+ func (m *NatsStreamingReadOpts) GetChannel() string

+ func (m *NatsStreamingReadOpts) GetDurableName() string

+ func (m *NatsStreamingReadOpts) GetReadAll() bool

+ func (m *NatsStreamingReadOpts) GetReadLastAvailable() bool

+ func (m *NatsStreamingReadOpts) GetReadSequenceNumber() uint32

+ func (m *NatsStreamingReadOpts) GetReadSince() string

+ func (m *NatsStreamingReadOpts) Reset()

+ func (m *NatsStreamingReadOpts) String() string

+ func (m *NatsStreamingReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *NatsStreamingReadOpts) XXX_Size() int

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

+ type NatsStreamingWriteOpts struct

+ Channel string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsStreamingWriteOpts) ProtoMessage()

+ func (m *NatsStreamingWriteOpts) GetChannel() string

+ func (m *NatsStreamingWriteOpts) Reset()

+ func (m *NatsStreamingWriteOpts) String() string

+ func (m *NatsStreamingWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *NatsStreamingWriteOpts) XXX_Size() int

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

+ type NatsWriteOpts struct

+ Subject string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NatsWriteOpts) ProtoMessage()

+ func (m *NatsWriteOpts) GetSubject() string

+ func (m *NatsWriteOpts) Reset()

+ func (m *NatsWriteOpts) String() string

+ func (m *NatsWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *NatsWriteOpts) XXX_Size() int

+ func (m *NatsWriteOpts) 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 PostgresReadOpts struct

+ PublisherName string

+ ReplicationSlotName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PostgresReadOpts) ProtoMessage()

+ func (m *PostgresReadOpts) GetPublisherName() string

+ func (m *PostgresReadOpts) GetReplicationSlotName() string

+ func (m *PostgresReadOpts) Reset()

+ func (m *PostgresReadOpts) String() string

+ func (m *PostgresReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *PostgresReadOpts) XXX_Size() int

+ func (m *PostgresReadOpts) 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 PulsarReadOpts struct

+ SubscriptionName string

+ SubscriptionType SubscriptionType

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PulsarReadOpts) ProtoMessage()

+ func (m *PulsarReadOpts) GetSubscriptionName() string

+ func (m *PulsarReadOpts) GetSubscriptionType() SubscriptionType

+ func (m *PulsarReadOpts) GetTopic() string

+ func (m *PulsarReadOpts) Reset()

+ func (m *PulsarReadOpts) String() string

+ func (m *PulsarReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *PulsarReadOpts) XXX_Size() int

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

+ type PulsarWriteOpts struct

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PulsarWriteOpts) ProtoMessage()

+ func (m *PulsarWriteOpts) GetTopic() string

+ func (m *PulsarWriteOpts) Reset()

+ func (m *PulsarWriteOpts) String() string

+ func (m *PulsarWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *PulsarWriteOpts) XXX_Size() int

+ func (m *PulsarWriteOpts) 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 RabbitReadOpts 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 (*RabbitReadOpts) Descriptor() ([]byte, []int)

+ func (*RabbitReadOpts) ProtoMessage()

+ func (m *RabbitReadOpts) GetAutoAck() bool

+ func (m *RabbitReadOpts) GetBindingKey() string

+ func (m *RabbitReadOpts) GetConsumerTag() string

+ func (m *RabbitReadOpts) GetExchangeName() string

+ func (m *RabbitReadOpts) GetQueueDeclare() bool

+ func (m *RabbitReadOpts) GetQueueDelete() bool

+ func (m *RabbitReadOpts) GetQueueDurable() bool

+ func (m *RabbitReadOpts) GetQueueExclusive() bool

+ func (m *RabbitReadOpts) GetQueueName() string

+ func (m *RabbitReadOpts) Reset()

+ func (m *RabbitReadOpts) String() string

+ func (m *RabbitReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *RabbitReadOpts) XXX_Size() int

+ func (m *RabbitReadOpts) 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 RabbitStreamsReadOpts struct

+ DeclareStream bool

+ DeclareStreamSize string

+ OffsetOptions *RabbitStreamsOffsetOptions

+ Stream string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RabbitStreamsReadOpts) ProtoMessage()

+ func (m *RabbitStreamsReadOpts) GetDeclareStream() bool

+ func (m *RabbitStreamsReadOpts) GetDeclareStreamSize() string

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

+ func (m *RabbitStreamsReadOpts) GetStream() string

+ func (m *RabbitStreamsReadOpts) Reset()

+ func (m *RabbitStreamsReadOpts) String() string

+ func (m *RabbitStreamsReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *RabbitStreamsReadOpts) XXX_Size() int

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

+ type RabbitStreamsWriteOpts struct

+ DeclareStream bool

+ DeclareStreamSize string

+ Stream string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RabbitStreamsWriteOpts) ProtoMessage()

+ func (m *RabbitStreamsWriteOpts) GetDeclareStream() bool

+ func (m *RabbitStreamsWriteOpts) GetDeclareStreamSize() string

+ func (m *RabbitStreamsWriteOpts) GetStream() string

+ func (m *RabbitStreamsWriteOpts) Reset()

+ func (m *RabbitStreamsWriteOpts) String() string

+ func (m *RabbitStreamsWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *RabbitStreamsWriteOpts) XXX_Size() int

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

+ type RabbitWriteOpts struct

+ AppId string

+ ExchangeName string

+ RoutingKey string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RabbitWriteOpts) ProtoMessage()

+ func (m *RabbitWriteOpts) GetAppId() string

+ func (m *RabbitWriteOpts) GetExchangeName() string

+ func (m *RabbitWriteOpts) GetRoutingKey() string

+ func (m *RabbitWriteOpts) Reset()

+ func (m *RabbitWriteOpts) String() string

+ func (m *RabbitWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *RabbitWriteOpts) XXX_Size() int

+ func (m *RabbitWriteOpts) 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 RedisPubSubReadOpts struct

+ Channel []string

+ Database uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RedisPubSubReadOpts) ProtoMessage()

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

+ func (m *RedisPubSubReadOpts) GetDatabase() uint32

+ func (m *RedisPubSubReadOpts) Reset()

+ func (m *RedisPubSubReadOpts) String() string

+ func (m *RedisPubSubReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *RedisPubSubReadOpts) XXX_Size() int

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

+ type RedisPubSubWriteOpts struct

+ Channel []string

+ Database uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RedisPubSubWriteOpts) ProtoMessage()

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

+ func (m *RedisPubSubWriteOpts) GetDatabase() uint32

+ func (m *RedisPubSubWriteOpts) Reset()

+ func (m *RedisPubSubWriteOpts) String() string

+ func (m *RedisPubSubWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *RedisPubSubWriteOpts) XXX_Size() int

+ func (m *RedisPubSubWriteOpts) 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 RedisStreamsReadOpts struct

+ ConsumerGroup string

+ ConsumerName string

+ Count uint32

+ CreateConsumerConfig *CreateConsumerConfig

+ Database uint32

+ Stream []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RedisStreamsReadOpts) ProtoMessage()

+ func (m *RedisStreamsReadOpts) GetConsumerGroup() string

+ func (m *RedisStreamsReadOpts) GetConsumerName() string

+ func (m *RedisStreamsReadOpts) GetCount() uint32

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

+ func (m *RedisStreamsReadOpts) GetDatabase() uint32

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

+ func (m *RedisStreamsReadOpts) Reset()

+ func (m *RedisStreamsReadOpts) String() string

+ func (m *RedisStreamsReadOpts) XXX_DiscardUnknown()

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

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

+ func (m *RedisStreamsReadOpts) XXX_Size() int

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

+ type RedisStreamsWriteOpts struct

+ Key string

+ Streams []string

+ WriteId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RedisStreamsWriteOpts) ProtoMessage()

+ func (m *RedisStreamsWriteOpts) GetKey() string

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

+ func (m *RedisStreamsWriteOpts) GetWriteId() string

+ func (m *RedisStreamsWriteOpts) Reset()

+ func (m *RedisStreamsWriteOpts) String() string

+ func (m *RedisStreamsWriteOpts) XXX_DiscardUnknown()

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

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

+ func (m *RedisStreamsWriteOpts) XXX_Size() int

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

+ type SubscriptionType int32

+ const SubscriptionType_EXCLUSIVE

+ const SubscriptionType_FAILOVER

+ const SubscriptionType_KEYSHARED

+ const SubscriptionType_SHARED

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

+ func (x SubscriptionType) String() string

Jul 19, 2021

Changes in this version

type Kafka

+ Brokers []string

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

Jul 16, 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