opts

Mar 13, 2024

Changes in this version

type CreateRelayOptions

+ StreamdalIntegrationOptions *StreamdalIntegrationOptions

+ func (x *CreateRelayOptions) GetStreamdalIntegrationOptions() *StreamdalIntegrationOptions

type RelayOptions

+ StreamdalIntegrationOptions *StreamdalIntegrationOptions

+ func (x *RelayOptions) GetStreamdalIntegrationOptions() *StreamdalIntegrationOptions

+ type StreamdalIntegrationOptions struct

+ StreamdalIntegrationAuthToken string

+ StreamdalIntegrationEnable bool

+ StreamdalIntegrationServerAddress string

+ StreamdalIntegrationServiceName string

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

+ func (*StreamdalIntegrationOptions) ProtoMessage()

+ func (x *StreamdalIntegrationOptions) GetStreamdalIntegrationAuthToken() string

+ func (x *StreamdalIntegrationOptions) GetStreamdalIntegrationEnable() bool

+ func (x *StreamdalIntegrationOptions) GetStreamdalIntegrationServerAddress() string

+ func (x *StreamdalIntegrationOptions) GetStreamdalIntegrationServiceName() string

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

+ func (x *StreamdalIntegrationOptions) Reset()

+ func (x *StreamdalIntegrationOptions) String() string

Apr 26, 2023

Changes in this version

+ var File_opts_ps_opts_cli_proto protoreflect.FileDescriptor

+ var File_opts_ps_opts_connection_proto protoreflect.FileDescriptor

+ var File_opts_ps_opts_manage_connection_proto protoreflect.FileDescriptor

+ var File_opts_ps_opts_manage_proto protoreflect.FileDescriptor

+ var File_opts_ps_opts_manage_relay_proto protoreflect.FileDescriptor

+ var File_opts_ps_opts_manage_tunnel_proto protoreflect.FileDescriptor

+ var File_opts_ps_opts_read_proto protoreflect.FileDescriptor

+ var File_opts_ps_opts_relay_proto protoreflect.FileDescriptor

+ var File_opts_ps_opts_server_proto protoreflect.FileDescriptor

+ var File_opts_ps_opts_streamdal_proto protoreflect.FileDescriptor

+ var File_opts_ps_opts_tunnel_proto protoreflect.FileDescriptor

+ var File_opts_ps_opts_write_proto protoreflect.FileDescriptor

type CLIOptions

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

type ConnectionOptions

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

type ConvertOption

+ func (ConvertOption) Descriptor() protoreflect.EnumDescriptor

+ func (ConvertOption) Type() protoreflect.EnumType

+ func (x ConvertOption) Enum() *ConvertOption

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

type CreateConnectionOptions

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

type CreateOptions

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

type CreateRelayOptions

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

type CreateTunnelOptions

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

type DeleteConnectionOptions

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

type DeleteOptions

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

type DeleteRelayOptions

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

type DeleteTunnelOptions

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

type GetConnectionOptions

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

type GetOptions

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

type GetRelayOptions

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

type GetTunnelOptions

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

type GlobalCLIOptions

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

type GlobalManageOptions

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

type HTTPDestination

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

type InferSchemaOptions

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

type InferSchemaOptions_Type

+ func (InferSchemaOptions_Type) Descriptor() protoreflect.EnumDescriptor

+ func (InferSchemaOptions_Type) Type() protoreflect.EnumType

+ func (x InferSchemaOptions_Type) Enum() *InferSchemaOptions_Type

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

type ManageOptions

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

type ReadCLIOptions

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

type ReadFilterOptions

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

type ReadGroupAWSKinesisOptions

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

type ReadGroupAWSSQSOptions

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

type ReadGroupActiveMQOptions

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

type ReadGroupAzureEventHubOptions

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

type ReadGroupAzureServiceBusOptions

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

type ReadGroupGCPPubSubOptions

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

type ReadGroupKafkaOptions

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

type ReadGroupKubeMQQueueOptions

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

type ReadGroupMQTTOptions

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

type ReadGroupMemphisOptions

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

type ReadGroupMongoOptions

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

type ReadGroupNSQOptions

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

type ReadGroupNatsJetstreamOptions

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

type ReadGroupNatsOptions

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

type ReadGroupNatsStreamingOptions

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

type ReadGroupPostgresOptions

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

type ReadGroupPulsarOptions

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

type ReadGroupRabbitOptions

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

type ReadGroupRabbitStreamsOptions

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

type ReadGroupRedisPubSubOptions

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

type ReadGroupRedisStreamsOptions

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

type ReadOptions

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

type ReadSampleOptions

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

type RelayCLIOptions

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

type RelayGroupAWSSQSOptions

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

type RelayGroupAzureServiceBusOptions

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

type RelayGroupGCPPubSubOptions

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

type RelayGroupKafkaOptions

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

type RelayGroupKubeMQQueueOptions

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

type RelayGroupMQTTOptions

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

type RelayGroupMongoOptions

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

type RelayGroupNSQOptions

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

type RelayGroupNatsJetStreamOptions

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

type RelayGroupNatsOptions

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

type RelayGroupNatsStreamingOptions

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

type RelayGroupPostgresOptions

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

type RelayGroupRabbitOptions

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

type RelayGroupRedisPubSubOptions

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

type RelayGroupRedisStreamsOptions

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

type RelayOptions

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

type ResumeOptions

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

type ResumeRelayOptions

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

type ResumeTunnelOptions

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

type ServerOptions

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

type StopOptions

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

type StopRelayOptions

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

type StopTunnelOptions

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

type StreamdalArchiveOptions

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

type StreamdalArchiveReplayOptions

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

type StreamdalCreateCollectionOptions

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

type StreamdalCreateDestinationOptions

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

type StreamdalCreateOptions

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

type StreamdalCreateReplayOptions

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

type StreamdalListCollectionOptions

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

type StreamdalListDestinationOptions

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

type StreamdalListOptions

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

type StreamdalListReplayOptions

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

type StreamdalListSchemaOptions

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

type StreamdalLoginOptions

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

type StreamdalLogoutOptions

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

type StreamdalOptions

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

type StreamdalOutputType

+ func (StreamdalOutputType) Descriptor() protoreflect.EnumDescriptor

+ func (StreamdalOutputType) Type() protoreflect.EnumType

+ func (x StreamdalOutputType) Enum() *StreamdalOutputType

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

type StreamdalReplayType

+ func (StreamdalReplayType) Descriptor() protoreflect.EnumDescriptor

+ func (StreamdalReplayType) Type() protoreflect.EnumType

+ func (x StreamdalReplayType) Enum() *StreamdalReplayType

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

type StreamdalSearchOptions

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

type TunnelGroupAWSKinesisOptions

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

type TunnelGroupAWSSNSOptions

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

type TunnelGroupAWSSQSOptions

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

type TunnelGroupActiveMQOptions

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

type TunnelGroupAzureEventHubOptions

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

type TunnelGroupAzureServiceBusOptions

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

type TunnelGroupGCPPubSubOptions

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

type TunnelGroupKafkaOptions

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

type TunnelGroupKubeMQQueueOptions

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

type TunnelGroupMQTTOptions

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

type TunnelGroupMemphisOptions

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

type TunnelGroupNSQOptions

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

type TunnelGroupNatsJetstreamOptions

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

type TunnelGroupNatsOptions

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

type TunnelGroupNatsStreamingOptions

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

type TunnelGroupPulsarOptions

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

type TunnelGroupRabbitOptions

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

type TunnelGroupRabbitStreamsOptions

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

type TunnelGroupRedisPubSubOptions

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

type TunnelGroupRedisStreamsOptions

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

type TunnelOptions

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

type WriteCLIOptions

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

type WriteGroupAWSKinesisOptions

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

type WriteGroupAWSSNSOptions

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

type WriteGroupAWSSQSOptions

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

type WriteGroupActiveMQOptions

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

type WriteGroupAzureEventHubOptions

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

type WriteGroupAzureServiceBusOptions

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

type WriteGroupGCPPubSubOptions

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

type WriteGroupKafkaOptions

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

type WriteGroupKubeMQQueueOptions

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

type WriteGroupMQTTOptions

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

type WriteGroupMemphisOptions

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

type WriteGroupNSQOptions

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

type WriteGroupNatsJetstreamOptions

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

type WriteGroupNatsOptions

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

type WriteGroupNatsStreamingOptions

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

type WriteGroupPulsarOptions

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

type WriteGroupRabbitOptions

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

type WriteGroupRabbitStreamsOptions

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

type WriteGroupRedisPubSubOptions

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

type WriteGroupRedisStreamsOptions

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

type WriteOptions

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

Feb 15, 2023

Changes in this version

type ConnectionOptions

+ func (m *ConnectionOptions) GetMemphis() *args.MemphisConn

+ type ConnectionOptions_Memphis struct

+ Memphis *args.MemphisConn

type CreateTunnelOptions

+ Memphis *args.MemphisWriteArgs

+ func (m *CreateTunnelOptions) GetMemphis() *args.MemphisWriteArgs

+ type ReadGroupMemphisOptions struct

+ Args *args.MemphisReadArgs

+ XConn *args.MemphisConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupMemphisOptions) ProtoMessage()

+ func (m *ReadGroupMemphisOptions) GetArgs() *args.MemphisReadArgs

+ func (m *ReadGroupMemphisOptions) GetXConn() *args.MemphisConn

+ func (m *ReadGroupMemphisOptions) Reset()

+ func (m *ReadGroupMemphisOptions) String() string

+ func (m *ReadGroupMemphisOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupMemphisOptions) XXX_Size() int

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

type ReadOptions

+ Memphis *ReadGroupMemphisOptions

+ func (m *ReadOptions) GetMemphis() *ReadGroupMemphisOptions

+ type TunnelGroupMemphisOptions struct

+ Args *args.MemphisWriteArgs

+ XConn *args.MemphisConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupMemphisOptions) ProtoMessage()

+ func (m *TunnelGroupMemphisOptions) GetArgs() *args.MemphisWriteArgs

+ func (m *TunnelGroupMemphisOptions) GetXConn() *args.MemphisConn

+ func (m *TunnelGroupMemphisOptions) Reset()

+ func (m *TunnelGroupMemphisOptions) String() string

+ func (m *TunnelGroupMemphisOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupMemphisOptions) XXX_Size() int

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

type TunnelOptions

+ Memphis *TunnelGroupMemphisOptions

+ func (m *TunnelOptions) GetMemphis() *TunnelGroupMemphisOptions

+ type WriteGroupMemphisOptions struct

+ Args *args.MemphisWriteArgs

+ XConn *args.MemphisConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WriteGroupMemphisOptions) ProtoMessage()

+ func (m *WriteGroupMemphisOptions) GetArgs() *args.MemphisWriteArgs

+ func (m *WriteGroupMemphisOptions) GetXConn() *args.MemphisConn

+ func (m *WriteGroupMemphisOptions) Reset()

+ func (m *WriteGroupMemphisOptions) String() string

+ func (m *WriteGroupMemphisOptions) XXX_DiscardUnknown()

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

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

+ func (m *WriteGroupMemphisOptions) XXX_Size() int

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

type WriteOptions

+ Memphis *WriteGroupMemphisOptions

+ func (m *WriteOptions) GetMemphis() *WriteGroupMemphisOptions

Feb 6, 2023

Changes in this version

+ var StreamdalOutputType_name = map[int32]string

+ var StreamdalOutputType_value = map[string]int32

+ var StreamdalReplayType_name = map[int32]string

+ var StreamdalReplayType_value = map[string]int32

type CLIOptions

+ Streamdal *StreamdalOptions

+ func (m *CLIOptions) GetStreamdal() *StreamdalOptions

type CreateRelayOptions

+ StreamdalGrpcAddress string

+ StreamdalGrpcDisableTls bool

+ StreamdalGrpcTimeoutSeconds int32

+ func (m *CreateRelayOptions) GetStreamdalGrpcAddress() string

+ func (m *CreateRelayOptions) GetStreamdalGrpcDisableTls() bool

+ func (m *CreateRelayOptions) GetStreamdalGrpcTimeoutSeconds() int32

type RelayOptions

+ XStreamdalGrpcAddress string

+ XStreamdalGrpcDisableTls bool

+ XStreamdalGrpcTimeoutSeconds int32

+ func (m *RelayOptions) GetXStreamdalGrpcAddress() string

+ func (m *RelayOptions) GetXStreamdalGrpcDisableTls() bool

+ func (m *RelayOptions) GetXStreamdalGrpcTimeoutSeconds() int32

+ type StreamdalArchiveOptions struct

+ Replay *StreamdalArchiveReplayOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalArchiveOptions) ProtoMessage()

+ func (m *StreamdalArchiveOptions) GetReplay() *StreamdalArchiveReplayOptions

+ func (m *StreamdalArchiveOptions) Reset()

+ func (m *StreamdalArchiveOptions) String() string

+ func (m *StreamdalArchiveOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalArchiveOptions) XXX_Size() int

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

+ type StreamdalArchiveReplayOptions struct

+ ReplayId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalArchiveReplayOptions) ProtoMessage()

+ func (m *StreamdalArchiveReplayOptions) GetReplayId() string

+ func (m *StreamdalArchiveReplayOptions) Reset()

+ func (m *StreamdalArchiveReplayOptions) String() string

+ func (m *StreamdalArchiveReplayOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalArchiveReplayOptions) XXX_Size() int

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

+ type StreamdalCreateCollectionOptions struct

+ EnvelopeRootMessage string

+ EnvelopeType string

+ Name string

+ Notes string

+ PayloadFieldId string

+ PayloadFieldMessage string

+ SchemaId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalCreateCollectionOptions) ProtoMessage()

+ func (m *StreamdalCreateCollectionOptions) GetEnvelopeRootMessage() string

+ func (m *StreamdalCreateCollectionOptions) GetEnvelopeType() string

+ func (m *StreamdalCreateCollectionOptions) GetName() string

+ func (m *StreamdalCreateCollectionOptions) GetNotes() string

+ func (m *StreamdalCreateCollectionOptions) GetPayloadFieldId() string

+ func (m *StreamdalCreateCollectionOptions) GetPayloadFieldMessage() string

+ func (m *StreamdalCreateCollectionOptions) GetSchemaId() string

+ func (m *StreamdalCreateCollectionOptions) Reset()

+ func (m *StreamdalCreateCollectionOptions) String() string

+ func (m *StreamdalCreateCollectionOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalCreateCollectionOptions) XXX_Size() int

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

+ type StreamdalCreateDestinationOptions struct

+ AwsSqs *WriteGroupAWSSQSOptions

+ Http *HTTPDestination

+ Kafka *WriteGroupKafkaOptions

+ KubemqQueue *WriteGroupKubeMQQueueOptions

+ Name string

+ Notes string

+ Rabbit *WriteGroupRabbitOptions

+ XApiDestinationType string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalCreateDestinationOptions) ProtoMessage()

+ func (m *StreamdalCreateDestinationOptions) GetAwsSqs() *WriteGroupAWSSQSOptions

+ func (m *StreamdalCreateDestinationOptions) GetHttp() *HTTPDestination

+ func (m *StreamdalCreateDestinationOptions) GetKafka() *WriteGroupKafkaOptions

+ func (m *StreamdalCreateDestinationOptions) GetKubemqQueue() *WriteGroupKubeMQQueueOptions

+ func (m *StreamdalCreateDestinationOptions) GetName() string

+ func (m *StreamdalCreateDestinationOptions) GetNotes() string

+ func (m *StreamdalCreateDestinationOptions) GetRabbit() *WriteGroupRabbitOptions

+ func (m *StreamdalCreateDestinationOptions) GetXApiDestinationType() string

+ func (m *StreamdalCreateDestinationOptions) Reset()

+ func (m *StreamdalCreateDestinationOptions) String() string

+ func (m *StreamdalCreateDestinationOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalCreateDestinationOptions) XXX_Size() int

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

+ type StreamdalCreateOptions struct

+ Collection *StreamdalCreateCollectionOptions

+ Destination *StreamdalCreateDestinationOptions

+ Replay *StreamdalCreateReplayOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalCreateOptions) ProtoMessage()

+ func (m *StreamdalCreateOptions) GetCollection() *StreamdalCreateCollectionOptions

+ func (m *StreamdalCreateOptions) GetDestination() *StreamdalCreateDestinationOptions

+ func (m *StreamdalCreateOptions) GetReplay() *StreamdalCreateReplayOptions

+ func (m *StreamdalCreateOptions) Reset()

+ func (m *StreamdalCreateOptions) String() string

+ func (m *StreamdalCreateOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalCreateOptions) XXX_Size() int

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

+ type StreamdalCreateReplayOptions struct

+ CollectionId string

+ DestinationId string

+ FromTimestamp string

+ Name string

+ Notes string

+ Query string

+ ToTimestamp string

+ Type StreamdalReplayType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalCreateReplayOptions) ProtoMessage()

+ func (m *StreamdalCreateReplayOptions) GetCollectionId() string

+ func (m *StreamdalCreateReplayOptions) GetDestinationId() string

+ func (m *StreamdalCreateReplayOptions) GetFromTimestamp() string

+ func (m *StreamdalCreateReplayOptions) GetName() string

+ func (m *StreamdalCreateReplayOptions) GetNotes() string

+ func (m *StreamdalCreateReplayOptions) GetQuery() string

+ func (m *StreamdalCreateReplayOptions) GetToTimestamp() string

+ func (m *StreamdalCreateReplayOptions) GetType() StreamdalReplayType

+ func (m *StreamdalCreateReplayOptions) Reset()

+ func (m *StreamdalCreateReplayOptions) String() string

+ func (m *StreamdalCreateReplayOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalCreateReplayOptions) XXX_Size() int

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

+ type StreamdalListCollectionOptions struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalListCollectionOptions) ProtoMessage()

+ func (m *StreamdalListCollectionOptions) Reset()

+ func (m *StreamdalListCollectionOptions) String() string

+ func (m *StreamdalListCollectionOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalListCollectionOptions) XXX_Size() int

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

+ type StreamdalListDestinationOptions struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalListDestinationOptions) ProtoMessage()

+ func (m *StreamdalListDestinationOptions) Reset()

+ func (m *StreamdalListDestinationOptions) String() string

+ func (m *StreamdalListDestinationOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalListDestinationOptions) XXX_Size() int

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

+ type StreamdalListOptions struct

+ Collection *StreamdalListCollectionOptions

+ Destination *StreamdalListDestinationOptions

+ Replay *StreamdalListReplayOptions

+ Schema *StreamdalListSchemaOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalListOptions) ProtoMessage()

+ func (m *StreamdalListOptions) GetCollection() *StreamdalListCollectionOptions

+ func (m *StreamdalListOptions) GetDestination() *StreamdalListDestinationOptions

+ func (m *StreamdalListOptions) GetReplay() *StreamdalListReplayOptions

+ func (m *StreamdalListOptions) GetSchema() *StreamdalListSchemaOptions

+ func (m *StreamdalListOptions) Reset()

+ func (m *StreamdalListOptions) String() string

+ func (m *StreamdalListOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalListOptions) XXX_Size() int

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

+ type StreamdalListReplayOptions struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalListReplayOptions) ProtoMessage()

+ func (m *StreamdalListReplayOptions) Reset()

+ func (m *StreamdalListReplayOptions) String() string

+ func (m *StreamdalListReplayOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalListReplayOptions) XXX_Size() int

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

+ type StreamdalListSchemaOptions struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalListSchemaOptions) ProtoMessage()

+ func (m *StreamdalListSchemaOptions) Reset()

+ func (m *StreamdalListSchemaOptions) String() string

+ func (m *StreamdalListSchemaOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalListSchemaOptions) XXX_Size() int

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

+ type StreamdalLoginOptions struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalLoginOptions) ProtoMessage()

+ func (m *StreamdalLoginOptions) Reset()

+ func (m *StreamdalLoginOptions) String() string

+ func (m *StreamdalLoginOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalLoginOptions) XXX_Size() int

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

+ type StreamdalLogoutOptions struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalLogoutOptions) ProtoMessage()

+ func (m *StreamdalLogoutOptions) Reset()

+ func (m *StreamdalLogoutOptions) String() string

+ func (m *StreamdalLogoutOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalLogoutOptions) XXX_Size() int

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

+ type StreamdalOptions struct

+ ApiUrl string

+ Archive *StreamdalArchiveOptions

+ Create *StreamdalCreateOptions

+ List *StreamdalListOptions

+ Login *StreamdalLoginOptions

+ Logout *StreamdalLogoutOptions

+ OutputType StreamdalOutputType

+ Search *StreamdalSearchOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalOptions) ProtoMessage()

+ func (m *StreamdalOptions) GetApiUrl() string

+ func (m *StreamdalOptions) GetArchive() *StreamdalArchiveOptions

+ func (m *StreamdalOptions) GetCreate() *StreamdalCreateOptions

+ func (m *StreamdalOptions) GetList() *StreamdalListOptions

+ func (m *StreamdalOptions) GetLogin() *StreamdalLoginOptions

+ func (m *StreamdalOptions) GetLogout() *StreamdalLogoutOptions

+ func (m *StreamdalOptions) GetOutputType() StreamdalOutputType

+ func (m *StreamdalOptions) GetSearch() *StreamdalSearchOptions

+ func (m *StreamdalOptions) Reset()

+ func (m *StreamdalOptions) String() string

+ func (m *StreamdalOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalOptions) XXX_Size() int

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

+ type StreamdalOutputType int32

+ const StreamdalOutputType_JSON

+ const StreamdalOutputType_TABLE

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

+ func (x StreamdalOutputType) String() string

+ type StreamdalReplayType int32

+ const StreamdalReplayType_CONTINUOUS

+ const StreamdalReplayType_SINGLE

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

+ func (x StreamdalReplayType) String() string

+ type StreamdalSearchOptions struct

+ CollectionId string

+ Page int32

+ Query string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamdalSearchOptions) ProtoMessage()

+ func (m *StreamdalSearchOptions) GetCollectionId() string

+ func (m *StreamdalSearchOptions) GetPage() int32

+ func (m *StreamdalSearchOptions) GetQuery() string

+ func (m *StreamdalSearchOptions) Reset()

+ func (m *StreamdalSearchOptions) String() string

+ func (m *StreamdalSearchOptions) XXX_DiscardUnknown()

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

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

+ func (m *StreamdalSearchOptions) XXX_Size() int

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

Jan 20, 2023

Changes in this version

type CreateRelayOptions

+ DeadLetter bool

+ func (m *CreateRelayOptions) GetDeadLetter() bool

type RelayOptions

+ DeadLetter bool

+ func (m *RelayOptions) GetDeadLetter() bool

Oct 27, 2022

Changes in this version

type BatchCreateCollectionOptions

+ EnvelopeRootMessage string

+ EnvelopeType string

+ PayloadFieldId string

+ PayloadFieldMessage string

+ func (m *BatchCreateCollectionOptions) GetEnvelopeRootMessage() string

+ func (m *BatchCreateCollectionOptions) GetEnvelopeType() string

+ func (m *BatchCreateCollectionOptions) GetPayloadFieldId() string

+ func (m *BatchCreateCollectionOptions) GetPayloadFieldMessage() string

Mar 8, 2022

Changes in this version

type ServerOptions

+ RemoteControlAddress string

+ RemoteControlApiToken string

+ RemoteControlDisableTls bool

+ RemoteControlEnabled bool

+ func (m *ServerOptions) GetRemoteControlAddress() string

+ func (m *ServerOptions) GetRemoteControlApiToken() string

+ func (m *ServerOptions) GetRemoteControlDisableTls() bool

+ func (m *ServerOptions) GetRemoteControlEnabled() bool

Feb 23, 2022

Changes in this version

+ func MergeTunnelOptions(backend string, tunnelOpts *TunnelOptions, ...) error

Feb 23, 2022

Changes in this version

type CreateTunnelOptions

+ TunnelToken string

+ func (m *CreateTunnelOptions) GetTunnelToken() string

Feb 23, 2022

Changes in this version

type CreateRelayOptions

+ BatchshGrpcAddress string

+ BatchshGrpcDisableTls bool

+ BatchshGrpcTimeoutSeconds int32

+ func (m *CreateRelayOptions) GetBatchshGrpcAddress() string

+ func (m *CreateRelayOptions) GetBatchshGrpcDisableTls() bool

+ func (m *CreateRelayOptions) GetBatchshGrpcTimeoutSeconds() int32

Feb 23, 2022

Changes in this version

+ func MergeRelayOptions(backend string, relayOpts *RelayOptions, createRelayOpts *CreateRelayOptions) error

Feb 23, 2022

Changes in this version

type GlobalManageOptions

+ DisablePretty bool

+ func (m *GlobalManageOptions) GetDisablePretty() bool

Feb 22, 2022

Changes in this version

type GlobalCLIOptions

+ XCommands []string

+ func (m *GlobalCLIOptions) GetXCommands() []string

type GlobalManageOptions

+ ManageAddress string

+ ManageInsecureTls bool

+ ManagePretty bool

+ ManageTimeoutSeconds int64

+ ManageTlsCaFile string

+ ManageTlsCertFile string

+ ManageTlsKeyFile string

+ ManageToken string

+ ManageUseTls bool

+ func (m *GlobalManageOptions) GetManageAddress() string

+ func (m *GlobalManageOptions) GetManageInsecureTls() bool

+ func (m *GlobalManageOptions) GetManagePretty() bool

+ func (m *GlobalManageOptions) GetManageTimeoutSeconds() int64

+ func (m *GlobalManageOptions) GetManageTlsCaFile() string

+ func (m *GlobalManageOptions) GetManageTlsCertFile() string

+ func (m *GlobalManageOptions) GetManageTlsKeyFile() string

+ func (m *GlobalManageOptions) GetManageToken() string

+ func (m *GlobalManageOptions) GetManageUseTls() bool

Feb 21, 2022

Changes in this version

type GlobalManageOptions

+ ServerAddress string

+ ServerInsecureTls bool

+ ServerToken string

+ ServerUseTls bool

+ func (m *GlobalManageOptions) GetServerAddress() string

+ func (m *GlobalManageOptions) GetServerInsecureTls() bool

+ func (m *GlobalManageOptions) GetServerToken() string

+ func (m *GlobalManageOptions) GetServerUseTls() bool

Feb 21, 2022

Changes in this version

type CLIOptions

+ Manage *ManageOptions

+ func (m *CLIOptions) GetManage() *ManageOptions

+ type CreateConnectionOptions struct

+ ActiveMq *args.ActiveMQConn

+ AwsKinesis *args.AWSKinesisConn

+ AwsSns *args.AWSSNSConn

+ AwsSqs *args.AWSSQSConn

+ AzureEventHub *args.AzureEventHubConn

+ AzureServiceBus *args.AzureServiceBusConn

+ GcpPubsub *args.GCPPubSubConn

+ Kafka *args.KafkaConn

+ KubemqQueue *args.KubeMQQueueConn

+ Mongo *args.MongoConn

+ Mqtt *args.MQTTConn

+ Name string

+ Nats *args.NatsConn

+ NatsJetstream *args.NatsJetstreamConn

+ NatsStreaming *args.NatsStreamingConn

+ Notes string

+ Nsq *args.NSQConn

+ Postgres *args.PostgresConn

+ Pulsar *args.PulsarConn

+ Rabbit *args.RabbitConn

+ RabbitStreams *args.RabbitStreamsConn

+ RedisPubsub *args.RedisPubSubConn

+ RedisStreams *args.RedisStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateConnectionOptions) ProtoMessage()

+ func (m *CreateConnectionOptions) GetActiveMq() *args.ActiveMQConn

+ func (m *CreateConnectionOptions) GetAwsKinesis() *args.AWSKinesisConn

+ func (m *CreateConnectionOptions) GetAwsSns() *args.AWSSNSConn

+ func (m *CreateConnectionOptions) GetAwsSqs() *args.AWSSQSConn

+ func (m *CreateConnectionOptions) GetAzureEventHub() *args.AzureEventHubConn

+ func (m *CreateConnectionOptions) GetAzureServiceBus() *args.AzureServiceBusConn

+ func (m *CreateConnectionOptions) GetGcpPubsub() *args.GCPPubSubConn

+ func (m *CreateConnectionOptions) GetKafka() *args.KafkaConn

+ func (m *CreateConnectionOptions) GetKubemqQueue() *args.KubeMQQueueConn

+ func (m *CreateConnectionOptions) GetMongo() *args.MongoConn

+ func (m *CreateConnectionOptions) GetMqtt() *args.MQTTConn

+ func (m *CreateConnectionOptions) GetName() string

+ func (m *CreateConnectionOptions) GetNats() *args.NatsConn

+ func (m *CreateConnectionOptions) GetNatsJetstream() *args.NatsJetstreamConn

+ func (m *CreateConnectionOptions) GetNatsStreaming() *args.NatsStreamingConn

+ func (m *CreateConnectionOptions) GetNotes() string

+ func (m *CreateConnectionOptions) GetNsq() *args.NSQConn

+ func (m *CreateConnectionOptions) GetPostgres() *args.PostgresConn

+ func (m *CreateConnectionOptions) GetPulsar() *args.PulsarConn

+ func (m *CreateConnectionOptions) GetRabbit() *args.RabbitConn

+ func (m *CreateConnectionOptions) GetRabbitStreams() *args.RabbitStreamsConn

+ func (m *CreateConnectionOptions) GetRedisPubsub() *args.RedisPubSubConn

+ func (m *CreateConnectionOptions) GetRedisStreams() *args.RedisStreamsConn

+ func (m *CreateConnectionOptions) Reset()

+ func (m *CreateConnectionOptions) String() string

+ func (m *CreateConnectionOptions) XXX_DiscardUnknown()

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

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

+ func (m *CreateConnectionOptions) XXX_Size() int

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

+ type CreateOptions struct

+ Connection *CreateConnectionOptions

+ Relay *CreateRelayOptions

+ Tunnel *CreateTunnelOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateOptions) ProtoMessage()

+ func (m *CreateOptions) GetConnection() *CreateConnectionOptions

+ func (m *CreateOptions) GetRelay() *CreateRelayOptions

+ func (m *CreateOptions) GetTunnel() *CreateTunnelOptions

+ func (m *CreateOptions) Reset()

+ func (m *CreateOptions) String() string

+ func (m *CreateOptions) XXX_DiscardUnknown()

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

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

+ func (m *CreateOptions) XXX_Size() int

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

+ type CreateRelayOptions struct

+ AwsSqs *args.AWSSQSRelayArgs

+ AzureServiceBus *args.AzureServiceBusReadArgs

+ BatchMaxRetry int32

+ BatchSize int32

+ CollectionToken string

+ ConnectionId string

+ GcpPubsub *args.GCPPubSubReadArgs

+ Kafka *args.KafkaRelayArgs

+ KubemqQueue *args.KubeMQQueueReadArgs

+ Mongo *args.MongoReadArgs

+ Mqtt *args.MQTTReadArgs

+ Nats *args.NatsReadArgs

+ NatsJetstream *args.NatsJetstreamReadArgs

+ NatsStreaming *args.NatsStreamingReadArgs

+ Nsq *args.NSQReadArgs

+ NumWorkers int32

+ Postgres *args.PostgresReadArgs

+ Rabbit *args.RabbitReadArgs

+ RedisPubsub *args.RedisPubSubReadArgs

+ RedisStreams *args.RedisStreamsReadArgs

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateRelayOptions) ProtoMessage()

+ func (m *CreateRelayOptions) GetAwsSqs() *args.AWSSQSRelayArgs

+ func (m *CreateRelayOptions) GetAzureServiceBus() *args.AzureServiceBusReadArgs

+ func (m *CreateRelayOptions) GetBatchMaxRetry() int32

+ func (m *CreateRelayOptions) GetBatchSize() int32

+ func (m *CreateRelayOptions) GetCollectionToken() string

+ func (m *CreateRelayOptions) GetConnectionId() string

+ func (m *CreateRelayOptions) GetGcpPubsub() *args.GCPPubSubReadArgs

+ func (m *CreateRelayOptions) GetKafka() *args.KafkaRelayArgs

+ func (m *CreateRelayOptions) GetKubemqQueue() *args.KubeMQQueueReadArgs

+ func (m *CreateRelayOptions) GetMongo() *args.MongoReadArgs

+ func (m *CreateRelayOptions) GetMqtt() *args.MQTTReadArgs

+ func (m *CreateRelayOptions) GetNats() *args.NatsReadArgs

+ func (m *CreateRelayOptions) GetNatsJetstream() *args.NatsJetstreamReadArgs

+ func (m *CreateRelayOptions) GetNatsStreaming() *args.NatsStreamingReadArgs

+ func (m *CreateRelayOptions) GetNsq() *args.NSQReadArgs

+ func (m *CreateRelayOptions) GetNumWorkers() int32

+ func (m *CreateRelayOptions) GetPostgres() *args.PostgresReadArgs

+ func (m *CreateRelayOptions) GetRabbit() *args.RabbitReadArgs

+ func (m *CreateRelayOptions) GetRedisPubsub() *args.RedisPubSubReadArgs

+ func (m *CreateRelayOptions) GetRedisStreams() *args.RedisStreamsReadArgs

+ func (m *CreateRelayOptions) Reset()

+ func (m *CreateRelayOptions) String() string

+ func (m *CreateRelayOptions) XXX_DiscardUnknown()

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

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

+ func (m *CreateRelayOptions) XXX_Size() int

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

+ type CreateTunnelOptions struct

+ Activemq *args.ActiveMQWriteArgs

+ AwsKinesis *args.AWSKinesisWriteArgs

+ AwsSns *args.AWSSNSWriteArgs

+ AwsSqs *args.AWSSQSWriteArgs

+ AzureEventHub *args.AzureEventHubWriteArgs

+ AzureServiceBus *args.AzureServiceBusWriteArgs

+ ConnectionId string

+ GcpPubsub *args.GCPPubSubWriteArgs

+ Kafka *args.KafkaWriteArgs

+ KubemqQueue *args.KubeMQQueueWriteArgs

+ Mqtt *args.MQTTWriteArgs

+ Name string

+ Nats *args.NatsWriteArgs

+ NatsJetstream *args.NatsJetstreamWriteArgs

+ NatsStreaming *args.NatsStreamingWriteArgs

+ Notes string

+ Nsq *args.NSQWriteArgs

+ Pulsar *args.PulsarWriteArgs

+ Rabbit *args.RabbitWriteArgs

+ RabbitStreams *args.RabbitStreamsWriteArgs

+ RedisPubsub *args.RedisPubSubWriteArgs

+ RedisStreams *args.RedisStreamsWriteArgs

+ XTunnelAddress string

+ XTunnelInsecure bool

+ XTunnelTimeoutSeconds uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateTunnelOptions) ProtoMessage()

+ func (m *CreateTunnelOptions) GetActivemq() *args.ActiveMQWriteArgs

+ func (m *CreateTunnelOptions) GetAwsKinesis() *args.AWSKinesisWriteArgs

+ func (m *CreateTunnelOptions) GetAwsSns() *args.AWSSNSWriteArgs

+ func (m *CreateTunnelOptions) GetAwsSqs() *args.AWSSQSWriteArgs

+ func (m *CreateTunnelOptions) GetAzureEventHub() *args.AzureEventHubWriteArgs

+ func (m *CreateTunnelOptions) GetAzureServiceBus() *args.AzureServiceBusWriteArgs

+ func (m *CreateTunnelOptions) GetConnectionId() string

+ func (m *CreateTunnelOptions) GetGcpPubsub() *args.GCPPubSubWriteArgs

+ func (m *CreateTunnelOptions) GetKafka() *args.KafkaWriteArgs

+ func (m *CreateTunnelOptions) GetKubemqQueue() *args.KubeMQQueueWriteArgs

+ func (m *CreateTunnelOptions) GetMqtt() *args.MQTTWriteArgs

+ func (m *CreateTunnelOptions) GetName() string

+ func (m *CreateTunnelOptions) GetNats() *args.NatsWriteArgs

+ func (m *CreateTunnelOptions) GetNatsJetstream() *args.NatsJetstreamWriteArgs

+ func (m *CreateTunnelOptions) GetNatsStreaming() *args.NatsStreamingWriteArgs

+ func (m *CreateTunnelOptions) GetNotes() string

+ func (m *CreateTunnelOptions) GetNsq() *args.NSQWriteArgs

+ func (m *CreateTunnelOptions) GetPulsar() *args.PulsarWriteArgs

+ func (m *CreateTunnelOptions) GetRabbit() *args.RabbitWriteArgs

+ func (m *CreateTunnelOptions) GetRabbitStreams() *args.RabbitStreamsWriteArgs

+ func (m *CreateTunnelOptions) GetRedisPubsub() *args.RedisPubSubWriteArgs

+ func (m *CreateTunnelOptions) GetRedisStreams() *args.RedisStreamsWriteArgs

+ func (m *CreateTunnelOptions) GetXTunnelAddress() string

+ func (m *CreateTunnelOptions) GetXTunnelInsecure() bool

+ func (m *CreateTunnelOptions) GetXTunnelTimeoutSeconds() uint32

+ func (m *CreateTunnelOptions) Reset()

+ func (m *CreateTunnelOptions) String() string

+ func (m *CreateTunnelOptions) XXX_DiscardUnknown()

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

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

+ func (m *CreateTunnelOptions) XXX_Size() int

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

+ type DeleteConnectionOptions struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteConnectionOptions) ProtoMessage()

+ func (m *DeleteConnectionOptions) GetId() string

+ func (m *DeleteConnectionOptions) Reset()

+ func (m *DeleteConnectionOptions) String() string

+ func (m *DeleteConnectionOptions) XXX_DiscardUnknown()

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

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

+ func (m *DeleteConnectionOptions) XXX_Size() int

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

+ type DeleteOptions struct

+ Connection *DeleteConnectionOptions

+ Relay *DeleteRelayOptions

+ Tunnel *DeleteTunnelOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteOptions) ProtoMessage()

+ func (m *DeleteOptions) GetConnection() *DeleteConnectionOptions

+ func (m *DeleteOptions) GetRelay() *DeleteRelayOptions

+ func (m *DeleteOptions) GetTunnel() *DeleteTunnelOptions

+ func (m *DeleteOptions) Reset()

+ func (m *DeleteOptions) String() string

+ func (m *DeleteOptions) XXX_DiscardUnknown()

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

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

+ func (m *DeleteOptions) XXX_Size() int

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

+ type DeleteRelayOptions struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteRelayOptions) ProtoMessage()

+ func (m *DeleteRelayOptions) GetId() string

+ func (m *DeleteRelayOptions) Reset()

+ func (m *DeleteRelayOptions) String() string

+ func (m *DeleteRelayOptions) XXX_DiscardUnknown()

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

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

+ func (m *DeleteRelayOptions) XXX_Size() int

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

+ type DeleteTunnelOptions struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteTunnelOptions) ProtoMessage()

+ func (m *DeleteTunnelOptions) GetId() string

+ func (m *DeleteTunnelOptions) Reset()

+ func (m *DeleteTunnelOptions) String() string

+ func (m *DeleteTunnelOptions) XXX_DiscardUnknown()

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

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

+ func (m *DeleteTunnelOptions) XXX_Size() int

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

+ type GetConnectionOptions struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetConnectionOptions) ProtoMessage()

+ func (m *GetConnectionOptions) GetId() string

+ func (m *GetConnectionOptions) Reset()

+ func (m *GetConnectionOptions) String() string

+ func (m *GetConnectionOptions) XXX_DiscardUnknown()

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

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

+ func (m *GetConnectionOptions) XXX_Size() int

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

+ type GetOptions struct

+ Connection *GetConnectionOptions

+ Relay *GetRelayOptions

+ Tunnel *GetTunnelOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetOptions) ProtoMessage()

+ func (m *GetOptions) GetConnection() *GetConnectionOptions

+ func (m *GetOptions) GetRelay() *GetRelayOptions

+ func (m *GetOptions) GetTunnel() *GetTunnelOptions

+ func (m *GetOptions) Reset()

+ func (m *GetOptions) String() string

+ func (m *GetOptions) XXX_DiscardUnknown()

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

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

+ func (m *GetOptions) XXX_Size() int

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

+ type GetRelayOptions struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetRelayOptions) ProtoMessage()

+ func (m *GetRelayOptions) GetId() string

+ func (m *GetRelayOptions) Reset()

+ func (m *GetRelayOptions) String() string

+ func (m *GetRelayOptions) XXX_DiscardUnknown()

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

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

+ func (m *GetRelayOptions) XXX_Size() int

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

+ type GetTunnelOptions struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetTunnelOptions) ProtoMessage()

+ func (m *GetTunnelOptions) GetId() string

+ func (m *GetTunnelOptions) Reset()

+ func (m *GetTunnelOptions) String() string

+ func (m *GetTunnelOptions) XXX_DiscardUnknown()

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

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

+ func (m *GetTunnelOptions) XXX_Size() int

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

+ type GlobalManageOptions struct

+ Address string

+ Auth string

+ TlsSkipVerify bool

+ UseTls bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GlobalManageOptions) ProtoMessage()

+ func (m *GlobalManageOptions) GetAddress() string

+ func (m *GlobalManageOptions) GetAuth() string

+ func (m *GlobalManageOptions) GetTlsSkipVerify() bool

+ func (m *GlobalManageOptions) GetUseTls() bool

+ func (m *GlobalManageOptions) Reset()

+ func (m *GlobalManageOptions) String() string

+ func (m *GlobalManageOptions) XXX_DiscardUnknown()

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

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

+ func (m *GlobalManageOptions) XXX_Size() int

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

+ type ManageOptions struct

+ Create *CreateOptions

+ Delete *DeleteOptions

+ Get *GetOptions

+ GlobalOptions *GlobalManageOptions

+ Resume *ResumeOptions

+ Stop *StopOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ManageOptions) ProtoMessage()

+ func (m *ManageOptions) GetCreate() *CreateOptions

+ func (m *ManageOptions) GetDelete() *DeleteOptions

+ func (m *ManageOptions) GetGet() *GetOptions

+ func (m *ManageOptions) GetGlobalOptions() *GlobalManageOptions

+ func (m *ManageOptions) GetResume() *ResumeOptions

+ func (m *ManageOptions) GetStop() *StopOptions

+ func (m *ManageOptions) Reset()

+ func (m *ManageOptions) String() string

+ func (m *ManageOptions) XXX_DiscardUnknown()

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

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

+ func (m *ManageOptions) XXX_Size() int

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

+ type ResumeOptions struct

+ Relay *ResumeRelayOptions

+ Tunnel *ResumeTunnelOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ResumeOptions) ProtoMessage()

+ func (m *ResumeOptions) GetRelay() *ResumeRelayOptions

+ func (m *ResumeOptions) GetTunnel() *ResumeTunnelOptions

+ func (m *ResumeOptions) Reset()

+ func (m *ResumeOptions) String() string

+ func (m *ResumeOptions) XXX_DiscardUnknown()

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

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

+ func (m *ResumeOptions) XXX_Size() int

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

+ type ResumeRelayOptions struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ResumeRelayOptions) ProtoMessage()

+ func (m *ResumeRelayOptions) GetId() string

+ func (m *ResumeRelayOptions) Reset()

+ func (m *ResumeRelayOptions) String() string

+ func (m *ResumeRelayOptions) XXX_DiscardUnknown()

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

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

+ func (m *ResumeRelayOptions) XXX_Size() int

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

+ type ResumeTunnelOptions struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ResumeTunnelOptions) ProtoMessage()

+ func (m *ResumeTunnelOptions) GetId() string

+ func (m *ResumeTunnelOptions) Reset()

+ func (m *ResumeTunnelOptions) String() string

+ func (m *ResumeTunnelOptions) XXX_DiscardUnknown()

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

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

+ func (m *ResumeTunnelOptions) XXX_Size() int

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

+ type StopOptions struct

+ Relay *StopRelayOptions

+ Tunnel *StopTunnelOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StopOptions) ProtoMessage()

+ func (m *StopOptions) GetRelay() *StopRelayOptions

+ func (m *StopOptions) GetTunnel() *StopTunnelOptions

+ func (m *StopOptions) Reset()

+ func (m *StopOptions) String() string

+ func (m *StopOptions) XXX_DiscardUnknown()

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

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

+ func (m *StopOptions) XXX_Size() int

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

+ type StopRelayOptions struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StopRelayOptions) ProtoMessage()

+ func (m *StopRelayOptions) GetId() string

+ func (m *StopRelayOptions) Reset()

+ func (m *StopRelayOptions) String() string

+ func (m *StopRelayOptions) XXX_DiscardUnknown()

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

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

+ func (m *StopRelayOptions) XXX_Size() int

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

+ type StopTunnelOptions struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StopTunnelOptions) ProtoMessage()

+ func (m *StopTunnelOptions) GetId() string

+ func (m *StopTunnelOptions) Reset()

+ func (m *StopTunnelOptions) String() string

+ func (m *StopTunnelOptions) XXX_DiscardUnknown()

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

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

+ func (m *StopTunnelOptions) XXX_Size() int

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

Feb 15, 2022

Changes in this version

type CLIOptions

+ Tunnel *TunnelOptions

+ func (m *CLIOptions) GetTunnel() *TunnelOptions

+ type TunnelGroupAWSKinesisOptions struct

+ Args *args.AWSKinesisWriteArgs

+ XConn *args.AWSKinesisConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupAWSKinesisOptions) ProtoMessage()

+ func (m *TunnelGroupAWSKinesisOptions) GetArgs() *args.AWSKinesisWriteArgs

+ func (m *TunnelGroupAWSKinesisOptions) GetXConn() *args.AWSKinesisConn

+ func (m *TunnelGroupAWSKinesisOptions) Reset()

+ func (m *TunnelGroupAWSKinesisOptions) String() string

+ func (m *TunnelGroupAWSKinesisOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupAWSKinesisOptions) XXX_Size() int

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

+ type TunnelGroupAWSSNSOptions struct

+ Args *args.AWSSNSWriteArgs

+ XConn *args.AWSSNSConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupAWSSNSOptions) ProtoMessage()

+ func (m *TunnelGroupAWSSNSOptions) GetArgs() *args.AWSSNSWriteArgs

+ func (m *TunnelGroupAWSSNSOptions) GetXConn() *args.AWSSNSConn

+ func (m *TunnelGroupAWSSNSOptions) Reset()

+ func (m *TunnelGroupAWSSNSOptions) String() string

+ func (m *TunnelGroupAWSSNSOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupAWSSNSOptions) XXX_Size() int

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

+ type TunnelGroupAWSSQSOptions struct

+ Args *args.AWSSQSWriteArgs

+ XConn *args.AWSSQSConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupAWSSQSOptions) ProtoMessage()

+ func (m *TunnelGroupAWSSQSOptions) GetArgs() *args.AWSSQSWriteArgs

+ func (m *TunnelGroupAWSSQSOptions) GetXConn() *args.AWSSQSConn

+ func (m *TunnelGroupAWSSQSOptions) Reset()

+ func (m *TunnelGroupAWSSQSOptions) String() string

+ func (m *TunnelGroupAWSSQSOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupAWSSQSOptions) XXX_Size() int

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

+ type TunnelGroupActiveMQOptions struct

+ Args *args.ActiveMQWriteArgs

+ XConn *args.ActiveMQConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupActiveMQOptions) ProtoMessage()

+ func (m *TunnelGroupActiveMQOptions) GetArgs() *args.ActiveMQWriteArgs

+ func (m *TunnelGroupActiveMQOptions) GetXConn() *args.ActiveMQConn

+ func (m *TunnelGroupActiveMQOptions) Reset()

+ func (m *TunnelGroupActiveMQOptions) String() string

+ func (m *TunnelGroupActiveMQOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupActiveMQOptions) XXX_Size() int

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

+ type TunnelGroupAzureEventHubOptions struct

+ Args *args.AzureEventHubWriteArgs

+ XConn *args.AzureEventHubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupAzureEventHubOptions) ProtoMessage()

+ func (m *TunnelGroupAzureEventHubOptions) GetArgs() *args.AzureEventHubWriteArgs

+ func (m *TunnelGroupAzureEventHubOptions) GetXConn() *args.AzureEventHubConn

+ func (m *TunnelGroupAzureEventHubOptions) Reset()

+ func (m *TunnelGroupAzureEventHubOptions) String() string

+ func (m *TunnelGroupAzureEventHubOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupAzureEventHubOptions) XXX_Size() int

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

+ type TunnelGroupAzureServiceBusOptions struct

+ Args *args.AzureServiceBusWriteArgs

+ XConn *args.AzureServiceBusConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupAzureServiceBusOptions) ProtoMessage()

+ func (m *TunnelGroupAzureServiceBusOptions) GetArgs() *args.AzureServiceBusWriteArgs

+ func (m *TunnelGroupAzureServiceBusOptions) GetXConn() *args.AzureServiceBusConn

+ func (m *TunnelGroupAzureServiceBusOptions) Reset()

+ func (m *TunnelGroupAzureServiceBusOptions) String() string

+ func (m *TunnelGroupAzureServiceBusOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupAzureServiceBusOptions) XXX_Size() int

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

+ type TunnelGroupGCPPubSubOptions struct

+ Args *args.GCPPubSubWriteArgs

+ XConn *args.GCPPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupGCPPubSubOptions) ProtoMessage()

+ func (m *TunnelGroupGCPPubSubOptions) GetArgs() *args.GCPPubSubWriteArgs

+ func (m *TunnelGroupGCPPubSubOptions) GetXConn() *args.GCPPubSubConn

+ func (m *TunnelGroupGCPPubSubOptions) Reset()

+ func (m *TunnelGroupGCPPubSubOptions) String() string

+ func (m *TunnelGroupGCPPubSubOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupGCPPubSubOptions) XXX_Size() int

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

+ type TunnelGroupKafkaOptions struct

+ Args *args.KafkaWriteArgs

+ XConn *args.KafkaConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupKafkaOptions) ProtoMessage()

+ func (m *TunnelGroupKafkaOptions) GetArgs() *args.KafkaWriteArgs

+ func (m *TunnelGroupKafkaOptions) GetXConn() *args.KafkaConn

+ func (m *TunnelGroupKafkaOptions) Reset()

+ func (m *TunnelGroupKafkaOptions) String() string

+ func (m *TunnelGroupKafkaOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupKafkaOptions) XXX_Size() int

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

+ type TunnelGroupKubeMQQueueOptions struct

+ Args *args.KubeMQQueueWriteArgs

+ XConn *args.KubeMQQueueConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupKubeMQQueueOptions) ProtoMessage()

+ func (m *TunnelGroupKubeMQQueueOptions) GetArgs() *args.KubeMQQueueWriteArgs

+ func (m *TunnelGroupKubeMQQueueOptions) GetXConn() *args.KubeMQQueueConn

+ func (m *TunnelGroupKubeMQQueueOptions) Reset()

+ func (m *TunnelGroupKubeMQQueueOptions) String() string

+ func (m *TunnelGroupKubeMQQueueOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupKubeMQQueueOptions) XXX_Size() int

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

+ type TunnelGroupMQTTOptions struct

+ Args *args.MQTTWriteArgs

+ XConn *args.MQTTConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupMQTTOptions) ProtoMessage()

+ func (m *TunnelGroupMQTTOptions) GetArgs() *args.MQTTWriteArgs

+ func (m *TunnelGroupMQTTOptions) GetXConn() *args.MQTTConn

+ func (m *TunnelGroupMQTTOptions) Reset()

+ func (m *TunnelGroupMQTTOptions) String() string

+ func (m *TunnelGroupMQTTOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupMQTTOptions) XXX_Size() int

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

+ type TunnelGroupNSQOptions struct

+ Args *args.NSQWriteArgs

+ XConn *args.NSQConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupNSQOptions) ProtoMessage()

+ func (m *TunnelGroupNSQOptions) GetArgs() *args.NSQWriteArgs

+ func (m *TunnelGroupNSQOptions) GetXConn() *args.NSQConn

+ func (m *TunnelGroupNSQOptions) Reset()

+ func (m *TunnelGroupNSQOptions) String() string

+ func (m *TunnelGroupNSQOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupNSQOptions) XXX_Size() int

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

+ type TunnelGroupNatsJetstreamOptions struct

+ Args *args.NatsJetstreamWriteArgs

+ XConn *args.NatsJetstreamConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupNatsJetstreamOptions) ProtoMessage()

+ func (m *TunnelGroupNatsJetstreamOptions) GetArgs() *args.NatsJetstreamWriteArgs

+ func (m *TunnelGroupNatsJetstreamOptions) GetXConn() *args.NatsJetstreamConn

+ func (m *TunnelGroupNatsJetstreamOptions) Reset()

+ func (m *TunnelGroupNatsJetstreamOptions) String() string

+ func (m *TunnelGroupNatsJetstreamOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupNatsJetstreamOptions) XXX_Size() int

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

+ type TunnelGroupNatsOptions struct

+ Args *args.NatsWriteArgs

+ XConn *args.NatsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupNatsOptions) ProtoMessage()

+ func (m *TunnelGroupNatsOptions) GetArgs() *args.NatsWriteArgs

+ func (m *TunnelGroupNatsOptions) GetXConn() *args.NatsConn

+ func (m *TunnelGroupNatsOptions) Reset()

+ func (m *TunnelGroupNatsOptions) String() string

+ func (m *TunnelGroupNatsOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupNatsOptions) XXX_Size() int

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

+ type TunnelGroupNatsStreamingOptions struct

+ Args *args.NatsStreamingWriteArgs

+ XConn *args.NatsStreamingConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupNatsStreamingOptions) ProtoMessage()

+ func (m *TunnelGroupNatsStreamingOptions) GetArgs() *args.NatsStreamingWriteArgs

+ func (m *TunnelGroupNatsStreamingOptions) GetXConn() *args.NatsStreamingConn

+ func (m *TunnelGroupNatsStreamingOptions) Reset()

+ func (m *TunnelGroupNatsStreamingOptions) String() string

+ func (m *TunnelGroupNatsStreamingOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupNatsStreamingOptions) XXX_Size() int

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

+ type TunnelGroupPulsarOptions struct

+ Args *args.PulsarWriteArgs

+ XConn *args.PulsarConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupPulsarOptions) ProtoMessage()

+ func (m *TunnelGroupPulsarOptions) GetArgs() *args.PulsarWriteArgs

+ func (m *TunnelGroupPulsarOptions) GetXConn() *args.PulsarConn

+ func (m *TunnelGroupPulsarOptions) Reset()

+ func (m *TunnelGroupPulsarOptions) String() string

+ func (m *TunnelGroupPulsarOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupPulsarOptions) XXX_Size() int

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

+ type TunnelGroupRabbitOptions struct

+ Args *args.RabbitWriteArgs

+ XConn *args.RabbitConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupRabbitOptions) ProtoMessage()

+ func (m *TunnelGroupRabbitOptions) GetArgs() *args.RabbitWriteArgs

+ func (m *TunnelGroupRabbitOptions) GetXConn() *args.RabbitConn

+ func (m *TunnelGroupRabbitOptions) Reset()

+ func (m *TunnelGroupRabbitOptions) String() string

+ func (m *TunnelGroupRabbitOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupRabbitOptions) XXX_Size() int

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

+ type TunnelGroupRabbitStreamsOptions struct

+ Args *args.RabbitStreamsWriteArgs

+ XConn *args.RabbitStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupRabbitStreamsOptions) ProtoMessage()

+ func (m *TunnelGroupRabbitStreamsOptions) GetArgs() *args.RabbitStreamsWriteArgs

+ func (m *TunnelGroupRabbitStreamsOptions) GetXConn() *args.RabbitStreamsConn

+ func (m *TunnelGroupRabbitStreamsOptions) Reset()

+ func (m *TunnelGroupRabbitStreamsOptions) String() string

+ func (m *TunnelGroupRabbitStreamsOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupRabbitStreamsOptions) XXX_Size() int

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

+ type TunnelGroupRedisPubSubOptions struct

+ Args *args.RedisPubSubWriteArgs

+ XConn *args.RedisPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupRedisPubSubOptions) ProtoMessage()

+ func (m *TunnelGroupRedisPubSubOptions) GetArgs() *args.RedisPubSubWriteArgs

+ func (m *TunnelGroupRedisPubSubOptions) GetXConn() *args.RedisPubSubConn

+ func (m *TunnelGroupRedisPubSubOptions) Reset()

+ func (m *TunnelGroupRedisPubSubOptions) String() string

+ func (m *TunnelGroupRedisPubSubOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupRedisPubSubOptions) XXX_Size() int

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

+ type TunnelGroupRedisStreamsOptions struct

+ Args *args.RedisStreamsWriteArgs

+ XConn *args.RedisStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelGroupRedisStreamsOptions) ProtoMessage()

+ func (m *TunnelGroupRedisStreamsOptions) GetArgs() *args.RedisStreamsWriteArgs

+ func (m *TunnelGroupRedisStreamsOptions) GetXConn() *args.RedisStreamsConn

+ func (m *TunnelGroupRedisStreamsOptions) Reset()

+ func (m *TunnelGroupRedisStreamsOptions) String() string

+ func (m *TunnelGroupRedisStreamsOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelGroupRedisStreamsOptions) XXX_Size() int

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

+ type TunnelOptions struct

+ Activemq *TunnelGroupActiveMQOptions

+ ApiToken string

+ AwsKinesis *TunnelGroupAWSKinesisOptions

+ AwsSns *TunnelGroupAWSSNSOptions

+ AwsSqs *TunnelGroupAWSSQSOptions

+ AzureEventHub *TunnelGroupAzureEventHubOptions

+ AzureServiceBus *TunnelGroupAzureServiceBusOptions

+ ConnectionId string

+ GcpPubsub *TunnelGroupGCPPubSubOptions

+ Kafka *TunnelGroupKafkaOptions

+ KubemqQueue *TunnelGroupKubeMQQueueOptions

+ Mqtt *TunnelGroupMQTTOptions

+ Name string

+ Nats *TunnelGroupNatsOptions

+ NatsJetstream *TunnelGroupNatsJetstreamOptions

+ NatsStreaming *TunnelGroupNatsStreamingOptions

+ Nsq *TunnelGroupNSQOptions

+ Pulsar *TunnelGroupPulsarOptions

+ Rabbit *TunnelGroupRabbitOptions

+ RabbitStreams *TunnelGroupRabbitStreamsOptions

+ RedisPubsub *TunnelGroupRedisPubSubOptions

+ RedisStreams *TunnelGroupRedisStreamsOptions

+ XActive bool

+ XGrpcAddress string

+ XGrpcInsecure bool

+ XGrpcTimeoutSeconds uint32

+ XTunnelId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TunnelOptions) ProtoMessage()

+ func (m *TunnelOptions) GetActivemq() *TunnelGroupActiveMQOptions

+ func (m *TunnelOptions) GetApiToken() string

+ func (m *TunnelOptions) GetAwsKinesis() *TunnelGroupAWSKinesisOptions

+ func (m *TunnelOptions) GetAwsSns() *TunnelGroupAWSSNSOptions

+ func (m *TunnelOptions) GetAwsSqs() *TunnelGroupAWSSQSOptions

+ func (m *TunnelOptions) GetAzureEventHub() *TunnelGroupAzureEventHubOptions

+ func (m *TunnelOptions) GetAzureServiceBus() *TunnelGroupAzureServiceBusOptions

+ func (m *TunnelOptions) GetConnectionId() string

+ func (m *TunnelOptions) GetGcpPubsub() *TunnelGroupGCPPubSubOptions

+ func (m *TunnelOptions) GetKafka() *TunnelGroupKafkaOptions

+ func (m *TunnelOptions) GetKubemqQueue() *TunnelGroupKubeMQQueueOptions

+ func (m *TunnelOptions) GetMqtt() *TunnelGroupMQTTOptions

+ func (m *TunnelOptions) GetName() string

+ func (m *TunnelOptions) GetNats() *TunnelGroupNatsOptions

+ func (m *TunnelOptions) GetNatsJetstream() *TunnelGroupNatsJetstreamOptions

+ func (m *TunnelOptions) GetNatsStreaming() *TunnelGroupNatsStreamingOptions

+ func (m *TunnelOptions) GetNsq() *TunnelGroupNSQOptions

+ func (m *TunnelOptions) GetPulsar() *TunnelGroupPulsarOptions

+ func (m *TunnelOptions) GetRabbit() *TunnelGroupRabbitOptions

+ func (m *TunnelOptions) GetRabbitStreams() *TunnelGroupRabbitStreamsOptions

+ func (m *TunnelOptions) GetRedisPubsub() *TunnelGroupRedisPubSubOptions

+ func (m *TunnelOptions) GetRedisStreams() *TunnelGroupRedisStreamsOptions

+ func (m *TunnelOptions) GetXActive() bool

+ func (m *TunnelOptions) GetXGrpcAddress() string

+ func (m *TunnelOptions) GetXGrpcInsecure() bool

+ func (m *TunnelOptions) GetXGrpcTimeoutSeconds() uint32

+ func (m *TunnelOptions) GetXTunnelId() string

+ func (m *TunnelOptions) Reset()

+ func (m *TunnelOptions) String() string

+ func (m *TunnelOptions) XXX_DiscardUnknown()

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

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

+ func (m *TunnelOptions) XXX_Size() int

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

Feb 14, 2022

Changes in this version

type DynamicOptions

+ Name string

+ func (m *DynamicOptions) GetName() string

Feb 10, 2022

Changes in this version

type ServerOptions

+ UseTls bool

+ func (m *ServerOptions) GetUseTls() bool

Feb 9, 2022

Changes in this version

type ServerOptions

+ EnableCluster bool

+ func (m *ServerOptions) GetEnableCluster() bool

Feb 8, 2022

Changes in this version

type ServerOptions

+ NatsUrl []string

+ TlsCaFile string

+ TlsCertFile string

+ TlsKeyFile string

+ TlsSkipVerify bool

+ func (m *ServerOptions) GetNatsUrl() []string

+ func (m *ServerOptions) GetTlsCaFile() string

+ func (m *ServerOptions) GetTlsCertFile() string

+ func (m *ServerOptions) GetTlsKeyFile() string

+ func (m *ServerOptions) GetTlsSkipVerify() bool

Feb 7, 2022

Changes in this version

type DynamicOptions

+ XActive bool

+ XDynamicId string

+ func (m *DynamicOptions) GetXActive() bool

+ func (m *DynamicOptions) GetXDynamicId() string

Feb 3, 2022

Changes in this version

type ServerOptions

+ StoragePath string

+ func (m *ServerOptions) GetStoragePath() string

Feb 2, 2022

Changes in this version

type ServerOptions

+ HttpListenAddress string

+ func (m *ServerOptions) GetHttpListenAddress() string

Feb 1, 2022

Changes in this version

type DynamicOptions

+ ConnectionId string

+ func (m *DynamicOptions) GetConnectionId() string

type RelayOptions

+ XActive string

+ func (m *RelayOptions) GetXActive() string

Jan 25, 2022

Changes in this version

type AlertEmailOutput

+ EmailAddresses []string

+ func (m *AlertEmailOutput) GetEmailAddresses() []string

type AlertSchedule

+ TimeRangeOffs []*AlertTimeRange

+ TimeRangeOns []*AlertTimeRange

+ func (m *AlertSchedule) GetTimeRangeOffs() []*AlertTimeRange

+ func (m *AlertSchedule) GetTimeRangeOns() []*AlertTimeRange

type AlertSlackOutput

+ ChannelIds []string

+ func (m *AlertSlackOutput) GetChannelIds() []string

type InferSchemaOptions_Type

+ const InferSchemaOptions_JSONSCHEMA

type MonitorSchemaValidationConfig

+ SchemaIds []string

+ func (m *MonitorSchemaValidationConfig) GetSchemaIds() []string

type WriteCLIOptions

+ InputStdins []string

+ func (m *WriteCLIOptions) GetInputStdins() []string

Jan 25, 2022

Changes in this version

+ type RelayGroupNatsJetStreamOptions struct

+ Args *args.NatsJetstreamReadArgs

+ XConn *args.NatsJetstreamConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupNatsJetStreamOptions) ProtoMessage()

+ func (m *RelayGroupNatsJetStreamOptions) GetArgs() *args.NatsJetstreamReadArgs

+ func (m *RelayGroupNatsJetStreamOptions) GetXConn() *args.NatsJetstreamConn

+ func (m *RelayGroupNatsJetStreamOptions) Reset()

+ func (m *RelayGroupNatsJetStreamOptions) String() string

+ func (m *RelayGroupNatsJetStreamOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupNatsJetStreamOptions) XXX_Size() int

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

+ type RelayGroupNatsOptions struct

+ Args *args.NatsReadArgs

+ XConn *args.NatsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupNatsOptions) ProtoMessage()

+ func (m *RelayGroupNatsOptions) GetArgs() *args.NatsReadArgs

+ func (m *RelayGroupNatsOptions) GetXConn() *args.NatsConn

+ func (m *RelayGroupNatsOptions) Reset()

+ func (m *RelayGroupNatsOptions) String() string

+ func (m *RelayGroupNatsOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupNatsOptions) XXX_Size() int

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

+ type RelayGroupNatsStreamingOptions struct

+ Args *args.NatsStreamingReadArgs

+ XConn *args.NatsStreamingConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupNatsStreamingOptions) ProtoMessage()

+ func (m *RelayGroupNatsStreamingOptions) GetArgs() *args.NatsStreamingReadArgs

+ func (m *RelayGroupNatsStreamingOptions) GetXConn() *args.NatsStreamingConn

+ func (m *RelayGroupNatsStreamingOptions) Reset()

+ func (m *RelayGroupNatsStreamingOptions) String() string

+ func (m *RelayGroupNatsStreamingOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupNatsStreamingOptions) XXX_Size() int

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

type RelayOptions

+ Nats *RelayGroupNatsOptions

+ NatsJetstream *RelayGroupNatsJetStreamOptions

+ NatsStreaming *RelayGroupNatsStreamingOptions

+ func (m *RelayOptions) GetNats() *RelayGroupNatsOptions

+ func (m *RelayOptions) GetNatsJetstream() *RelayGroupNatsJetStreamOptions

+ func (m *RelayOptions) GetNatsStreaming() *RelayGroupNatsStreamingOptions

Jan 25, 2022

Changes in this version

+ type BatchListCollectionOptions struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchListCollectionOptions) ProtoMessage()

+ func (m *BatchListCollectionOptions) Reset()

+ func (m *BatchListCollectionOptions) String() string

+ func (m *BatchListCollectionOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchListCollectionOptions) XXX_Size() int

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

+ type BatchListDestinationOptions struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchListDestinationOptions) ProtoMessage()

+ func (m *BatchListDestinationOptions) Reset()

+ func (m *BatchListDestinationOptions) String() string

+ func (m *BatchListDestinationOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchListDestinationOptions) XXX_Size() int

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

+ type BatchListReplayOptions struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchListReplayOptions) ProtoMessage()

+ func (m *BatchListReplayOptions) Reset()

+ func (m *BatchListReplayOptions) String() string

+ func (m *BatchListReplayOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchListReplayOptions) XXX_Size() int

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

+ type BatchListSchemaOptions struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchListSchemaOptions) ProtoMessage()

+ func (m *BatchListSchemaOptions) Reset()

+ func (m *BatchListSchemaOptions) String() string

+ func (m *BatchListSchemaOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchListSchemaOptions) XXX_Size() int

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

Dec 21, 2021

Changes in this version

type ConnectionOptions

+ func (m *ConnectionOptions) GetAwsKinesis() *args.AWSKinesisConn

+ type ConnectionOptions_AwsKinesis struct

+ AwsKinesis *args.AWSKinesisConn

+ type DynamicGroupAWSKinesisOptions struct

+ Args *args.AWSKinesisWriteArgs

+ XConn *args.AWSKinesisConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupAWSKinesisOptions) ProtoMessage()

+ func (m *DynamicGroupAWSKinesisOptions) GetArgs() *args.AWSKinesisWriteArgs

+ func (m *DynamicGroupAWSKinesisOptions) GetXConn() *args.AWSKinesisConn

+ func (m *DynamicGroupAWSKinesisOptions) Reset()

+ func (m *DynamicGroupAWSKinesisOptions) String() string

+ func (m *DynamicGroupAWSKinesisOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupAWSKinesisOptions) XXX_Size() int

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

type DynamicOptions

+ AwsKinesis *DynamicGroupAWSKinesisOptions

+ func (m *DynamicOptions) GetAwsKinesis() *DynamicGroupAWSKinesisOptions

+ type ReadGroupAWSKinesisOptions struct

+ Args *args.AWSKinesisReadArgs

+ XConn *args.AWSKinesisConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupAWSKinesisOptions) ProtoMessage()

+ func (m *ReadGroupAWSKinesisOptions) GetArgs() *args.AWSKinesisReadArgs

+ func (m *ReadGroupAWSKinesisOptions) GetXConn() *args.AWSKinesisConn

+ func (m *ReadGroupAWSKinesisOptions) Reset()

+ func (m *ReadGroupAWSKinesisOptions) String() string

+ func (m *ReadGroupAWSKinesisOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupAWSKinesisOptions) XXX_Size() int

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

type ReadOptions

+ AwsKinesis *ReadGroupAWSKinesisOptions

+ func (m *ReadOptions) GetAwsKinesis() *ReadGroupAWSKinesisOptions

+ type WriteGroupAWSKinesisOptions struct

+ Args *args.AWSKinesisWriteArgs

+ XConn *args.AWSKinesisConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WriteGroupAWSKinesisOptions) ProtoMessage()

+ func (m *WriteGroupAWSKinesisOptions) GetArgs() *args.AWSKinesisWriteArgs

+ func (m *WriteGroupAWSKinesisOptions) GetXConn() *args.AWSKinesisConn

+ func (m *WriteGroupAWSKinesisOptions) Reset()

+ func (m *WriteGroupAWSKinesisOptions) String() string

+ func (m *WriteGroupAWSKinesisOptions) XXX_DiscardUnknown()

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

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

+ func (m *WriteGroupAWSKinesisOptions) XXX_Size() int

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

type WriteOptions

+ AwsKinesis *WriteGroupAWSKinesisOptions

+ func (m *WriteOptions) GetAwsKinesis() *WriteGroupAWSKinesisOptions

Dec 16, 2021

Changes in this version

type ConnectionOptions

+ func (m *ConnectionOptions) GetNatsJetstream() *args.NatsJetstreamConn

+ type ConnectionOptions_NatsJetstream struct

+ NatsJetstream *args.NatsJetstreamConn

+ type DynamicGroupNatsJetstreamOptions struct

+ Args *args.NatsJetstreamWriteArgs

+ XConn *args.NatsJetstreamConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupNatsJetstreamOptions) ProtoMessage()

+ func (m *DynamicGroupNatsJetstreamOptions) GetArgs() *args.NatsJetstreamWriteArgs

+ func (m *DynamicGroupNatsJetstreamOptions) GetXConn() *args.NatsJetstreamConn

+ func (m *DynamicGroupNatsJetstreamOptions) Reset()

+ func (m *DynamicGroupNatsJetstreamOptions) String() string

+ func (m *DynamicGroupNatsJetstreamOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupNatsJetstreamOptions) XXX_Size() int

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

type DynamicOptions

+ NatsJetstream *DynamicGroupNatsJetstreamOptions

+ func (m *DynamicOptions) GetNatsJetstream() *DynamicGroupNatsJetstreamOptions

+ type ReadGroupNatsJetstreamOptions struct

+ Args *args.NatsJetstreamReadArgs

+ XConn *args.NatsJetstreamConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupNatsJetstreamOptions) ProtoMessage()

+ func (m *ReadGroupNatsJetstreamOptions) GetArgs() *args.NatsJetstreamReadArgs

+ func (m *ReadGroupNatsJetstreamOptions) GetXConn() *args.NatsJetstreamConn

+ func (m *ReadGroupNatsJetstreamOptions) Reset()

+ func (m *ReadGroupNatsJetstreamOptions) String() string

+ func (m *ReadGroupNatsJetstreamOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupNatsJetstreamOptions) XXX_Size() int

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

type ReadOptions

+ NatsJetstream *ReadGroupNatsJetstreamOptions

+ func (m *ReadOptions) GetNatsJetstream() *ReadGroupNatsJetstreamOptions

+ type WriteGroupNatsJetstreamOptions struct

+ Args *args.NatsJetstreamWriteArgs

+ XConn *args.NatsJetstreamConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WriteGroupNatsJetstreamOptions) ProtoMessage()

+ func (m *WriteGroupNatsJetstreamOptions) GetArgs() *args.NatsJetstreamWriteArgs

+ func (m *WriteGroupNatsJetstreamOptions) GetXConn() *args.NatsJetstreamConn

+ func (m *WriteGroupNatsJetstreamOptions) Reset()

+ func (m *WriteGroupNatsJetstreamOptions) String() string

+ func (m *WriteGroupNatsJetstreamOptions) XXX_DiscardUnknown()

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

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

+ func (m *WriteGroupNatsJetstreamOptions) XXX_Size() int

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

type WriteOptions

+ NatsJetstream *WriteGroupNatsJetstreamOptions

+ func (m *WriteOptions) GetNatsJetstream() *WriteGroupNatsJetstreamOptions

Dec 10, 2021

Changes in this version

type ReadCLIOptions

+ Json bool

+ func (m *ReadCLIOptions) GetJson() bool

Dec 3, 2021

Changes in this version

type BatchCreateDestinationOptions

+ AwsSqs *WriteGroupAWSSQSOptions

+ func (m *BatchCreateDestinationOptions) GetAwsSqs() *WriteGroupAWSSQSOptions

type ConnectionOptions

+ func (m *ConnectionOptions) GetAwsSns() *args.AWSSNSConn

+ func (m *ConnectionOptions) GetAwsSqs() *args.AWSSQSConn

+ type ConnectionOptions_AwsSns struct

+ AwsSns *args.AWSSNSConn

+ type ConnectionOptions_AwsSqs struct

+ AwsSqs *args.AWSSQSConn

type DynamicOptions

+ AwsSns *DynamicGroupAWSSNSOptions

+ AwsSqs *DynamicGroupAWSSQSOptions

+ func (m *DynamicOptions) GetAwsSns() *DynamicGroupAWSSNSOptions

+ func (m *DynamicOptions) GetAwsSqs() *DynamicGroupAWSSQSOptions

type ReadOptions

+ AwsSqs *ReadGroupAWSSQSOptions

+ func (m *ReadOptions) GetAwsSqs() *ReadGroupAWSSQSOptions

type RelayOptions

+ AwsSqs *RelayGroupAWSSQSOptions

+ func (m *RelayOptions) GetAwsSqs() *RelayGroupAWSSQSOptions

type WriteOptions

+ AwsSns *WriteGroupAWSSNSOptions

+ AwsSqs *WriteGroupAWSSQSOptions

+ func (m *WriteOptions) GetAwsSns() *WriteGroupAWSSNSOptions

+ func (m *WriteOptions) GetAwsSqs() *WriteGroupAWSSQSOptions

Nov 23, 2021

Changes in this version

type DynamicOptions

+ RabbitStreams *DynamicGroupRabbitStreamsOptions

+ func (m *DynamicOptions) GetRabbitStreams() *DynamicGroupRabbitStreamsOptions

Nov 19, 2021

Changes in this version

+ type DynamicGroupPulsarOptions struct

+ Args *args.PulsarWriteArgs

+ XConn *args.PulsarConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupPulsarOptions) ProtoMessage()

+ func (m *DynamicGroupPulsarOptions) GetArgs() *args.PulsarWriteArgs

+ func (m *DynamicGroupPulsarOptions) GetXConn() *args.PulsarConn

+ func (m *DynamicGroupPulsarOptions) Reset()

+ func (m *DynamicGroupPulsarOptions) String() string

+ func (m *DynamicGroupPulsarOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupPulsarOptions) XXX_Size() int

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

type DynamicOptions

+ Pulsar *DynamicGroupPulsarOptions

+ func (m *DynamicOptions) GetPulsar() *DynamicGroupPulsarOptions

Nov 17, 2021

Changes in this version

+ type Composite struct

+ ReadIds []string

+ XId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Composite) ProtoMessage()

+ func (m *Composite) GetReadIds() []string

+ func (m *Composite) GetXId() string

+ func (m *Composite) Reset()

+ func (m *Composite) String() string

+ func (m *Composite) XXX_DiscardUnknown()

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

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

+ func (m *Composite) XXX_Size() int

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

Nov 16, 2021

Changes in this version

type RelayOptions

+ StatsEnable bool

+ StatsReportIntervalSec int32

+ func (m *RelayOptions) GetStatsEnable() bool

+ func (m *RelayOptions) GetStatsReportIntervalSec() int32

Nov 8, 2021

Changes in this version

+ var Counter_Resource_name = map[int32]string

+ var Counter_Resource_value = map[string]int32

+ var Counter_Type_name = map[int32]string

+ var Counter_Type_value = map[string]int32

+ type Counter struct

+ Name string

+ Resource Counter_Resource

+ ResourceId string

+ Type Counter_Type

+ Value float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Counter) ProtoMessage()

+ func (m *Counter) GetName() string

+ func (m *Counter) GetResource() Counter_Resource

+ func (m *Counter) GetResourceId() string

+ func (m *Counter) GetType() Counter_Type

+ func (m *Counter) GetValue() float64

+ func (m *Counter) Reset()

+ func (m *Counter) String() string

+ func (m *Counter) XXX_DiscardUnknown()

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

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

+ func (m *Counter) XXX_Size() int

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

+ type Counter_Resource int32

+ const Counter_RESOURCE_CONNECTION

+ const Counter_RESOURCE_READ

+ const Counter_RESOURCE_REPLAY

+ const Counter_RESOURCE_SCHEMA

+ const Counter_RESOURCE_UNSET

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

+ func (x Counter_Resource) String() string

+ type Counter_Type int32

+ const Counter_TYPE_MESSAGE_RECEIVED

+ const Counter_TYPE_MESSAGE_REPLAYED

+ const Counter_TYPE_SCHEMA_VIOLATION

+ const Counter_TYPE_UNSET

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

+ func (x Counter_Type) String() string

type ServerOptions

+ StatsDatabasePath string

+ StatsFlushIntervalSeconds int32

+ func (m *ServerOptions) GetStatsDatabasePath() string

+ func (m *ServerOptions) GetStatsFlushIntervalSeconds() int32

Nov 5, 2021

Changes in this version

type MonitorServiceSchemaVersionConfig

+ ServiceId string

+ func (m *MonitorServiceSchemaVersionConfig) GetServiceId() string

Oct 26, 2021

Changes in this version

type MonitorSchemaValidationConfig

+ Validations []*protos.Validation

+ func (m *MonitorSchemaValidationConfig) GetValidations() []*protos.Validation

Oct 19, 2021

Changes in this version

+ var MonitorServiceSchemaVersionType_name = map[int32]string

+ var MonitorServiceSchemaVersionType_value = map[string]int32

+ var ReadOperator_name = map[int32]string

+ var ReadOperator_value = map[string]int32

+ var Weekday_name = map[int32]string

+ var Weekday_value = map[string]int32

+ type AlertEmailOutput struct

+ EmailAddress []string

+ Metadata map[string]string

+ SmtpServer *AlertEmailOutput_SMTPServer

+ Subject string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AlertEmailOutput) ProtoMessage()

+ func (m *AlertEmailOutput) GetEmailAddress() []string

+ func (m *AlertEmailOutput) GetMetadata() map[string]string

+ func (m *AlertEmailOutput) GetSmtpServer() *AlertEmailOutput_SMTPServer

+ func (m *AlertEmailOutput) GetSubject() string

+ func (m *AlertEmailOutput) Reset()

+ func (m *AlertEmailOutput) String() string

+ func (m *AlertEmailOutput) XXX_DiscardUnknown()

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

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

+ func (m *AlertEmailOutput) XXX_Size() int

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

+ type AlertEmailOutput_SMTPServer struct

+ FromAddress string

+ Hostname string

+ Password string

+ Port int32

+ UseTls bool

+ Username string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AlertEmailOutput_SMTPServer) ProtoMessage()

+ func (m *AlertEmailOutput_SMTPServer) GetFromAddress() string

+ func (m *AlertEmailOutput_SMTPServer) GetHostname() string

+ func (m *AlertEmailOutput_SMTPServer) GetPassword() string

+ func (m *AlertEmailOutput_SMTPServer) GetPort() int32

+ func (m *AlertEmailOutput_SMTPServer) GetUseTls() bool

+ func (m *AlertEmailOutput_SMTPServer) GetUsername() string

+ func (m *AlertEmailOutput_SMTPServer) Reset()

+ func (m *AlertEmailOutput_SMTPServer) String() string

+ func (m *AlertEmailOutput_SMTPServer) XXX_DiscardUnknown()

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

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

+ func (m *AlertEmailOutput_SMTPServer) XXX_Size() int

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

+ type AlertOptions struct

+ MonitorIds []string

+ Outputs []*AlertOutput

+ Schedule *AlertSchedule

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AlertOptions) ProtoMessage()

+ func (m *AlertOptions) GetMonitorIds() []string

+ func (m *AlertOptions) GetOutputs() []*AlertOutput

+ func (m *AlertOptions) GetSchedule() *AlertSchedule

+ func (m *AlertOptions) Reset()

+ func (m *AlertOptions) String() string

+ func (m *AlertOptions) XXX_DiscardUnknown()

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

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

+ func (m *AlertOptions) XXX_Size() int

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

+ type AlertOutput struct

+ Output isAlertOutput_Output

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AlertOutput) ProtoMessage()

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

+ func (m *AlertOutput) GetEmail() *AlertEmailOutput

+ func (m *AlertOutput) GetOutput() isAlertOutput_Output

+ func (m *AlertOutput) GetPagerduty() *AlertPagerdutyOutput

+ func (m *AlertOutput) GetSlack() *AlertSlackOutput

+ func (m *AlertOutput) Reset()

+ func (m *AlertOutput) String() string

+ func (m *AlertOutput) XXX_DiscardUnknown()

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

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

+ func (m *AlertOutput) XXX_Size() int

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

+ type AlertOutput_Email struct

+ Email *AlertEmailOutput

+ type AlertOutput_Pagerduty struct

+ Pagerduty *AlertPagerdutyOutput

+ type AlertOutput_Slack struct

+ Slack *AlertSlackOutput

+ type AlertPagerdutyOutput struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AlertPagerdutyOutput) ProtoMessage()

+ func (m *AlertPagerdutyOutput) Reset()

+ func (m *AlertPagerdutyOutput) String() string

+ func (m *AlertPagerdutyOutput) XXX_DiscardUnknown()

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

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

+ func (m *AlertPagerdutyOutput) XXX_Size() int

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

+ type AlertSchedule struct

+ TimeRangeOff []*AlertTimeRange

+ TimeRangeOn []*AlertTimeRange

+ Timezone string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AlertSchedule) ProtoMessage()

+ func (m *AlertSchedule) GetTimeRangeOff() []*AlertTimeRange

+ func (m *AlertSchedule) GetTimeRangeOn() []*AlertTimeRange

+ func (m *AlertSchedule) GetTimezone() string

+ func (m *AlertSchedule) Reset()

+ func (m *AlertSchedule) String() string

+ func (m *AlertSchedule) XXX_DiscardUnknown()

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

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

+ func (m *AlertSchedule) XXX_Size() int

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

+ type AlertSlackOutput struct

+ AuthToken string

+ ChannelId []string

+ Metadata map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AlertSlackOutput) ProtoMessage()

+ func (m *AlertSlackOutput) GetAuthToken() string

+ func (m *AlertSlackOutput) GetChannelId() []string

+ func (m *AlertSlackOutput) GetMetadata() map[string]string

+ func (m *AlertSlackOutput) Reset()

+ func (m *AlertSlackOutput) String() string

+ func (m *AlertSlackOutput) XXX_DiscardUnknown()

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

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

+ func (m *AlertSlackOutput) XXX_Size() int

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

+ type AlertTimeRange struct

+ Days []Weekday

+ FromHour uint32

+ FromMin uint32

+ ToHour uint32

+ ToMin uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AlertTimeRange) ProtoMessage()

+ func (m *AlertTimeRange) GetDays() []Weekday

+ func (m *AlertTimeRange) GetFromHour() uint32

+ func (m *AlertTimeRange) GetFromMin() uint32

+ func (m *AlertTimeRange) GetToHour() uint32

+ func (m *AlertTimeRange) GetToMin() uint32

+ func (m *AlertTimeRange) Reset()

+ func (m *AlertTimeRange) String() string

+ func (m *AlertTimeRange) XXX_DiscardUnknown()

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

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

+ func (m *AlertTimeRange) XXX_Size() int

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

+ type IsAlertOutput_Output = isAlertOutput_Output

+ type IsMonitorOptions_Config = isMonitorOptions_Config

+ type MonitorOptions struct

+ Config isMonitorOptions_Config

+ Notes string

+ XCreatedAtTsUtc int64

+ XCreatedBy string

+ XId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MonitorOptions) ProtoMessage()

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

+ func (m *MonitorOptions) GetConfig() isMonitorOptions_Config

+ func (m *MonitorOptions) GetNotes() string

+ func (m *MonitorOptions) GetReadHasData() *MonitorReadHasDataConfig

+ func (m *MonitorOptions) GetSchemaValidation() *MonitorSchemaValidationConfig

+ func (m *MonitorOptions) GetServiceSchemaVersion() *MonitorServiceSchemaVersionConfig

+ func (m *MonitorOptions) GetXCreatedAtTsUtc() int64

+ func (m *MonitorOptions) GetXCreatedBy() string

+ func (m *MonitorOptions) GetXId() string

+ func (m *MonitorOptions) Reset()

+ func (m *MonitorOptions) String() string

+ func (m *MonitorOptions) XXX_DiscardUnknown()

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

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

+ func (m *MonitorOptions) XXX_Size() int

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

+ type MonitorOptions_ReadHasData struct

+ ReadHasData *MonitorReadHasDataConfig

+ type MonitorOptions_SchemaValidation struct

+ SchemaValidation *MonitorSchemaValidationConfig

+ type MonitorOptions_ServiceSchemaVersion struct

+ ServiceSchemaVersion *MonitorServiceSchemaVersionConfig

+ type MonitorReadHasDataConfig struct

+ IntervalSeconds int32

+ Operator ReadOperator

+ ReadIds []string

+ Value int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MonitorReadHasDataConfig) ProtoMessage()

+ func (m *MonitorReadHasDataConfig) GetIntervalSeconds() int32

+ func (m *MonitorReadHasDataConfig) GetOperator() ReadOperator

+ func (m *MonitorReadHasDataConfig) GetReadIds() []string

+ func (m *MonitorReadHasDataConfig) GetValue() int32

+ func (m *MonitorReadHasDataConfig) Reset()

+ func (m *MonitorReadHasDataConfig) String() string

+ func (m *MonitorReadHasDataConfig) XXX_DiscardUnknown()

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

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

+ func (m *MonitorReadHasDataConfig) XXX_Size() int

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

+ type MonitorSchemaValidationConfig struct

+ SchemaId []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MonitorSchemaValidationConfig) ProtoMessage()

+ func (m *MonitorSchemaValidationConfig) GetSchemaId() []string

+ func (m *MonitorSchemaValidationConfig) Reset()

+ func (m *MonitorSchemaValidationConfig) String() string

+ func (m *MonitorSchemaValidationConfig) XXX_DiscardUnknown()

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

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

+ func (m *MonitorSchemaValidationConfig) XXX_Size() int

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

+ type MonitorServiceSchemaVersionConfig struct

+ Args map[string]string

+ ServiceIds []string

+ Type MonitorServiceSchemaVersionType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MonitorServiceSchemaVersionConfig) ProtoMessage()

+ func (m *MonitorServiceSchemaVersionConfig) GetArgs() map[string]string

+ func (m *MonitorServiceSchemaVersionConfig) GetServiceIds() []string

+ func (m *MonitorServiceSchemaVersionConfig) GetType() MonitorServiceSchemaVersionType

+ func (m *MonitorServiceSchemaVersionConfig) Reset()

+ func (m *MonitorServiceSchemaVersionConfig) String() string

+ func (m *MonitorServiceSchemaVersionConfig) XXX_DiscardUnknown()

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

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

+ func (m *MonitorServiceSchemaVersionConfig) XXX_Size() int

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

+ type MonitorServiceSchemaVersionType int32

+ const MonitorServiceSchemaVersionType_SERVICE_SCHEMA_VERSION_CONDITION_TYPE_EXACT

+ const MonitorServiceSchemaVersionType_SERVICE_SCHEMA_VERSION_CONDITION_TYPE_LATEST

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

+ func (x MonitorServiceSchemaVersionType) String() string

+ type ReadOperator int32

+ const ReadOperator_READ_OPERATOR_EQ

+ const ReadOperator_READ_OPERATOR_GT

+ const ReadOperator_READ_OPERATOR_GTE

+ const ReadOperator_READ_OPERATOR_LT

+ const ReadOperator_READ_OPERATOR_LTE

+ const ReadOperator_READ_OPERATOR_UNSET

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

+ func (x ReadOperator) String() string

+ type Weekday int32

+ const Weekday_WEEKDAY_FRIDAY

+ const Weekday_WEEKDAY_MONDAY

+ const Weekday_WEEKDAY_SATURDAY

+ const Weekday_WEEKDAY_SUNDAY

+ const Weekday_WEEKDAY_THURSDAY

+ const Weekday_WEEKDAY_TUESDAY

+ const Weekday_WEEKDAY_WEDNESDAY

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

+ func (x Weekday) String() string

Oct 15, 2021

Changes in this version

+ var InferSchemaOptions_Type_name = map[int32]string

+ var InferSchemaOptions_Type_value = map[string]int32

+ type InferSchemaOptions struct

+ SchemaId string

+ Type InferSchemaOptions_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InferSchemaOptions) ProtoMessage()

+ func (m *InferSchemaOptions) GetSchemaId() string

+ func (m *InferSchemaOptions) GetType() InferSchemaOptions_Type

+ func (m *InferSchemaOptions) Reset()

+ func (m *InferSchemaOptions) String() string

+ func (m *InferSchemaOptions) XXX_DiscardUnknown()

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

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

+ func (m *InferSchemaOptions) XXX_Size() int

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

+ type InferSchemaOptions_Type int32

+ const InferSchemaOptions_JSONSchema

+ const InferSchemaOptions_UNSET

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

+ func (x InferSchemaOptions_Type) String() string

type ReadOptions

+ InferSchemaOptions *InferSchemaOptions

+ func (m *ReadOptions) GetInferSchemaOptions() *InferSchemaOptions

Oct 7, 2021

Changes in this version

+ type ReadFilterOptions struct

+ Query string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadFilterOptions) ProtoMessage()

+ func (m *ReadFilterOptions) GetQuery() string

+ func (m *ReadFilterOptions) Reset()

+ func (m *ReadFilterOptions) String() string

+ func (m *ReadFilterOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadFilterOptions) XXX_Size() int

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

type ReadOptions

+ Filter *ReadFilterOptions

+ func (m *ReadOptions) GetFilter() *ReadFilterOptions

Sep 24, 2021

Changes in this version

type ServerOptions

+ VcserviceGrpcAddress string

+ VcserviceGrpcInsecure bool

+ VcserviceGrpcTimeoutSeconds uint32

+ func (m *ServerOptions) GetVcserviceGrpcAddress() string

+ func (m *ServerOptions) GetVcserviceGrpcInsecure() bool

+ func (m *ServerOptions) GetVcserviceGrpcTimeoutSeconds() uint32

Sep 21, 2021

Changes in this version

type IsConnectionOptions_Conn

+ func GenerateConnOpts(backend string, connArgs interface{}) (IsConnectionOptions_Conn, bool)

Sep 15, 2021

Changes in this version

+ var BatchOutputType_name = map[int32]string

+ var BatchOutputType_value = map[string]int32

+ var BatchReplayType_name = map[int32]string

+ var BatchReplayType_value = map[string]int32

+ type BatchArchiveOptions struct

+ Replay *BatchArchiveReplayOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchArchiveOptions) ProtoMessage()

+ func (m *BatchArchiveOptions) GetReplay() *BatchArchiveReplayOptions

+ func (m *BatchArchiveOptions) Reset()

+ func (m *BatchArchiveOptions) String() string

+ func (m *BatchArchiveOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchArchiveOptions) XXX_Size() int

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

+ type BatchArchiveReplayOptions struct

+ ReplayId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchArchiveReplayOptions) ProtoMessage()

+ func (m *BatchArchiveReplayOptions) GetReplayId() string

+ func (m *BatchArchiveReplayOptions) Reset()

+ func (m *BatchArchiveReplayOptions) String() string

+ func (m *BatchArchiveReplayOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchArchiveReplayOptions) XXX_Size() int

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

+ type BatchCreateCollectionOptions struct

+ Name string

+ Notes string

+ SchemaId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchCreateCollectionOptions) ProtoMessage()

+ func (m *BatchCreateCollectionOptions) GetName() string

+ func (m *BatchCreateCollectionOptions) GetNotes() string

+ func (m *BatchCreateCollectionOptions) GetSchemaId() string

+ func (m *BatchCreateCollectionOptions) Reset()

+ func (m *BatchCreateCollectionOptions) String() string

+ func (m *BatchCreateCollectionOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchCreateCollectionOptions) XXX_Size() int

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

+ type BatchCreateDestinationOptions struct

+ Awssqs *WriteGroupAWSSQSOptions

+ Http *HTTPDestination

+ Kafka *WriteGroupKafkaOptions

+ KubemqQueue *WriteGroupKubeMQQueueOptions

+ Name string

+ Notes string

+ Rabbit *WriteGroupRabbitOptions

+ XApiDestinationType string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchCreateDestinationOptions) ProtoMessage()

+ func (m *BatchCreateDestinationOptions) GetAwssqs() *WriteGroupAWSSQSOptions

+ func (m *BatchCreateDestinationOptions) GetHttp() *HTTPDestination

+ func (m *BatchCreateDestinationOptions) GetKafka() *WriteGroupKafkaOptions

+ func (m *BatchCreateDestinationOptions) GetKubemqQueue() *WriteGroupKubeMQQueueOptions

+ func (m *BatchCreateDestinationOptions) GetName() string

+ func (m *BatchCreateDestinationOptions) GetNotes() string

+ func (m *BatchCreateDestinationOptions) GetRabbit() *WriteGroupRabbitOptions

+ func (m *BatchCreateDestinationOptions) GetXApiDestinationType() string

+ func (m *BatchCreateDestinationOptions) Reset()

+ func (m *BatchCreateDestinationOptions) String() string

+ func (m *BatchCreateDestinationOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchCreateDestinationOptions) XXX_Size() int

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

+ type BatchCreateOptions struct

+ Collection *BatchCreateCollectionOptions

+ Destination *BatchCreateDestinationOptions

+ Replay *BatchCreateReplayOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchCreateOptions) ProtoMessage()

+ func (m *BatchCreateOptions) GetCollection() *BatchCreateCollectionOptions

+ func (m *BatchCreateOptions) GetDestination() *BatchCreateDestinationOptions

+ func (m *BatchCreateOptions) GetReplay() *BatchCreateReplayOptions

+ func (m *BatchCreateOptions) Reset()

+ func (m *BatchCreateOptions) String() string

+ func (m *BatchCreateOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchCreateOptions) XXX_Size() int

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

+ type BatchCreateReplayOptions struct

+ CollectionId string

+ DestinationId string

+ FromTimestamp string

+ Name string

+ Notes string

+ Query string

+ ToTimestamp string

+ Type BatchReplayType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchCreateReplayOptions) ProtoMessage()

+ func (m *BatchCreateReplayOptions) GetCollectionId() string

+ func (m *BatchCreateReplayOptions) GetDestinationId() string

+ func (m *BatchCreateReplayOptions) GetFromTimestamp() string

+ func (m *BatchCreateReplayOptions) GetName() string

+ func (m *BatchCreateReplayOptions) GetNotes() string

+ func (m *BatchCreateReplayOptions) GetQuery() string

+ func (m *BatchCreateReplayOptions) GetToTimestamp() string

+ func (m *BatchCreateReplayOptions) GetType() BatchReplayType

+ func (m *BatchCreateReplayOptions) Reset()

+ func (m *BatchCreateReplayOptions) String() string

+ func (m *BatchCreateReplayOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchCreateReplayOptions) XXX_Size() int

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

+ type BatchListOptions struct

+ Collection bool

+ Destination bool

+ Replay bool

+ Schema bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchListOptions) ProtoMessage()

+ func (m *BatchListOptions) GetCollection() bool

+ func (m *BatchListOptions) GetDestination() bool

+ func (m *BatchListOptions) GetReplay() bool

+ func (m *BatchListOptions) GetSchema() bool

+ func (m *BatchListOptions) Reset()

+ func (m *BatchListOptions) String() string

+ func (m *BatchListOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchListOptions) XXX_Size() int

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

+ type BatchLoginOptions struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchLoginOptions) ProtoMessage()

+ func (m *BatchLoginOptions) Reset()

+ func (m *BatchLoginOptions) String() string

+ func (m *BatchLoginOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchLoginOptions) XXX_Size() int

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

+ type BatchLogoutOptions struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchLogoutOptions) ProtoMessage()

+ func (m *BatchLogoutOptions) Reset()

+ func (m *BatchLogoutOptions) String() string

+ func (m *BatchLogoutOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchLogoutOptions) XXX_Size() int

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

+ type BatchOptions struct

+ ApiUrl string

+ Archive *BatchArchiveOptions

+ Create *BatchCreateOptions

+ List *BatchListOptions

+ Login *BatchLoginOptions

+ Logout *BatchLogoutOptions

+ OutputType BatchOutputType

+ Search *BatchSearchOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchOptions) ProtoMessage()

+ func (m *BatchOptions) GetApiUrl() string

+ func (m *BatchOptions) GetArchive() *BatchArchiveOptions

+ func (m *BatchOptions) GetCreate() *BatchCreateOptions

+ func (m *BatchOptions) GetList() *BatchListOptions

+ func (m *BatchOptions) GetLogin() *BatchLoginOptions

+ func (m *BatchOptions) GetLogout() *BatchLogoutOptions

+ func (m *BatchOptions) GetOutputType() BatchOutputType

+ func (m *BatchOptions) GetSearch() *BatchSearchOptions

+ func (m *BatchOptions) Reset()

+ func (m *BatchOptions) String() string

+ func (m *BatchOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchOptions) XXX_Size() int

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

+ type BatchOutputType int32

+ const BatchOutputType_JSON

+ const BatchOutputType_TABLE

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

+ func (x BatchOutputType) String() string

+ type BatchReplayType int32

+ const BatchReplayType_CONTINUOUS

+ const BatchReplayType_SINGLE

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

+ func (x BatchReplayType) String() string

+ type BatchSearchOptions struct

+ CollectionId string

+ Page int32

+ Query string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BatchSearchOptions) ProtoMessage()

+ func (m *BatchSearchOptions) GetCollectionId() string

+ func (m *BatchSearchOptions) GetPage() int32

+ func (m *BatchSearchOptions) GetQuery() string

+ func (m *BatchSearchOptions) Reset()

+ func (m *BatchSearchOptions) String() string

+ func (m *BatchSearchOptions) XXX_DiscardUnknown()

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

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

+ func (m *BatchSearchOptions) XXX_Size() int

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

type CLIOptions

+ Batch *BatchOptions

+ Dynamic *DynamicOptions

+ func (m *CLIOptions) GetBatch() *BatchOptions

+ func (m *CLIOptions) GetDynamic() *DynamicOptions

+ type DynamicGroupAWSSNSOptions struct

+ Args *args.AWSSNSWriteArgs

+ XConn *args.AWSSNSConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupAWSSNSOptions) ProtoMessage()

+ func (m *DynamicGroupAWSSNSOptions) GetArgs() *args.AWSSNSWriteArgs

+ func (m *DynamicGroupAWSSNSOptions) GetXConn() *args.AWSSNSConn

+ func (m *DynamicGroupAWSSNSOptions) Reset()

+ func (m *DynamicGroupAWSSNSOptions) String() string

+ func (m *DynamicGroupAWSSNSOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupAWSSNSOptions) XXX_Size() int

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

+ type DynamicGroupAWSSQSOptions struct

+ Args *args.AWSSQSWriteArgs

+ XConn *args.AWSSQSConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupAWSSQSOptions) ProtoMessage()

+ func (m *DynamicGroupAWSSQSOptions) GetArgs() *args.AWSSQSWriteArgs

+ func (m *DynamicGroupAWSSQSOptions) GetXConn() *args.AWSSQSConn

+ func (m *DynamicGroupAWSSQSOptions) Reset()

+ func (m *DynamicGroupAWSSQSOptions) String() string

+ func (m *DynamicGroupAWSSQSOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupAWSSQSOptions) XXX_Size() int

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

+ type DynamicGroupActiveMQOptions struct

+ Args *args.ActiveMQWriteArgs

+ XConn *args.ActiveMQConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupActiveMQOptions) ProtoMessage()

+ func (m *DynamicGroupActiveMQOptions) GetArgs() *args.ActiveMQWriteArgs

+ func (m *DynamicGroupActiveMQOptions) GetXConn() *args.ActiveMQConn

+ func (m *DynamicGroupActiveMQOptions) Reset()

+ func (m *DynamicGroupActiveMQOptions) String() string

+ func (m *DynamicGroupActiveMQOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupActiveMQOptions) XXX_Size() int

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

+ type DynamicGroupAzureEventHubOptions struct

+ Args *args.AzureEventHubWriteArgs

+ XConn *args.AzureEventHubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupAzureEventHubOptions) ProtoMessage()

+ func (m *DynamicGroupAzureEventHubOptions) GetArgs() *args.AzureEventHubWriteArgs

+ func (m *DynamicGroupAzureEventHubOptions) GetXConn() *args.AzureEventHubConn

+ func (m *DynamicGroupAzureEventHubOptions) Reset()

+ func (m *DynamicGroupAzureEventHubOptions) String() string

+ func (m *DynamicGroupAzureEventHubOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupAzureEventHubOptions) XXX_Size() int

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

+ type DynamicGroupAzureServiceBusOptions struct

+ Args *args.AzureServiceBusWriteArgs

+ XConn *args.AzureServiceBusConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupAzureServiceBusOptions) ProtoMessage()

+ func (m *DynamicGroupAzureServiceBusOptions) GetArgs() *args.AzureServiceBusWriteArgs

+ func (m *DynamicGroupAzureServiceBusOptions) GetXConn() *args.AzureServiceBusConn

+ func (m *DynamicGroupAzureServiceBusOptions) Reset()

+ func (m *DynamicGroupAzureServiceBusOptions) String() string

+ func (m *DynamicGroupAzureServiceBusOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupAzureServiceBusOptions) XXX_Size() int

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

+ type DynamicGroupGCPPubSubOptions struct

+ Args *args.GCPPubSubWriteArgs

+ XConn *args.GCPPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupGCPPubSubOptions) ProtoMessage()

+ func (m *DynamicGroupGCPPubSubOptions) GetArgs() *args.GCPPubSubWriteArgs

+ func (m *DynamicGroupGCPPubSubOptions) GetXConn() *args.GCPPubSubConn

+ func (m *DynamicGroupGCPPubSubOptions) Reset()

+ func (m *DynamicGroupGCPPubSubOptions) String() string

+ func (m *DynamicGroupGCPPubSubOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupGCPPubSubOptions) XXX_Size() int

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

+ type DynamicGroupKafkaOptions struct

+ Args *args.KafkaWriteArgs

+ XConn *args.KafkaConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupKafkaOptions) ProtoMessage()

+ func (m *DynamicGroupKafkaOptions) GetArgs() *args.KafkaWriteArgs

+ func (m *DynamicGroupKafkaOptions) GetXConn() *args.KafkaConn

+ func (m *DynamicGroupKafkaOptions) Reset()

+ func (m *DynamicGroupKafkaOptions) String() string

+ func (m *DynamicGroupKafkaOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupKafkaOptions) XXX_Size() int

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

+ type DynamicGroupKubeMQQueueOptions struct

+ Args *args.KubeMQQueueWriteArgs

+ XConn *args.KubeMQQueueConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupKubeMQQueueOptions) ProtoMessage()

+ func (m *DynamicGroupKubeMQQueueOptions) GetArgs() *args.KubeMQQueueWriteArgs

+ func (m *DynamicGroupKubeMQQueueOptions) GetXConn() *args.KubeMQQueueConn

+ func (m *DynamicGroupKubeMQQueueOptions) Reset()

+ func (m *DynamicGroupKubeMQQueueOptions) String() string

+ func (m *DynamicGroupKubeMQQueueOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupKubeMQQueueOptions) XXX_Size() int

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

+ type DynamicGroupMQTTOptions struct

+ Args *args.MQTTWriteArgs

+ XConn *args.MQTTConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupMQTTOptions) ProtoMessage()

+ func (m *DynamicGroupMQTTOptions) GetArgs() *args.MQTTWriteArgs

+ func (m *DynamicGroupMQTTOptions) GetXConn() *args.MQTTConn

+ func (m *DynamicGroupMQTTOptions) Reset()

+ func (m *DynamicGroupMQTTOptions) String() string

+ func (m *DynamicGroupMQTTOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupMQTTOptions) XXX_Size() int

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

+ type DynamicGroupNSQOptions struct

+ Args *args.NSQWriteArgs

+ XConn *args.NSQConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupNSQOptions) ProtoMessage()

+ func (m *DynamicGroupNSQOptions) GetArgs() *args.NSQWriteArgs

+ func (m *DynamicGroupNSQOptions) GetXConn() *args.NSQConn

+ func (m *DynamicGroupNSQOptions) Reset()

+ func (m *DynamicGroupNSQOptions) String() string

+ func (m *DynamicGroupNSQOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupNSQOptions) XXX_Size() int

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

+ type DynamicGroupNatsOptions struct

+ Args *args.NatsWriteArgs

+ XConn *args.NatsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupNatsOptions) ProtoMessage()

+ func (m *DynamicGroupNatsOptions) GetArgs() *args.NatsWriteArgs

+ func (m *DynamicGroupNatsOptions) GetXConn() *args.NatsConn

+ func (m *DynamicGroupNatsOptions) Reset()

+ func (m *DynamicGroupNatsOptions) String() string

+ func (m *DynamicGroupNatsOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupNatsOptions) XXX_Size() int

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

+ type DynamicGroupNatsStreamingOptions struct

+ Args *args.NatsStreamingWriteArgs

+ XConn *args.NatsStreamingConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupNatsStreamingOptions) ProtoMessage()

+ func (m *DynamicGroupNatsStreamingOptions) GetArgs() *args.NatsStreamingWriteArgs

+ func (m *DynamicGroupNatsStreamingOptions) GetXConn() *args.NatsStreamingConn

+ func (m *DynamicGroupNatsStreamingOptions) Reset()

+ func (m *DynamicGroupNatsStreamingOptions) String() string

+ func (m *DynamicGroupNatsStreamingOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupNatsStreamingOptions) XXX_Size() int

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

+ type DynamicGroupRabbitOptions struct

+ Args *args.RabbitWriteArgs

+ XConn *args.RabbitConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupRabbitOptions) ProtoMessage()

+ func (m *DynamicGroupRabbitOptions) GetArgs() *args.RabbitWriteArgs

+ func (m *DynamicGroupRabbitOptions) GetXConn() *args.RabbitConn

+ func (m *DynamicGroupRabbitOptions) Reset()

+ func (m *DynamicGroupRabbitOptions) String() string

+ func (m *DynamicGroupRabbitOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupRabbitOptions) XXX_Size() int

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

+ type DynamicGroupRabbitStreamsOptions struct

+ Args *args.RabbitStreamsWriteArgs

+ XConn *args.RabbitStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupRabbitStreamsOptions) ProtoMessage()

+ func (m *DynamicGroupRabbitStreamsOptions) GetArgs() *args.RabbitStreamsWriteArgs

+ func (m *DynamicGroupRabbitStreamsOptions) GetXConn() *args.RabbitStreamsConn

+ func (m *DynamicGroupRabbitStreamsOptions) Reset()

+ func (m *DynamicGroupRabbitStreamsOptions) String() string

+ func (m *DynamicGroupRabbitStreamsOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupRabbitStreamsOptions) XXX_Size() int

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

+ type DynamicGroupRedisPubSubOptions struct

+ Args *args.RedisPubSubWriteArgs

+ XConn *args.RedisPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupRedisPubSubOptions) ProtoMessage()

+ func (m *DynamicGroupRedisPubSubOptions) GetArgs() *args.RedisPubSubWriteArgs

+ func (m *DynamicGroupRedisPubSubOptions) GetXConn() *args.RedisPubSubConn

+ func (m *DynamicGroupRedisPubSubOptions) Reset()

+ func (m *DynamicGroupRedisPubSubOptions) String() string

+ func (m *DynamicGroupRedisPubSubOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupRedisPubSubOptions) XXX_Size() int

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

+ type DynamicGroupRedisStreamsOptions struct

+ Args *args.RedisStreamsWriteArgs

+ XConn *args.RedisStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicGroupRedisStreamsOptions) ProtoMessage()

+ func (m *DynamicGroupRedisStreamsOptions) GetArgs() *args.RedisStreamsWriteArgs

+ func (m *DynamicGroupRedisStreamsOptions) GetXConn() *args.RedisStreamsConn

+ func (m *DynamicGroupRedisStreamsOptions) Reset()

+ func (m *DynamicGroupRedisStreamsOptions) String() string

+ func (m *DynamicGroupRedisStreamsOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicGroupRedisStreamsOptions) XXX_Size() int

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

+ type DynamicOptions struct

+ Activemq *DynamicGroupActiveMQOptions

+ ApiToken string

+ Awssns *DynamicGroupAWSSNSOptions

+ Awssqs *DynamicGroupAWSSQSOptions

+ AzureEventHub *DynamicGroupAzureEventHubOptions

+ AzureServiceBus *DynamicGroupAzureServiceBusOptions

+ GcpPubsub *DynamicGroupGCPPubSubOptions

+ Kafka *DynamicGroupKafkaOptions

+ KubemqQueue *DynamicGroupKubeMQQueueOptions

+ Mqtt *DynamicGroupMQTTOptions

+ Nats *DynamicGroupNatsOptions

+ NatsStreaming *DynamicGroupNatsStreamingOptions

+ Nsq *DynamicGroupNSQOptions

+ Rabbit *DynamicGroupRabbitOptions

+ RedisPubsub *DynamicGroupRedisPubSubOptions

+ RedisStreams *DynamicGroupRedisStreamsOptions

+ XGrpcAddress string

+ XGrpcInsecure bool

+ XGrpcTimeoutSeconds uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DynamicOptions) ProtoMessage()

+ func (m *DynamicOptions) GetActivemq() *DynamicGroupActiveMQOptions

+ func (m *DynamicOptions) GetApiToken() string

+ func (m *DynamicOptions) GetAwssns() *DynamicGroupAWSSNSOptions

+ func (m *DynamicOptions) GetAwssqs() *DynamicGroupAWSSQSOptions

+ func (m *DynamicOptions) GetAzureEventHub() *DynamicGroupAzureEventHubOptions

+ func (m *DynamicOptions) GetAzureServiceBus() *DynamicGroupAzureServiceBusOptions

+ func (m *DynamicOptions) GetGcpPubsub() *DynamicGroupGCPPubSubOptions

+ func (m *DynamicOptions) GetKafka() *DynamicGroupKafkaOptions

+ func (m *DynamicOptions) GetKubemqQueue() *DynamicGroupKubeMQQueueOptions

+ func (m *DynamicOptions) GetMqtt() *DynamicGroupMQTTOptions

+ func (m *DynamicOptions) GetNats() *DynamicGroupNatsOptions

+ func (m *DynamicOptions) GetNatsStreaming() *DynamicGroupNatsStreamingOptions

+ func (m *DynamicOptions) GetNsq() *DynamicGroupNSQOptions

+ func (m *DynamicOptions) GetRabbit() *DynamicGroupRabbitOptions

+ func (m *DynamicOptions) GetRedisPubsub() *DynamicGroupRedisPubSubOptions

+ func (m *DynamicOptions) GetRedisStreams() *DynamicGroupRedisStreamsOptions

+ func (m *DynamicOptions) GetXGrpcAddress() string

+ func (m *DynamicOptions) GetXGrpcInsecure() bool

+ func (m *DynamicOptions) GetXGrpcTimeoutSeconds() uint32

+ func (m *DynamicOptions) Reset()

+ func (m *DynamicOptions) String() string

+ func (m *DynamicOptions) XXX_DiscardUnknown()

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

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

+ func (m *DynamicOptions) XXX_Size() int

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

+ type HTTPDestination struct

+ Headers map[string]string

+ Url string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*HTTPDestination) ProtoMessage()

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

+ func (m *HTTPDestination) GetUrl() string

+ func (m *HTTPDestination) Reset()

+ func (m *HTTPDestination) String() string

+ func (m *HTTPDestination) XXX_DiscardUnknown()

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

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

+ func (m *HTTPDestination) XXX_Size() int

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

type ReadCLIOptions

+ Pretty bool

+ func (m *ReadCLIOptions) GetPretty() bool

type ReadOptions

+ ConvertOutput ConvertOption

+ func (m *ReadOptions) GetConvertOutput() ConvertOption

type WriteCLIOptions

+ InputStdin []string

+ func (m *WriteCLIOptions) GetInputStdin() []string

Sep 11, 2021

Changes in this version

+ type CLIOptions struct

+ Global *GlobalCLIOptions

+ Read *ReadOptions

+ Relay *RelayOptions

+ Server *ServerOptions

+ Write *WriteOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CLIOptions) ProtoMessage()

+ func (m *CLIOptions) GetGlobal() *GlobalCLIOptions

+ func (m *CLIOptions) GetRead() *ReadOptions

+ func (m *CLIOptions) GetRelay() *RelayOptions

+ func (m *CLIOptions) GetServer() *ServerOptions

+ func (m *CLIOptions) GetWrite() *WriteOptions

+ func (m *CLIOptions) Reset()

+ func (m *CLIOptions) String() string

+ func (m *CLIOptions) XXX_DiscardUnknown()

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

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

+ func (m *CLIOptions) XXX_Size() int

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

+ type GlobalCLIOptions struct

+ Debug bool

+ Quiet bool

+ Version bool

+ XAction string

+ XBackend string

+ XFullCommand string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GlobalCLIOptions) ProtoMessage()

+ func (m *GlobalCLIOptions) GetDebug() bool

+ func (m *GlobalCLIOptions) GetQuiet() bool

+ func (m *GlobalCLIOptions) GetVersion() bool

+ func (m *GlobalCLIOptions) GetXAction() string

+ func (m *GlobalCLIOptions) GetXBackend() string

+ func (m *GlobalCLIOptions) GetXFullCommand() string

+ func (m *GlobalCLIOptions) Reset()

+ func (m *GlobalCLIOptions) String() string

+ func (m *GlobalCLIOptions) XXX_DiscardUnknown()

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

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

+ func (m *GlobalCLIOptions) XXX_Size() int

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

Sep 10, 2021

Changes in this version

type WriteOptions

+ EncodeOptions *encoding.EncodeOptions

+ func (m *WriteOptions) GetEncodeOptions() *encoding.EncodeOptions

Sep 10, 2021

Changes in this version

+ var ConvertOption_name = map[int32]string

+ var ConvertOption_value = map[string]int32

+ type ConnectionOptions struct

+ Conn isConnectionOptions_Conn

+ Name string

+ Notes string

+ XId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ConnectionOptions) ProtoMessage()

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

+ func (m *ConnectionOptions) GetActiveMq() *args.ActiveMQConn

+ func (m *ConnectionOptions) GetAwssns() *args.AWSSNSConn

+ func (m *ConnectionOptions) GetAwssqs() *args.AWSSQSConn

+ func (m *ConnectionOptions) GetAzureEventHub() *args.AzureEventHubConn

+ func (m *ConnectionOptions) GetAzureServiceBus() *args.AzureServiceBusConn

+ func (m *ConnectionOptions) GetConn() isConnectionOptions_Conn

+ func (m *ConnectionOptions) GetGcpPubsub() *args.GCPPubSubConn

+ func (m *ConnectionOptions) GetKafka() *args.KafkaConn

+ func (m *ConnectionOptions) GetKubemqQueue() *args.KubeMQQueueConn

+ func (m *ConnectionOptions) GetMongo() *args.MongoConn

+ func (m *ConnectionOptions) GetMqtt() *args.MQTTConn

+ func (m *ConnectionOptions) GetName() string

+ func (m *ConnectionOptions) GetNats() *args.NatsConn

+ func (m *ConnectionOptions) GetNatsStreaming() *args.NatsStreamingConn

+ func (m *ConnectionOptions) GetNotes() string

+ func (m *ConnectionOptions) GetNsq() *args.NSQConn

+ func (m *ConnectionOptions) GetPostgres() *args.PostgresConn

+ func (m *ConnectionOptions) GetPulsar() *args.PulsarConn

+ func (m *ConnectionOptions) GetRabbit() *args.RabbitConn

+ func (m *ConnectionOptions) GetRabbitStreams() *args.RabbitStreamsConn

+ func (m *ConnectionOptions) GetRedisPubsub() *args.RedisPubSubConn

+ func (m *ConnectionOptions) GetRedisStreams() *args.RedisStreamsConn

+ func (m *ConnectionOptions) GetXId() string

+ func (m *ConnectionOptions) Reset()

+ func (m *ConnectionOptions) String() string

+ func (m *ConnectionOptions) XXX_DiscardUnknown()

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

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

+ func (m *ConnectionOptions) XXX_Size() int

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

+ type ConnectionOptions_ActiveMq struct

+ ActiveMq *args.ActiveMQConn

+ type ConnectionOptions_Awssns struct

+ Awssns *args.AWSSNSConn

+ type ConnectionOptions_Awssqs struct

+ Awssqs *args.AWSSQSConn

+ type ConnectionOptions_AzureEventHub struct

+ AzureEventHub *args.AzureEventHubConn

+ type ConnectionOptions_AzureServiceBus struct

+ AzureServiceBus *args.AzureServiceBusConn

+ type ConnectionOptions_GcpPubsub struct

+ GcpPubsub *args.GCPPubSubConn

+ type ConnectionOptions_Kafka struct

+ Kafka *args.KafkaConn

+ type ConnectionOptions_KubemqQueue struct

+ KubemqQueue *args.KubeMQQueueConn

+ type ConnectionOptions_Mongo struct

+ Mongo *args.MongoConn

+ type ConnectionOptions_Mqtt struct

+ Mqtt *args.MQTTConn

+ type ConnectionOptions_Nats struct

+ Nats *args.NatsConn

+ type ConnectionOptions_NatsStreaming struct

+ NatsStreaming *args.NatsStreamingConn

+ type ConnectionOptions_Nsq struct

+ Nsq *args.NSQConn

+ type ConnectionOptions_Postgres struct

+ Postgres *args.PostgresConn

+ type ConnectionOptions_Pulsar struct

+ Pulsar *args.PulsarConn

+ type ConnectionOptions_Rabbit struct

+ Rabbit *args.RabbitConn

+ type ConnectionOptions_RabbitStreams struct

+ RabbitStreams *args.RabbitStreamsConn

+ type ConnectionOptions_RedisPubsub struct

+ RedisPubsub *args.RedisPubSubConn

+ type ConnectionOptions_RedisStreams struct

+ RedisStreams *args.RedisStreamsConn

+ type ConvertOption int32

+ const ConvertOption_CONVERT_OPTION_BASE64

+ const ConvertOption_CONVERT_OPTION_GZIP

+ const ConvertOption_CONVERT_OPTION_UNSET

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

+ func (x ConvertOption) String() string

+ type IsConnectionOptions_Conn = isConnectionOptions_Conn

+ type ReadCLIOptions struct

+ ConvertOutput []ConvertOption

+ DisplayOffsetStats bool

+ StatsEnable bool

+ StatsReportIntervalSec int32

+ VerboseOutput bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadCLIOptions) ProtoMessage()

+ func (m *ReadCLIOptions) GetConvertOutput() []ConvertOption

+ func (m *ReadCLIOptions) GetDisplayOffsetStats() bool

+ func (m *ReadCLIOptions) GetStatsEnable() bool

+ func (m *ReadCLIOptions) GetStatsReportIntervalSec() int32

+ func (m *ReadCLIOptions) GetVerboseOutput() bool

+ func (m *ReadCLIOptions) Reset()

+ func (m *ReadCLIOptions) String() string

+ func (m *ReadCLIOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadCLIOptions) XXX_Size() int

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

+ type ReadGroupAWSSQSOptions struct

+ Args *args.AWSSQSReadArgs

+ XConn *args.AWSSQSConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupAWSSQSOptions) ProtoMessage()

+ func (m *ReadGroupAWSSQSOptions) GetArgs() *args.AWSSQSReadArgs

+ func (m *ReadGroupAWSSQSOptions) GetXConn() *args.AWSSQSConn

+ func (m *ReadGroupAWSSQSOptions) Reset()

+ func (m *ReadGroupAWSSQSOptions) String() string

+ func (m *ReadGroupAWSSQSOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupAWSSQSOptions) XXX_Size() int

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

+ type ReadGroupActiveMQOptions struct

+ Args *args.ActiveMQReadArgs

+ XConn *args.ActiveMQConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupActiveMQOptions) ProtoMessage()

+ func (m *ReadGroupActiveMQOptions) GetArgs() *args.ActiveMQReadArgs

+ func (m *ReadGroupActiveMQOptions) GetXConn() *args.ActiveMQConn

+ func (m *ReadGroupActiveMQOptions) Reset()

+ func (m *ReadGroupActiveMQOptions) String() string

+ func (m *ReadGroupActiveMQOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupActiveMQOptions) XXX_Size() int

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

+ type ReadGroupAzureEventHubOptions struct

+ Args *args.AzureEventHubReadArgs

+ XConn *args.AzureEventHubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupAzureEventHubOptions) ProtoMessage()

+ func (m *ReadGroupAzureEventHubOptions) GetArgs() *args.AzureEventHubReadArgs

+ func (m *ReadGroupAzureEventHubOptions) GetXConn() *args.AzureEventHubConn

+ func (m *ReadGroupAzureEventHubOptions) Reset()

+ func (m *ReadGroupAzureEventHubOptions) String() string

+ func (m *ReadGroupAzureEventHubOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupAzureEventHubOptions) XXX_Size() int

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

+ type ReadGroupAzureServiceBusOptions struct

+ Args *args.AzureServiceBusReadArgs

+ XConn *args.AzureServiceBusConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupAzureServiceBusOptions) ProtoMessage()

+ func (m *ReadGroupAzureServiceBusOptions) GetArgs() *args.AzureServiceBusReadArgs

+ func (m *ReadGroupAzureServiceBusOptions) GetXConn() *args.AzureServiceBusConn

+ func (m *ReadGroupAzureServiceBusOptions) Reset()

+ func (m *ReadGroupAzureServiceBusOptions) String() string

+ func (m *ReadGroupAzureServiceBusOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupAzureServiceBusOptions) XXX_Size() int

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

+ type ReadGroupGCPPubSubOptions struct

+ Args *args.GCPPubSubReadArgs

+ XConn *args.GCPPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupGCPPubSubOptions) ProtoMessage()

+ func (m *ReadGroupGCPPubSubOptions) GetArgs() *args.GCPPubSubReadArgs

+ func (m *ReadGroupGCPPubSubOptions) GetXConn() *args.GCPPubSubConn

+ func (m *ReadGroupGCPPubSubOptions) Reset()

+ func (m *ReadGroupGCPPubSubOptions) String() string

+ func (m *ReadGroupGCPPubSubOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupGCPPubSubOptions) XXX_Size() int

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

+ type ReadGroupKafkaOptions struct

+ Args *args.KafkaReadArgs

+ XConn *args.KafkaConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupKafkaOptions) ProtoMessage()

+ func (m *ReadGroupKafkaOptions) GetArgs() *args.KafkaReadArgs

+ func (m *ReadGroupKafkaOptions) GetXConn() *args.KafkaConn

+ func (m *ReadGroupKafkaOptions) Reset()

+ func (m *ReadGroupKafkaOptions) String() string

+ func (m *ReadGroupKafkaOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupKafkaOptions) XXX_Size() int

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

+ type ReadGroupKubeMQQueueOptions struct

+ Args *args.KubeMQQueueReadArgs

+ XConn *args.KubeMQQueueConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupKubeMQQueueOptions) ProtoMessage()

+ func (m *ReadGroupKubeMQQueueOptions) GetArgs() *args.KubeMQQueueReadArgs

+ func (m *ReadGroupKubeMQQueueOptions) GetXConn() *args.KubeMQQueueConn

+ func (m *ReadGroupKubeMQQueueOptions) Reset()

+ func (m *ReadGroupKubeMQQueueOptions) String() string

+ func (m *ReadGroupKubeMQQueueOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupKubeMQQueueOptions) XXX_Size() int

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

+ type ReadGroupMQTTOptions struct

+ Args *args.MQTTReadArgs

+ XConn *args.MQTTConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupMQTTOptions) ProtoMessage()

+ func (m *ReadGroupMQTTOptions) GetArgs() *args.MQTTReadArgs

+ func (m *ReadGroupMQTTOptions) GetXConn() *args.MQTTConn

+ func (m *ReadGroupMQTTOptions) Reset()

+ func (m *ReadGroupMQTTOptions) String() string

+ func (m *ReadGroupMQTTOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupMQTTOptions) XXX_Size() int

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

+ type ReadGroupMongoOptions struct

+ Args *args.MongoReadArgs

+ XConn *args.MongoConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupMongoOptions) ProtoMessage()

+ func (m *ReadGroupMongoOptions) GetArgs() *args.MongoReadArgs

+ func (m *ReadGroupMongoOptions) GetXConn() *args.MongoConn

+ func (m *ReadGroupMongoOptions) Reset()

+ func (m *ReadGroupMongoOptions) String() string

+ func (m *ReadGroupMongoOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupMongoOptions) XXX_Size() int

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

+ type ReadGroupNSQOptions struct

+ Args *args.NSQReadArgs

+ XConn *args.NSQConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupNSQOptions) ProtoMessage()

+ func (m *ReadGroupNSQOptions) GetArgs() *args.NSQReadArgs

+ func (m *ReadGroupNSQOptions) GetXConn() *args.NSQConn

+ func (m *ReadGroupNSQOptions) Reset()

+ func (m *ReadGroupNSQOptions) String() string

+ func (m *ReadGroupNSQOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupNSQOptions) XXX_Size() int

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

+ type ReadGroupNatsOptions struct

+ Args *args.NatsReadArgs

+ XConn *args.NatsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupNatsOptions) ProtoMessage()

+ func (m *ReadGroupNatsOptions) GetArgs() *args.NatsReadArgs

+ func (m *ReadGroupNatsOptions) GetXConn() *args.NatsConn

+ func (m *ReadGroupNatsOptions) Reset()

+ func (m *ReadGroupNatsOptions) String() string

+ func (m *ReadGroupNatsOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupNatsOptions) XXX_Size() int

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

+ type ReadGroupNatsStreamingOptions struct

+ Args *args.NatsStreamingReadArgs

+ XConn *args.NatsStreamingConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupNatsStreamingOptions) ProtoMessage()

+ func (m *ReadGroupNatsStreamingOptions) GetArgs() *args.NatsStreamingReadArgs

+ func (m *ReadGroupNatsStreamingOptions) GetXConn() *args.NatsStreamingConn

+ func (m *ReadGroupNatsStreamingOptions) Reset()

+ func (m *ReadGroupNatsStreamingOptions) String() string

+ func (m *ReadGroupNatsStreamingOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupNatsStreamingOptions) XXX_Size() int

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

+ type ReadGroupPostgresOptions struct

+ Args *args.PostgresReadArgs

+ XConn *args.PostgresConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupPostgresOptions) ProtoMessage()

+ func (m *ReadGroupPostgresOptions) GetArgs() *args.PostgresReadArgs

+ func (m *ReadGroupPostgresOptions) GetXConn() *args.PostgresConn

+ func (m *ReadGroupPostgresOptions) Reset()

+ func (m *ReadGroupPostgresOptions) String() string

+ func (m *ReadGroupPostgresOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupPostgresOptions) XXX_Size() int

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

+ type ReadGroupPulsarOptions struct

+ Args *args.PulsarReadArgs

+ XConn *args.PulsarConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupPulsarOptions) ProtoMessage()

+ func (m *ReadGroupPulsarOptions) GetArgs() *args.PulsarReadArgs

+ func (m *ReadGroupPulsarOptions) GetXConn() *args.PulsarConn

+ func (m *ReadGroupPulsarOptions) Reset()

+ func (m *ReadGroupPulsarOptions) String() string

+ func (m *ReadGroupPulsarOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupPulsarOptions) XXX_Size() int

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

+ type ReadGroupRabbitOptions struct

+ Args *args.RabbitReadArgs

+ XConn *args.RabbitConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupRabbitOptions) ProtoMessage()

+ func (m *ReadGroupRabbitOptions) GetArgs() *args.RabbitReadArgs

+ func (m *ReadGroupRabbitOptions) GetXConn() *args.RabbitConn

+ func (m *ReadGroupRabbitOptions) Reset()

+ func (m *ReadGroupRabbitOptions) String() string

+ func (m *ReadGroupRabbitOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupRabbitOptions) XXX_Size() int

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

+ type ReadGroupRabbitStreamsOptions struct

+ Args *args.RabbitStreamsReadArgs

+ XConn *args.RabbitStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupRabbitStreamsOptions) ProtoMessage()

+ func (m *ReadGroupRabbitStreamsOptions) GetArgs() *args.RabbitStreamsReadArgs

+ func (m *ReadGroupRabbitStreamsOptions) GetXConn() *args.RabbitStreamsConn

+ func (m *ReadGroupRabbitStreamsOptions) Reset()

+ func (m *ReadGroupRabbitStreamsOptions) String() string

+ func (m *ReadGroupRabbitStreamsOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupRabbitStreamsOptions) XXX_Size() int

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

+ type ReadGroupRedisPubSubOptions struct

+ Args *args.RedisPubSubReadArgs

+ XConn *args.RedisPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupRedisPubSubOptions) ProtoMessage()

+ func (m *ReadGroupRedisPubSubOptions) GetArgs() *args.RedisPubSubReadArgs

+ func (m *ReadGroupRedisPubSubOptions) GetXConn() *args.RedisPubSubConn

+ func (m *ReadGroupRedisPubSubOptions) Reset()

+ func (m *ReadGroupRedisPubSubOptions) String() string

+ func (m *ReadGroupRedisPubSubOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupRedisPubSubOptions) XXX_Size() int

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

+ type ReadGroupRedisStreamsOptions struct

+ Args *args.RedisStreamsReadArgs

+ XConn *args.RedisStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadGroupRedisStreamsOptions) ProtoMessage()

+ func (m *ReadGroupRedisStreamsOptions) GetArgs() *args.RedisStreamsReadArgs

+ func (m *ReadGroupRedisStreamsOptions) GetXConn() *args.RedisStreamsConn

+ func (m *ReadGroupRedisStreamsOptions) Reset()

+ func (m *ReadGroupRedisStreamsOptions) String() string

+ func (m *ReadGroupRedisStreamsOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadGroupRedisStreamsOptions) XXX_Size() int

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

+ type ReadOptions struct

+ Activemq *ReadGroupActiveMQOptions

+ Awssqs *ReadGroupAWSSQSOptions

+ AzureEventHub *ReadGroupAzureEventHubOptions

+ AzureServiceBus *ReadGroupAzureServiceBusOptions

+ ConnectionId string

+ Continuous bool

+ DecodeOptions *encoding.DecodeOptions

+ GcpPubsub *ReadGroupGCPPubSubOptions

+ Kafka *ReadGroupKafkaOptions

+ KubemqQueue *ReadGroupKubeMQQueueOptions

+ Mongo *ReadGroupMongoOptions

+ Mqtt *ReadGroupMQTTOptions

+ Name string

+ Nats *ReadGroupNatsOptions

+ NatsStreaming *ReadGroupNatsStreamingOptions

+ Nsq *ReadGroupNSQOptions

+ Postgres *ReadGroupPostgresOptions

+ Pulsar *ReadGroupPulsarOptions

+ Rabbit *ReadGroupRabbitOptions

+ RabbitStreams *ReadGroupRabbitStreamsOptions

+ RedisPubsub *ReadGroupRedisPubSubOptions

+ RedisStreams *ReadGroupRedisStreamsOptions

+ SampleOptions *ReadSampleOptions

+ XActive bool

+ XCliOptions *ReadCLIOptions

+ XId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadOptions) ProtoMessage()

+ func (m *ReadOptions) GetActivemq() *ReadGroupActiveMQOptions

+ func (m *ReadOptions) GetAwssqs() *ReadGroupAWSSQSOptions

+ func (m *ReadOptions) GetAzureEventHub() *ReadGroupAzureEventHubOptions

+ func (m *ReadOptions) GetAzureServiceBus() *ReadGroupAzureServiceBusOptions

+ func (m *ReadOptions) GetConnectionId() string

+ func (m *ReadOptions) GetContinuous() bool

+ func (m *ReadOptions) GetDecodeOptions() *encoding.DecodeOptions

+ func (m *ReadOptions) GetGcpPubsub() *ReadGroupGCPPubSubOptions

+ func (m *ReadOptions) GetKafka() *ReadGroupKafkaOptions

+ func (m *ReadOptions) GetKubemqQueue() *ReadGroupKubeMQQueueOptions

+ func (m *ReadOptions) GetMongo() *ReadGroupMongoOptions

+ func (m *ReadOptions) GetMqtt() *ReadGroupMQTTOptions

+ func (m *ReadOptions) GetName() string

+ func (m *ReadOptions) GetNats() *ReadGroupNatsOptions

+ func (m *ReadOptions) GetNatsStreaming() *ReadGroupNatsStreamingOptions

+ func (m *ReadOptions) GetNsq() *ReadGroupNSQOptions

+ func (m *ReadOptions) GetPostgres() *ReadGroupPostgresOptions

+ func (m *ReadOptions) GetPulsar() *ReadGroupPulsarOptions

+ func (m *ReadOptions) GetRabbit() *ReadGroupRabbitOptions

+ func (m *ReadOptions) GetRabbitStreams() *ReadGroupRabbitStreamsOptions

+ func (m *ReadOptions) GetRedisPubsub() *ReadGroupRedisPubSubOptions

+ func (m *ReadOptions) GetRedisStreams() *ReadGroupRedisStreamsOptions

+ func (m *ReadOptions) GetSampleOptions() *ReadSampleOptions

+ func (m *ReadOptions) GetXActive() bool

+ func (m *ReadOptions) GetXCliOptions() *ReadCLIOptions

+ func (m *ReadOptions) GetXId() string

+ func (m *ReadOptions) Reset()

+ func (m *ReadOptions) String() string

+ func (m *ReadOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadOptions) XXX_Size() int

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

+ type ReadSampleOptions struct

+ SampleIntervalSeconds uint32

+ SampleRate uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadSampleOptions) ProtoMessage()

+ func (m *ReadSampleOptions) GetSampleIntervalSeconds() uint32

+ func (m *ReadSampleOptions) GetSampleRate() uint32

+ func (m *ReadSampleOptions) Reset()

+ func (m *ReadSampleOptions) String() string

+ func (m *ReadSampleOptions) XXX_DiscardUnknown()

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

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

+ func (m *ReadSampleOptions) XXX_Size() int

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

+ type RelayCLIOptions struct

+ HttpListenAddress string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayCLIOptions) ProtoMessage()

+ func (m *RelayCLIOptions) GetHttpListenAddress() string

+ func (m *RelayCLIOptions) Reset()

+ func (m *RelayCLIOptions) String() string

+ func (m *RelayCLIOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayCLIOptions) XXX_Size() int

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

+ type RelayGroupAWSSQSOptions struct

+ Args *args.AWSSQSRelayArgs

+ XConn *args.AWSSQSConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupAWSSQSOptions) ProtoMessage()

+ func (m *RelayGroupAWSSQSOptions) GetArgs() *args.AWSSQSRelayArgs

+ func (m *RelayGroupAWSSQSOptions) GetXConn() *args.AWSSQSConn

+ func (m *RelayGroupAWSSQSOptions) Reset()

+ func (m *RelayGroupAWSSQSOptions) String() string

+ func (m *RelayGroupAWSSQSOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupAWSSQSOptions) XXX_Size() int

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

+ type RelayGroupAzureServiceBusOptions struct

+ Args *args.AzureServiceBusReadArgs

+ XConn *args.AzureServiceBusConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupAzureServiceBusOptions) ProtoMessage()

+ func (m *RelayGroupAzureServiceBusOptions) GetArgs() *args.AzureServiceBusReadArgs

+ func (m *RelayGroupAzureServiceBusOptions) GetXConn() *args.AzureServiceBusConn

+ func (m *RelayGroupAzureServiceBusOptions) Reset()

+ func (m *RelayGroupAzureServiceBusOptions) String() string

+ func (m *RelayGroupAzureServiceBusOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupAzureServiceBusOptions) XXX_Size() int

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

+ type RelayGroupGCPPubSubOptions struct

+ Args *args.GCPPubSubReadArgs

+ XConn *args.GCPPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupGCPPubSubOptions) ProtoMessage()

+ func (m *RelayGroupGCPPubSubOptions) GetArgs() *args.GCPPubSubReadArgs

+ func (m *RelayGroupGCPPubSubOptions) GetXConn() *args.GCPPubSubConn

+ func (m *RelayGroupGCPPubSubOptions) Reset()

+ func (m *RelayGroupGCPPubSubOptions) String() string

+ func (m *RelayGroupGCPPubSubOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupGCPPubSubOptions) XXX_Size() int

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

+ type RelayGroupKafkaOptions struct

+ Args *args.KafkaRelayArgs

+ XConn *args.KafkaConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupKafkaOptions) ProtoMessage()

+ func (m *RelayGroupKafkaOptions) GetArgs() *args.KafkaRelayArgs

+ func (m *RelayGroupKafkaOptions) GetXConn() *args.KafkaConn

+ func (m *RelayGroupKafkaOptions) Reset()

+ func (m *RelayGroupKafkaOptions) String() string

+ func (m *RelayGroupKafkaOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupKafkaOptions) XXX_Size() int

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

+ type RelayGroupKubeMQQueueOptions struct

+ Args *args.KubeMQQueueReadArgs

+ XConn *args.KubeMQQueueConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupKubeMQQueueOptions) ProtoMessage()

+ func (m *RelayGroupKubeMQQueueOptions) GetArgs() *args.KubeMQQueueReadArgs

+ func (m *RelayGroupKubeMQQueueOptions) GetXConn() *args.KubeMQQueueConn

+ func (m *RelayGroupKubeMQQueueOptions) Reset()

+ func (m *RelayGroupKubeMQQueueOptions) String() string

+ func (m *RelayGroupKubeMQQueueOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupKubeMQQueueOptions) XXX_Size() int

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

+ type RelayGroupMQTTOptions struct

+ Args *args.MQTTReadArgs

+ XConn *args.MQTTConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupMQTTOptions) ProtoMessage()

+ func (m *RelayGroupMQTTOptions) GetArgs() *args.MQTTReadArgs

+ func (m *RelayGroupMQTTOptions) GetXConn() *args.MQTTConn

+ func (m *RelayGroupMQTTOptions) Reset()

+ func (m *RelayGroupMQTTOptions) String() string

+ func (m *RelayGroupMQTTOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupMQTTOptions) XXX_Size() int

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

+ type RelayGroupMongoOptions struct

+ Args *args.MongoReadArgs

+ XConn *args.MongoConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupMongoOptions) ProtoMessage()

+ func (m *RelayGroupMongoOptions) GetArgs() *args.MongoReadArgs

+ func (m *RelayGroupMongoOptions) GetXConn() *args.MongoConn

+ func (m *RelayGroupMongoOptions) Reset()

+ func (m *RelayGroupMongoOptions) String() string

+ func (m *RelayGroupMongoOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupMongoOptions) XXX_Size() int

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

+ type RelayGroupNSQOptions struct

+ Args *args.NSQReadArgs

+ XConn *args.NSQConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupNSQOptions) ProtoMessage()

+ func (m *RelayGroupNSQOptions) GetArgs() *args.NSQReadArgs

+ func (m *RelayGroupNSQOptions) GetXConn() *args.NSQConn

+ func (m *RelayGroupNSQOptions) Reset()

+ func (m *RelayGroupNSQOptions) String() string

+ func (m *RelayGroupNSQOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupNSQOptions) XXX_Size() int

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

+ type RelayGroupPostgresOptions struct

+ Args *args.PostgresReadArgs

+ XConn *args.PostgresConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupPostgresOptions) ProtoMessage()

+ func (m *RelayGroupPostgresOptions) GetArgs() *args.PostgresReadArgs

+ func (m *RelayGroupPostgresOptions) GetXConn() *args.PostgresConn

+ func (m *RelayGroupPostgresOptions) Reset()

+ func (m *RelayGroupPostgresOptions) String() string

+ func (m *RelayGroupPostgresOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupPostgresOptions) XXX_Size() int

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

+ type RelayGroupRabbitOptions struct

+ Args *args.RabbitReadArgs

+ XConn *args.RabbitConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupRabbitOptions) ProtoMessage()

+ func (m *RelayGroupRabbitOptions) GetArgs() *args.RabbitReadArgs

+ func (m *RelayGroupRabbitOptions) GetXConn() *args.RabbitConn

+ func (m *RelayGroupRabbitOptions) Reset()

+ func (m *RelayGroupRabbitOptions) String() string

+ func (m *RelayGroupRabbitOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupRabbitOptions) XXX_Size() int

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

+ type RelayGroupRedisPubSubOptions struct

+ Args *args.RedisPubSubReadArgs

+ XConn *args.RedisPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupRedisPubSubOptions) ProtoMessage()

+ func (m *RelayGroupRedisPubSubOptions) GetArgs() *args.RedisPubSubReadArgs

+ func (m *RelayGroupRedisPubSubOptions) GetXConn() *args.RedisPubSubConn

+ func (m *RelayGroupRedisPubSubOptions) Reset()

+ func (m *RelayGroupRedisPubSubOptions) String() string

+ func (m *RelayGroupRedisPubSubOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupRedisPubSubOptions) XXX_Size() int

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

+ type RelayGroupRedisStreamsOptions struct

+ Args *args.RedisStreamsReadArgs

+ XConn *args.RedisStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayGroupRedisStreamsOptions) ProtoMessage()

+ func (m *RelayGroupRedisStreamsOptions) GetArgs() *args.RedisStreamsReadArgs

+ func (m *RelayGroupRedisStreamsOptions) GetXConn() *args.RedisStreamsConn

+ func (m *RelayGroupRedisStreamsOptions) Reset()

+ func (m *RelayGroupRedisStreamsOptions) String() string

+ func (m *RelayGroupRedisStreamsOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayGroupRedisStreamsOptions) XXX_Size() int

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

+ type RelayOptions struct

+ Awssqs *RelayGroupAWSSQSOptions

+ AzureServiceBus *RelayGroupAzureServiceBusOptions

+ BatchMaxRetry int32

+ BatchSize int32

+ CollectionToken string

+ ConnectionId string

+ GcpPubsub *RelayGroupGCPPubSubOptions

+ Kafka *RelayGroupKafkaOptions

+ KubemqQueue *RelayGroupKubeMQQueueOptions

+ Mongo *RelayGroupMongoOptions

+ Mqtt *RelayGroupMQTTOptions

+ Nsq *RelayGroupNSQOptions

+ NumWorkers int32

+ Postgres *RelayGroupPostgresOptions

+ Rabbit *RelayGroupRabbitOptions

+ RedisPubsub *RelayGroupRedisPubSubOptions

+ RedisStreams *RelayGroupRedisStreamsOptions

+ XBatchshGrpcAddress string

+ XBatchshGrpcDisableTls bool

+ XBatchshGrpcTimeoutSeconds int32

+ XCliOptions *RelayCLIOptions

+ XRelayId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RelayOptions) ProtoMessage()

+ func (m *RelayOptions) GetAwssqs() *RelayGroupAWSSQSOptions

+ func (m *RelayOptions) GetAzureServiceBus() *RelayGroupAzureServiceBusOptions

+ func (m *RelayOptions) GetBatchMaxRetry() int32

+ func (m *RelayOptions) GetBatchSize() int32

+ func (m *RelayOptions) GetCollectionToken() string

+ func (m *RelayOptions) GetConnectionId() string

+ func (m *RelayOptions) GetGcpPubsub() *RelayGroupGCPPubSubOptions

+ func (m *RelayOptions) GetKafka() *RelayGroupKafkaOptions

+ func (m *RelayOptions) GetKubemqQueue() *RelayGroupKubeMQQueueOptions

+ func (m *RelayOptions) GetMongo() *RelayGroupMongoOptions

+ func (m *RelayOptions) GetMqtt() *RelayGroupMQTTOptions

+ func (m *RelayOptions) GetNsq() *RelayGroupNSQOptions

+ func (m *RelayOptions) GetNumWorkers() int32

+ func (m *RelayOptions) GetPostgres() *RelayGroupPostgresOptions

+ func (m *RelayOptions) GetRabbit() *RelayGroupRabbitOptions

+ func (m *RelayOptions) GetRedisPubsub() *RelayGroupRedisPubSubOptions

+ func (m *RelayOptions) GetRedisStreams() *RelayGroupRedisStreamsOptions

+ func (m *RelayOptions) GetXBatchshGrpcAddress() string

+ func (m *RelayOptions) GetXBatchshGrpcDisableTls() bool

+ func (m *RelayOptions) GetXBatchshGrpcTimeoutSeconds() int32

+ func (m *RelayOptions) GetXCliOptions() *RelayCLIOptions

+ func (m *RelayOptions) GetXRelayId() string

+ func (m *RelayOptions) Reset()

+ func (m *RelayOptions) String() string

+ func (m *RelayOptions) XXX_DiscardUnknown()

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

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

+ func (m *RelayOptions) XXX_Size() int

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

+ type ServerOptions struct

+ AdvertiseClientUrl string

+ AdvertisePeerUrl string

+ AuthToken string

+ ClusterId string

+ GrpcListenAddress string

+ InitialCluster string

+ ListenerClientUrl string

+ ListenerPeerUrl string

+ NodeId string

+ PeerToken string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ServerOptions) ProtoMessage()

+ func (m *ServerOptions) GetAdvertiseClientUrl() string

+ func (m *ServerOptions) GetAdvertisePeerUrl() string

+ func (m *ServerOptions) GetAuthToken() string

+ func (m *ServerOptions) GetClusterId() string

+ func (m *ServerOptions) GetGrpcListenAddress() string

+ func (m *ServerOptions) GetInitialCluster() string

+ func (m *ServerOptions) GetListenerClientUrl() string

+ func (m *ServerOptions) GetListenerPeerUrl() string

+ func (m *ServerOptions) GetNodeId() string

+ func (m *ServerOptions) GetPeerToken() string

+ func (m *ServerOptions) Reset()

+ func (m *ServerOptions) String() string

+ func (m *ServerOptions) XXX_DiscardUnknown()

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

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

+ func (m *ServerOptions) XXX_Size() int

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

+ type WriteCLIOptions struct

+ InputAsJsonArray bool

+ InputFile string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WriteCLIOptions) ProtoMessage()

+ func (m *WriteCLIOptions) GetInputAsJsonArray() bool

+ func (m *WriteCLIOptions) GetInputFile() string

+ func (m *WriteCLIOptions) Reset()

+ func (m *WriteCLIOptions) String() string

+ func (m *WriteCLIOptions) XXX_DiscardUnknown()

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

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

+ func (m *WriteCLIOptions) XXX_Size() int

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

+ type WriteGroupAWSSNSOptions struct

+ Args *args.AWSSNSWriteArgs

+ XConn *args.AWSSNSConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WriteGroupAWSSNSOptions) ProtoMessage()

+ func (m *WriteGroupAWSSNSOptions) GetArgs() *args.AWSSNSWriteArgs

+ func (m *WriteGroupAWSSNSOptions) GetXConn() *args.AWSSNSConn

+ func (m *WriteGroupAWSSNSOptions) Reset()

+ func (m *WriteGroupAWSSNSOptions) String() string

+ func (m *WriteGroupAWSSNSOptions) XXX_DiscardUnknown()

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

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

+ func (m *WriteGroupAWSSNSOptions) XXX_Size() int

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

+ type WriteGroupAWSSQSOptions struct

+ Args *args.AWSSQSWriteArgs

+ XConn *args.AWSSQSConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WriteGroupAWSSQSOptions) ProtoMessage()

+ func (m *WriteGroupAWSSQSOptions) GetArgs() *args.AWSSQSWriteArgs

+ func (m *WriteGroupAWSSQSOptions) GetXConn() *args.AWSSQSConn

+ func (m *WriteGroupAWSSQSOptions) Reset()

+ func (m *WriteGroupAWSSQSOptions) String() string

+ func (m *WriteGroupAWSSQSOptions) XXX_DiscardUnknown()

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

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

+ func (m *WriteGroupAWSSQSOptions) XXX_Size() int

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

+ type WriteGroupActiveMQOptions struct

+ Args *args.ActiveMQWriteArgs

+ XConn *args.ActiveMQConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WriteGroupActiveMQOptions) ProtoMessage()

+ func (m *WriteGroupActiveMQOptions) GetArgs() *args.ActiveMQWriteArgs

+ func (m *WriteGroupActiveMQOptions) GetXConn() *args.ActiveMQConn

+ func (m *WriteGroupActiveMQOptions) Reset()

+ func (m *WriteGroupActiveMQOptions) String() string

+ func (m *WriteGroupActiveMQOptions) XXX_DiscardUnknown()

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

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

+ func (m *WriteGroupActiveMQOptions) XXX_Size() int

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

+ type WriteGroupAzureEventHubOptions struct

+ Args *args.AzureEventHubWriteArgs

+ XConn *args.AzureEventHubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WriteGroupAzureEventHubOptions) ProtoMessage()

+ func (m *WriteGroupAzureEventHubOptions) GetArgs() *args.AzureEventHubWriteArgs

+ func (m *WriteGroupAzureEventHubOptions) GetXConn() *args.AzureEventHubConn

+ func (m *WriteGroupAzureEventHubOptions) Reset()

+ func (m *WriteGroupAzureEventHubOptions) String() string

+ func (m *WriteGroupAzureEventHubOptions) XXX_DiscardUnknown()

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

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

+ func (m *WriteGroupAzureEventHubOptions) XXX_Size() int

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

+ type WriteGroupAzureServiceBusOptions struct

+ Args *args.AzureServiceBusWriteArgs

+ XConn *args.AzureServiceBusConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WriteGroupAzureServiceBusOptions) ProtoMessage()

+ func (m *WriteGroupAzureServiceBusOptions) GetArgs() *args.AzureServiceBusWriteArgs

+ func (m *WriteGroupAzureServiceBusOptions) GetXConn() *args.AzureServiceBusConn

+ func (m *WriteGroupAzureServiceBusOptions) Reset()

+ func (m *WriteGroupAzureServiceBusOptions) String() string

+ func (m *WriteGroupAzureServiceBusOptions) XXX_DiscardUnknown()

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

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

+ func (m *WriteGroupAzureServiceBusOptions) XXX_Size() int

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

+ type WriteGroupGCPPubSubOptions struct

+ Args *args.GCPPubSubWriteArgs

+ XConn *args.GCPPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WriteGroupGCPPubSubOptions) ProtoMessage()

+ func (m *WriteGroupGCPPubSubOptions) GetArgs() *args.GCPPubSubWriteArgs

+ func (m *WriteGroupGCPPubSubOptions) GetXConn() *args.GCPPubSubConn

+ func (m *WriteGroupGCPPubSubOptions) Reset()

+ func (m *WriteGroupGCPPubSubOptions) String() string

+ func (m *WriteGroupGCPPubSubOptions) XXX_DiscardUnknown()

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

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

+ func (m *WriteGroupGCPPubSubOptions) XXX_Size() int

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

+ type WriteGroupKafkaOptions struct

+ Args *args.KafkaWriteArgs

+ XConn *args.KafkaConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WriteGroupKafkaOptions) ProtoMessage()

+ func (m *WriteGroupKafkaOptions) GetArgs() *args.KafkaWriteArgs

+ func (m *WriteGroupKafkaOptions) GetXConn() *args.KafkaConn

+ func (m *WriteGroupKafkaOptions) Reset()

+ func (m *WriteGroupKafkaOptions) String() string

+ func (m *WriteGroupKafkaOptions) XXX_DiscardUnknown()

+ func (m *WriteGroupKafkaOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteGroupKafkaOptions) XXX_Merge(src proto.Message)

+ func (m *WriteGroupKafkaOptions) XXX_Size() int

+ func (m *WriteGroupKafkaOptions) XXX_Unmarshal(b []byte) error

+ type WriteGroupKubeMQQueueOptions struct

+ Args *args.KubeMQQueueWriteArgs

+ XConn *args.KubeMQQueueConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteGroupKubeMQQueueOptions) Descriptor() ([]byte, []int)

+ func (*WriteGroupKubeMQQueueOptions) ProtoMessage()

+ func (m *WriteGroupKubeMQQueueOptions) GetArgs() *args.KubeMQQueueWriteArgs

+ func (m *WriteGroupKubeMQQueueOptions) GetXConn() *args.KubeMQQueueConn

+ func (m *WriteGroupKubeMQQueueOptions) Reset()

+ func (m *WriteGroupKubeMQQueueOptions) String() string

+ func (m *WriteGroupKubeMQQueueOptions) XXX_DiscardUnknown()

+ func (m *WriteGroupKubeMQQueueOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteGroupKubeMQQueueOptions) XXX_Merge(src proto.Message)

+ func (m *WriteGroupKubeMQQueueOptions) XXX_Size() int

+ func (m *WriteGroupKubeMQQueueOptions) XXX_Unmarshal(b []byte) error

+ type WriteGroupMQTTOptions struct

+ Args *args.MQTTWriteArgs

+ XConn *args.MQTTConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteGroupMQTTOptions) Descriptor() ([]byte, []int)

+ func (*WriteGroupMQTTOptions) ProtoMessage()

+ func (m *WriteGroupMQTTOptions) GetArgs() *args.MQTTWriteArgs

+ func (m *WriteGroupMQTTOptions) GetXConn() *args.MQTTConn

+ func (m *WriteGroupMQTTOptions) Reset()

+ func (m *WriteGroupMQTTOptions) String() string

+ func (m *WriteGroupMQTTOptions) XXX_DiscardUnknown()

+ func (m *WriteGroupMQTTOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteGroupMQTTOptions) XXX_Merge(src proto.Message)

+ func (m *WriteGroupMQTTOptions) XXX_Size() int

+ func (m *WriteGroupMQTTOptions) XXX_Unmarshal(b []byte) error

+ type WriteGroupNSQOptions struct

+ Args *args.NSQWriteArgs

+ XConn *args.NSQConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteGroupNSQOptions) Descriptor() ([]byte, []int)

+ func (*WriteGroupNSQOptions) ProtoMessage()

+ func (m *WriteGroupNSQOptions) GetArgs() *args.NSQWriteArgs

+ func (m *WriteGroupNSQOptions) GetXConn() *args.NSQConn

+ func (m *WriteGroupNSQOptions) Reset()

+ func (m *WriteGroupNSQOptions) String() string

+ func (m *WriteGroupNSQOptions) XXX_DiscardUnknown()

+ func (m *WriteGroupNSQOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteGroupNSQOptions) XXX_Merge(src proto.Message)

+ func (m *WriteGroupNSQOptions) XXX_Size() int

+ func (m *WriteGroupNSQOptions) XXX_Unmarshal(b []byte) error

+ type WriteGroupNatsOptions struct

+ Args *args.NatsWriteArgs

+ XConn *args.NatsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteGroupNatsOptions) Descriptor() ([]byte, []int)

+ func (*WriteGroupNatsOptions) ProtoMessage()

+ func (m *WriteGroupNatsOptions) GetArgs() *args.NatsWriteArgs

+ func (m *WriteGroupNatsOptions) GetXConn() *args.NatsConn

+ func (m *WriteGroupNatsOptions) Reset()

+ func (m *WriteGroupNatsOptions) String() string

+ func (m *WriteGroupNatsOptions) XXX_DiscardUnknown()

+ func (m *WriteGroupNatsOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteGroupNatsOptions) XXX_Merge(src proto.Message)

+ func (m *WriteGroupNatsOptions) XXX_Size() int

+ func (m *WriteGroupNatsOptions) XXX_Unmarshal(b []byte) error

+ type WriteGroupNatsStreamingOptions struct

+ Args *args.NatsStreamingWriteArgs

+ XConn *args.NatsStreamingConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteGroupNatsStreamingOptions) Descriptor() ([]byte, []int)

+ func (*WriteGroupNatsStreamingOptions) ProtoMessage()

+ func (m *WriteGroupNatsStreamingOptions) GetArgs() *args.NatsStreamingWriteArgs

+ func (m *WriteGroupNatsStreamingOptions) GetXConn() *args.NatsStreamingConn

+ func (m *WriteGroupNatsStreamingOptions) Reset()

+ func (m *WriteGroupNatsStreamingOptions) String() string

+ func (m *WriteGroupNatsStreamingOptions) XXX_DiscardUnknown()

+ func (m *WriteGroupNatsStreamingOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteGroupNatsStreamingOptions) XXX_Merge(src proto.Message)

+ func (m *WriteGroupNatsStreamingOptions) XXX_Size() int

+ func (m *WriteGroupNatsStreamingOptions) XXX_Unmarshal(b []byte) error

+ type WriteGroupPulsarOptions struct

+ Args *args.PulsarWriteArgs

+ XConn *args.PulsarConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteGroupPulsarOptions) Descriptor() ([]byte, []int)

+ func (*WriteGroupPulsarOptions) ProtoMessage()

+ func (m *WriteGroupPulsarOptions) GetArgs() *args.PulsarWriteArgs

+ func (m *WriteGroupPulsarOptions) GetXConn() *args.PulsarConn

+ func (m *WriteGroupPulsarOptions) Reset()

+ func (m *WriteGroupPulsarOptions) String() string

+ func (m *WriteGroupPulsarOptions) XXX_DiscardUnknown()

+ func (m *WriteGroupPulsarOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteGroupPulsarOptions) XXX_Merge(src proto.Message)

+ func (m *WriteGroupPulsarOptions) XXX_Size() int

+ func (m *WriteGroupPulsarOptions) XXX_Unmarshal(b []byte) error

+ type WriteGroupRabbitOptions struct

+ Args *args.RabbitWriteArgs

+ XConn *args.RabbitConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteGroupRabbitOptions) Descriptor() ([]byte, []int)

+ func (*WriteGroupRabbitOptions) ProtoMessage()

+ func (m *WriteGroupRabbitOptions) GetArgs() *args.RabbitWriteArgs

+ func (m *WriteGroupRabbitOptions) GetXConn() *args.RabbitConn

+ func (m *WriteGroupRabbitOptions) Reset()

+ func (m *WriteGroupRabbitOptions) String() string

+ func (m *WriteGroupRabbitOptions) XXX_DiscardUnknown()

+ func (m *WriteGroupRabbitOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteGroupRabbitOptions) XXX_Merge(src proto.Message)

+ func (m *WriteGroupRabbitOptions) XXX_Size() int

+ func (m *WriteGroupRabbitOptions) XXX_Unmarshal(b []byte) error

+ type WriteGroupRabbitStreamsOptions struct

+ Args *args.RabbitStreamsWriteArgs

+ XConn *args.RabbitStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteGroupRabbitStreamsOptions) Descriptor() ([]byte, []int)

+ func (*WriteGroupRabbitStreamsOptions) ProtoMessage()

+ func (m *WriteGroupRabbitStreamsOptions) GetArgs() *args.RabbitStreamsWriteArgs

+ func (m *WriteGroupRabbitStreamsOptions) GetXConn() *args.RabbitStreamsConn

+ func (m *WriteGroupRabbitStreamsOptions) Reset()

+ func (m *WriteGroupRabbitStreamsOptions) String() string

+ func (m *WriteGroupRabbitStreamsOptions) XXX_DiscardUnknown()

+ func (m *WriteGroupRabbitStreamsOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteGroupRabbitStreamsOptions) XXX_Merge(src proto.Message)

+ func (m *WriteGroupRabbitStreamsOptions) XXX_Size() int

+ func (m *WriteGroupRabbitStreamsOptions) XXX_Unmarshal(b []byte) error

+ type WriteGroupRedisPubSubOptions struct

+ Args *args.RedisPubSubWriteArgs

+ XConn *args.RedisPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteGroupRedisPubSubOptions) Descriptor() ([]byte, []int)

+ func (*WriteGroupRedisPubSubOptions) ProtoMessage()

+ func (m *WriteGroupRedisPubSubOptions) GetArgs() *args.RedisPubSubWriteArgs

+ func (m *WriteGroupRedisPubSubOptions) GetXConn() *args.RedisPubSubConn

+ func (m *WriteGroupRedisPubSubOptions) Reset()

+ func (m *WriteGroupRedisPubSubOptions) String() string

+ func (m *WriteGroupRedisPubSubOptions) XXX_DiscardUnknown()

+ func (m *WriteGroupRedisPubSubOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteGroupRedisPubSubOptions) XXX_Merge(src proto.Message)

+ func (m *WriteGroupRedisPubSubOptions) XXX_Size() int

+ func (m *WriteGroupRedisPubSubOptions) XXX_Unmarshal(b []byte) error

+ type WriteGroupRedisStreamsOptions struct

+ Args *args.RedisStreamsWriteArgs

+ XConn *args.RedisStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteGroupRedisStreamsOptions) Descriptor() ([]byte, []int)

+ func (*WriteGroupRedisStreamsOptions) ProtoMessage()

+ func (m *WriteGroupRedisStreamsOptions) GetArgs() *args.RedisStreamsWriteArgs

+ func (m *WriteGroupRedisStreamsOptions) GetXConn() *args.RedisStreamsConn

+ func (m *WriteGroupRedisStreamsOptions) Reset()

+ func (m *WriteGroupRedisStreamsOptions) String() string

+ func (m *WriteGroupRedisStreamsOptions) XXX_DiscardUnknown()

+ func (m *WriteGroupRedisStreamsOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteGroupRedisStreamsOptions) XXX_Merge(src proto.Message)

+ func (m *WriteGroupRedisStreamsOptions) XXX_Size() int

+ func (m *WriteGroupRedisStreamsOptions) XXX_Unmarshal(b []byte) error

+ type WriteOptions struct

+ Activemq *WriteGroupActiveMQOptions

+ Awssns *WriteGroupAWSSNSOptions

+ Awssqs *WriteGroupAWSSQSOptions

+ AzureEventHub *WriteGroupAzureEventHubOptions

+ AzureServiceBus *WriteGroupAzureServiceBusOptions

+ ConnectionId string

+ GcpPubsub *WriteGroupGCPPubSubOptions

+ Kafka *WriteGroupKafkaOptions

+ KubemqQueue *WriteGroupKubeMQQueueOptions

+ Mqtt *WriteGroupMQTTOptions

+ Nats *WriteGroupNatsOptions

+ NatsStreaming *WriteGroupNatsStreamingOptions

+ Nsq *WriteGroupNSQOptions

+ Pulsar *WriteGroupPulsarOptions

+ Rabbit *WriteGroupRabbitOptions

+ RabbitStreams *WriteGroupRabbitStreamsOptions

+ Record *records.Write

+ RedisPubsub *WriteGroupRedisPubSubOptions

+ RedisStreams *WriteGroupRedisStreamsOptions

+ XCliOptions *WriteCLIOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptions) Descriptor() ([]byte, []int)

+ func (*WriteOptions) ProtoMessage()

+ func (m *WriteOptions) GetActivemq() *WriteGroupActiveMQOptions

+ func (m *WriteOptions) GetAwssns() *WriteGroupAWSSNSOptions

+ func (m *WriteOptions) GetAwssqs() *WriteGroupAWSSQSOptions

+ func (m *WriteOptions) GetAzureEventHub() *WriteGroupAzureEventHubOptions

+ func (m *WriteOptions) GetAzureServiceBus() *WriteGroupAzureServiceBusOptions

+ func (m *WriteOptions) GetConnectionId() string

+ func (m *WriteOptions) GetGcpPubsub() *WriteGroupGCPPubSubOptions

+ func (m *WriteOptions) GetKafka() *WriteGroupKafkaOptions

+ func (m *WriteOptions) GetKubemqQueue() *WriteGroupKubeMQQueueOptions

+ func (m *WriteOptions) GetMqtt() *WriteGroupMQTTOptions

+ func (m *WriteOptions) GetNats() *WriteGroupNatsOptions

+ func (m *WriteOptions) GetNatsStreaming() *WriteGroupNatsStreamingOptions

+ func (m *WriteOptions) GetNsq() *WriteGroupNSQOptions

+ func (m *WriteOptions) GetPulsar() *WriteGroupPulsarOptions

+ func (m *WriteOptions) GetRabbit() *WriteGroupRabbitOptions

+ func (m *WriteOptions) GetRabbitStreams() *WriteGroupRabbitStreamsOptions

+ func (m *WriteOptions) GetRecord() *records.Write

+ func (m *WriteOptions) GetRedisPubsub() *WriteGroupRedisPubSubOptions

+ func (m *WriteOptions) GetRedisStreams() *WriteGroupRedisStreamsOptions

+ func (m *WriteOptions) GetXCliOptions() *WriteCLIOptions

+ func (m *WriteOptions) Reset()

+ func (m *WriteOptions) String() string

+ func (m *WriteOptions) XXX_DiscardUnknown()

+ func (m *WriteOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptions) XXX_Merge(src proto.Message)

+ func (m *WriteOptions) XXX_Size() int

+ func (m *WriteOptions) XXX_Unmarshal(b []byte) error

Sep 8, 2021

Changes in this version

+ type Read struct

+ Activemq *ReadOptsActiveMQ

+ Awssqs *ReadOptsAWSSQS

+ AzureEventHub *ReadOptsAzureEventHub

+ AzureServiceBus *ReadOptsAzureServiceBus

+ GcpPubsub *ReadOptsGCPPubSub

+ Kafka *ReadOptsKafka

+ KubemqQueue *ReadOptsKubeMQQueue

+ Mongo *ReadOptsMongo

+ Mqtt *ReadOptsMQTT

+ Nats *ReadOptsNats

+ NatsStreaming *ReadOptsNatsStreaming

+ Nsq *ReadOptsNSQ

+ Postgres *ReadOptsPostgres

+ Pulsar *ReadOptsPulsar

+ Rabbit *ReadOptsRabbit

+ RabbitStreams *ReadOptsRabbitStreams

+ RedisPubsub *ReadOptsRedisPubSub

+ RedisStreams *ReadOptsRedisStreams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Read) Descriptor() ([]byte, []int)

+ func (*Read) ProtoMessage()

+ func (m *Read) GetActivemq() *ReadOptsActiveMQ

+ func (m *Read) GetAwssqs() *ReadOptsAWSSQS

+ func (m *Read) GetAzureEventHub() *ReadOptsAzureEventHub

+ func (m *Read) GetAzureServiceBus() *ReadOptsAzureServiceBus

+ func (m *Read) GetGcpPubsub() *ReadOptsGCPPubSub

+ func (m *Read) GetKafka() *ReadOptsKafka

+ func (m *Read) GetKubemqQueue() *ReadOptsKubeMQQueue

+ func (m *Read) GetMongo() *ReadOptsMongo

+ func (m *Read) GetMqtt() *ReadOptsMQTT

+ func (m *Read) GetNats() *ReadOptsNats

+ func (m *Read) GetNatsStreaming() *ReadOptsNatsStreaming

+ func (m *Read) GetNsq() *ReadOptsNSQ

+ func (m *Read) GetPostgres() *ReadOptsPostgres

+ func (m *Read) GetPulsar() *ReadOptsPulsar

+ func (m *Read) GetRabbit() *ReadOptsRabbit

+ func (m *Read) GetRabbitStreams() *ReadOptsRabbitStreams

+ func (m *Read) GetRedisPubsub() *ReadOptsRedisPubSub

+ func (m *Read) GetRedisStreams() *ReadOptsRedisStreams

+ func (m *Read) Reset()

+ func (m *Read) String() string

+ func (m *Read) XXX_DiscardUnknown()

+ func (m *Read) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Read) XXX_Merge(src proto.Message)

+ func (m *Read) XXX_Size() int

+ func (m *Read) XXX_Unmarshal(b []byte) error

+ type ReadOptsAWSSQS struct

+ Args *args.AWSSQSReadArgs

+ XConn *args.AWSSQSConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsAWSSQS) Descriptor() ([]byte, []int)

+ func (*ReadOptsAWSSQS) ProtoMessage()

+ func (m *ReadOptsAWSSQS) GetArgs() *args.AWSSQSReadArgs

+ func (m *ReadOptsAWSSQS) GetXConn() *args.AWSSQSConn

+ func (m *ReadOptsAWSSQS) Reset()

+ func (m *ReadOptsAWSSQS) String() string

+ func (m *ReadOptsAWSSQS) XXX_DiscardUnknown()

+ func (m *ReadOptsAWSSQS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsAWSSQS) XXX_Merge(src proto.Message)

+ func (m *ReadOptsAWSSQS) XXX_Size() int

+ func (m *ReadOptsAWSSQS) XXX_Unmarshal(b []byte) error

+ type ReadOptsActiveMQ struct

+ Args *args.ActiveMQReadArgs

+ XConn *args.ActiveMQConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsActiveMQ) Descriptor() ([]byte, []int)

+ func (*ReadOptsActiveMQ) ProtoMessage()

+ func (m *ReadOptsActiveMQ) GetArgs() *args.ActiveMQReadArgs

+ func (m *ReadOptsActiveMQ) GetXConn() *args.ActiveMQConn

+ func (m *ReadOptsActiveMQ) Reset()

+ func (m *ReadOptsActiveMQ) String() string

+ func (m *ReadOptsActiveMQ) XXX_DiscardUnknown()

+ func (m *ReadOptsActiveMQ) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsActiveMQ) XXX_Merge(src proto.Message)

+ func (m *ReadOptsActiveMQ) XXX_Size() int

+ func (m *ReadOptsActiveMQ) XXX_Unmarshal(b []byte) error

+ type ReadOptsAzureEventHub struct

+ Args *args.AzureEventHubReadArgs

+ XConn *args.AzureEventHubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsAzureEventHub) Descriptor() ([]byte, []int)

+ func (*ReadOptsAzureEventHub) ProtoMessage()

+ func (m *ReadOptsAzureEventHub) GetArgs() *args.AzureEventHubReadArgs

+ func (m *ReadOptsAzureEventHub) GetXConn() *args.AzureEventHubConn

+ func (m *ReadOptsAzureEventHub) Reset()

+ func (m *ReadOptsAzureEventHub) String() string

+ func (m *ReadOptsAzureEventHub) XXX_DiscardUnknown()

+ func (m *ReadOptsAzureEventHub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsAzureEventHub) XXX_Merge(src proto.Message)

+ func (m *ReadOptsAzureEventHub) XXX_Size() int

+ func (m *ReadOptsAzureEventHub) XXX_Unmarshal(b []byte) error

+ type ReadOptsAzureServiceBus struct

+ Args *args.AzureServiceBusReadArgs

+ XConn *args.AzureServiceBusConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsAzureServiceBus) Descriptor() ([]byte, []int)

+ func (*ReadOptsAzureServiceBus) ProtoMessage()

+ func (m *ReadOptsAzureServiceBus) GetArgs() *args.AzureServiceBusReadArgs

+ func (m *ReadOptsAzureServiceBus) GetXConn() *args.AzureServiceBusConn

+ func (m *ReadOptsAzureServiceBus) Reset()

+ func (m *ReadOptsAzureServiceBus) String() string

+ func (m *ReadOptsAzureServiceBus) XXX_DiscardUnknown()

+ func (m *ReadOptsAzureServiceBus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsAzureServiceBus) XXX_Merge(src proto.Message)

+ func (m *ReadOptsAzureServiceBus) XXX_Size() int

+ func (m *ReadOptsAzureServiceBus) XXX_Unmarshal(b []byte) error

+ type ReadOptsGCPPubSub struct

+ Args *args.GCPPubSubReadArgs

+ XConn *args.GCPPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsGCPPubSub) Descriptor() ([]byte, []int)

+ func (*ReadOptsGCPPubSub) ProtoMessage()

+ func (m *ReadOptsGCPPubSub) GetArgs() *args.GCPPubSubReadArgs

+ func (m *ReadOptsGCPPubSub) GetXConn() *args.GCPPubSubConn

+ func (m *ReadOptsGCPPubSub) Reset()

+ func (m *ReadOptsGCPPubSub) String() string

+ func (m *ReadOptsGCPPubSub) XXX_DiscardUnknown()

+ func (m *ReadOptsGCPPubSub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsGCPPubSub) XXX_Merge(src proto.Message)

+ func (m *ReadOptsGCPPubSub) XXX_Size() int

+ func (m *ReadOptsGCPPubSub) XXX_Unmarshal(b []byte) error

+ type ReadOptsKafka struct

+ Args *args.KafkaReadArgs

+ XConn *args.KafkaConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsKafka) Descriptor() ([]byte, []int)

+ func (*ReadOptsKafka) ProtoMessage()

+ func (m *ReadOptsKafka) GetArgs() *args.KafkaReadArgs

+ func (m *ReadOptsKafka) GetXConn() *args.KafkaConn

+ func (m *ReadOptsKafka) Reset()

+ func (m *ReadOptsKafka) String() string

+ func (m *ReadOptsKafka) XXX_DiscardUnknown()

+ func (m *ReadOptsKafka) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsKafka) XXX_Merge(src proto.Message)

+ func (m *ReadOptsKafka) XXX_Size() int

+ func (m *ReadOptsKafka) XXX_Unmarshal(b []byte) error

+ type ReadOptsKubeMQQueue struct

+ Args *args.KubeMQQueueReadArgs

+ XConn *args.KubeMQQueueConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsKubeMQQueue) Descriptor() ([]byte, []int)

+ func (*ReadOptsKubeMQQueue) ProtoMessage()

+ func (m *ReadOptsKubeMQQueue) GetArgs() *args.KubeMQQueueReadArgs

+ func (m *ReadOptsKubeMQQueue) GetXConn() *args.KubeMQQueueConn

+ func (m *ReadOptsKubeMQQueue) Reset()

+ func (m *ReadOptsKubeMQQueue) String() string

+ func (m *ReadOptsKubeMQQueue) XXX_DiscardUnknown()

+ func (m *ReadOptsKubeMQQueue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsKubeMQQueue) XXX_Merge(src proto.Message)

+ func (m *ReadOptsKubeMQQueue) XXX_Size() int

+ func (m *ReadOptsKubeMQQueue) XXX_Unmarshal(b []byte) error

+ type ReadOptsMQTT struct

+ Args *args.MQTTReadArgs

+ XConn *args.MQTTConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsMQTT) Descriptor() ([]byte, []int)

+ func (*ReadOptsMQTT) ProtoMessage()

+ func (m *ReadOptsMQTT) GetArgs() *args.MQTTReadArgs

+ func (m *ReadOptsMQTT) GetXConn() *args.MQTTConn

+ func (m *ReadOptsMQTT) Reset()

+ func (m *ReadOptsMQTT) String() string

+ func (m *ReadOptsMQTT) XXX_DiscardUnknown()

+ func (m *ReadOptsMQTT) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsMQTT) XXX_Merge(src proto.Message)

+ func (m *ReadOptsMQTT) XXX_Size() int

+ func (m *ReadOptsMQTT) XXX_Unmarshal(b []byte) error

+ type ReadOptsMongo struct

+ Args *args.MongoReadArgs

+ XConn *args.MongoConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsMongo) Descriptor() ([]byte, []int)

+ func (*ReadOptsMongo) ProtoMessage()

+ func (m *ReadOptsMongo) GetArgs() *args.MongoReadArgs

+ func (m *ReadOptsMongo) GetXConn() *args.MongoConn

+ func (m *ReadOptsMongo) Reset()

+ func (m *ReadOptsMongo) String() string

+ func (m *ReadOptsMongo) XXX_DiscardUnknown()

+ func (m *ReadOptsMongo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsMongo) XXX_Merge(src proto.Message)

+ func (m *ReadOptsMongo) XXX_Size() int

+ func (m *ReadOptsMongo) XXX_Unmarshal(b []byte) error

+ type ReadOptsNSQ struct

+ Args *args.NSQReadArgs

+ XConn *args.NSQConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsNSQ) Descriptor() ([]byte, []int)

+ func (*ReadOptsNSQ) ProtoMessage()

+ func (m *ReadOptsNSQ) GetArgs() *args.NSQReadArgs

+ func (m *ReadOptsNSQ) GetXConn() *args.NSQConn

+ func (m *ReadOptsNSQ) Reset()

+ func (m *ReadOptsNSQ) String() string

+ func (m *ReadOptsNSQ) XXX_DiscardUnknown()

+ func (m *ReadOptsNSQ) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsNSQ) XXX_Merge(src proto.Message)

+ func (m *ReadOptsNSQ) XXX_Size() int

+ func (m *ReadOptsNSQ) XXX_Unmarshal(b []byte) error

+ type ReadOptsNats struct

+ Args *args.NatsReadArgs

+ XConn *args.NatsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsNats) Descriptor() ([]byte, []int)

+ func (*ReadOptsNats) ProtoMessage()

+ func (m *ReadOptsNats) GetArgs() *args.NatsReadArgs

+ func (m *ReadOptsNats) GetXConn() *args.NatsConn

+ func (m *ReadOptsNats) Reset()

+ func (m *ReadOptsNats) String() string

+ func (m *ReadOptsNats) XXX_DiscardUnknown()

+ func (m *ReadOptsNats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsNats) XXX_Merge(src proto.Message)

+ func (m *ReadOptsNats) XXX_Size() int

+ func (m *ReadOptsNats) XXX_Unmarshal(b []byte) error

+ type ReadOptsNatsStreaming struct

+ Args *args.NatsStreamingReadArgs

+ XConn *args.NatsStreamingConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsNatsStreaming) Descriptor() ([]byte, []int)

+ func (*ReadOptsNatsStreaming) ProtoMessage()

+ func (m *ReadOptsNatsStreaming) GetArgs() *args.NatsStreamingReadArgs

+ func (m *ReadOptsNatsStreaming) GetXConn() *args.NatsStreamingConn

+ func (m *ReadOptsNatsStreaming) Reset()

+ func (m *ReadOptsNatsStreaming) String() string

+ func (m *ReadOptsNatsStreaming) XXX_DiscardUnknown()

+ func (m *ReadOptsNatsStreaming) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsNatsStreaming) XXX_Merge(src proto.Message)

+ func (m *ReadOptsNatsStreaming) XXX_Size() int

+ func (m *ReadOptsNatsStreaming) XXX_Unmarshal(b []byte) error

+ type ReadOptsPostgres struct

+ Args *args.PostgresReadArgs

+ XConn *args.PostgresConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsPostgres) Descriptor() ([]byte, []int)

+ func (*ReadOptsPostgres) ProtoMessage()

+ func (m *ReadOptsPostgres) GetArgs() *args.PostgresReadArgs

+ func (m *ReadOptsPostgres) GetXConn() *args.PostgresConn

+ func (m *ReadOptsPostgres) Reset()

+ func (m *ReadOptsPostgres) String() string

+ func (m *ReadOptsPostgres) XXX_DiscardUnknown()

+ func (m *ReadOptsPostgres) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsPostgres) XXX_Merge(src proto.Message)

+ func (m *ReadOptsPostgres) XXX_Size() int

+ func (m *ReadOptsPostgres) XXX_Unmarshal(b []byte) error

+ type ReadOptsPulsar struct

+ Args *args.PulsarReadArgs

+ XConn *args.PulsarConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsPulsar) Descriptor() ([]byte, []int)

+ func (*ReadOptsPulsar) ProtoMessage()

+ func (m *ReadOptsPulsar) GetArgs() *args.PulsarReadArgs

+ func (m *ReadOptsPulsar) GetXConn() *args.PulsarConn

+ func (m *ReadOptsPulsar) Reset()

+ func (m *ReadOptsPulsar) String() string

+ func (m *ReadOptsPulsar) XXX_DiscardUnknown()

+ func (m *ReadOptsPulsar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsPulsar) XXX_Merge(src proto.Message)

+ func (m *ReadOptsPulsar) XXX_Size() int

+ func (m *ReadOptsPulsar) XXX_Unmarshal(b []byte) error

+ type ReadOptsRabbit struct

+ Args *args.RabbitReadArgs

+ XConn *args.RabbitConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsRabbit) Descriptor() ([]byte, []int)

+ func (*ReadOptsRabbit) ProtoMessage()

+ func (m *ReadOptsRabbit) GetArgs() *args.RabbitReadArgs

+ func (m *ReadOptsRabbit) GetXConn() *args.RabbitConn

+ func (m *ReadOptsRabbit) Reset()

+ func (m *ReadOptsRabbit) String() string

+ func (m *ReadOptsRabbit) XXX_DiscardUnknown()

+ func (m *ReadOptsRabbit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsRabbit) XXX_Merge(src proto.Message)

+ func (m *ReadOptsRabbit) XXX_Size() int

+ func (m *ReadOptsRabbit) XXX_Unmarshal(b []byte) error

+ type ReadOptsRabbitStreams struct

+ Args *args.RabbitStreamsReadArgs

+ XConn *args.RabbitStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsRabbitStreams) Descriptor() ([]byte, []int)

+ func (*ReadOptsRabbitStreams) ProtoMessage()

+ func (m *ReadOptsRabbitStreams) GetArgs() *args.RabbitStreamsReadArgs

+ func (m *ReadOptsRabbitStreams) GetXConn() *args.RabbitStreamsConn

+ func (m *ReadOptsRabbitStreams) Reset()

+ func (m *ReadOptsRabbitStreams) String() string

+ func (m *ReadOptsRabbitStreams) XXX_DiscardUnknown()

+ func (m *ReadOptsRabbitStreams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsRabbitStreams) XXX_Merge(src proto.Message)

+ func (m *ReadOptsRabbitStreams) XXX_Size() int

+ func (m *ReadOptsRabbitStreams) XXX_Unmarshal(b []byte) error

+ type ReadOptsRedisPubSub struct

+ Args *args.RedisPubSubReadArgs

+ XConn *args.RedisPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsRedisPubSub) Descriptor() ([]byte, []int)

+ func (*ReadOptsRedisPubSub) ProtoMessage()

+ func (m *ReadOptsRedisPubSub) GetArgs() *args.RedisPubSubReadArgs

+ func (m *ReadOptsRedisPubSub) GetXConn() *args.RedisPubSubConn

+ func (m *ReadOptsRedisPubSub) Reset()

+ func (m *ReadOptsRedisPubSub) String() string

+ func (m *ReadOptsRedisPubSub) XXX_DiscardUnknown()

+ func (m *ReadOptsRedisPubSub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsRedisPubSub) XXX_Merge(src proto.Message)

+ func (m *ReadOptsRedisPubSub) XXX_Size() int

+ func (m *ReadOptsRedisPubSub) XXX_Unmarshal(b []byte) error

+ type ReadOptsRedisStreams struct

+ Args *args.RedisStreamsReadArgs

+ XConn *args.RedisStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadOptsRedisStreams) Descriptor() ([]byte, []int)

+ func (*ReadOptsRedisStreams) ProtoMessage()

+ func (m *ReadOptsRedisStreams) GetArgs() *args.RedisStreamsReadArgs

+ func (m *ReadOptsRedisStreams) GetXConn() *args.RedisStreamsConn

+ func (m *ReadOptsRedisStreams) Reset()

+ func (m *ReadOptsRedisStreams) String() string

+ func (m *ReadOptsRedisStreams) XXX_DiscardUnknown()

+ func (m *ReadOptsRedisStreams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadOptsRedisStreams) XXX_Merge(src proto.Message)

+ func (m *ReadOptsRedisStreams) XXX_Size() int

+ func (m *ReadOptsRedisStreams) XXX_Unmarshal(b []byte) error

+ type Relay struct

+ Awssqs *RelayOptsAWSSQS

+ AzureServiceBus *RelayOptsAzureServiceBus

+ GcpPubsub *RelayOptsGCPPubSub

+ Kafka *RelayOptsKafka

+ KubemqQueue *RelayOptsKubeMQQueue

+ Mongo *RelayOptsMongo

+ Mqtt *RelayOptsMQTT

+ Nsq *RelayOptsNSQ

+ Postgres *RelayOptsPostgres

+ Rabbit *RelayOptsRabbit

+ RedisPubsub *RelayOptsRedisPubSub

+ RedisStreams *RelayOptsRedisStreams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Relay) Descriptor() ([]byte, []int)

+ func (*Relay) ProtoMessage()

+ func (m *Relay) GetAwssqs() *RelayOptsAWSSQS

+ func (m *Relay) GetAzureServiceBus() *RelayOptsAzureServiceBus

+ func (m *Relay) GetGcpPubsub() *RelayOptsGCPPubSub

+ func (m *Relay) GetKafka() *RelayOptsKafka

+ func (m *Relay) GetKubemqQueue() *RelayOptsKubeMQQueue

+ func (m *Relay) GetMongo() *RelayOptsMongo

+ func (m *Relay) GetMqtt() *RelayOptsMQTT

+ func (m *Relay) GetNsq() *RelayOptsNSQ

+ func (m *Relay) GetPostgres() *RelayOptsPostgres

+ func (m *Relay) GetRabbit() *RelayOptsRabbit

+ func (m *Relay) GetRedisPubsub() *RelayOptsRedisPubSub

+ func (m *Relay) GetRedisStreams() *RelayOptsRedisStreams

+ func (m *Relay) Reset()

+ func (m *Relay) String() string

+ func (m *Relay) XXX_DiscardUnknown()

+ func (m *Relay) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Relay) XXX_Merge(src proto.Message)

+ func (m *Relay) XXX_Size() int

+ func (m *Relay) XXX_Unmarshal(b []byte) error

+ type RelayOptsAWSSQS struct

+ Args *args.AWSSQSRelayArgs

+ XConn *args.AWSSQSConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RelayOptsAWSSQS) Descriptor() ([]byte, []int)

+ func (*RelayOptsAWSSQS) ProtoMessage()

+ func (m *RelayOptsAWSSQS) GetArgs() *args.AWSSQSRelayArgs

+ func (m *RelayOptsAWSSQS) GetXConn() *args.AWSSQSConn

+ func (m *RelayOptsAWSSQS) Reset()

+ func (m *RelayOptsAWSSQS) String() string

+ func (m *RelayOptsAWSSQS) XXX_DiscardUnknown()

+ func (m *RelayOptsAWSSQS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RelayOptsAWSSQS) XXX_Merge(src proto.Message)

+ func (m *RelayOptsAWSSQS) XXX_Size() int

+ func (m *RelayOptsAWSSQS) XXX_Unmarshal(b []byte) error

+ type RelayOptsAzureServiceBus struct

+ Args *args.AzureServiceBusReadArgs

+ XConn *args.AzureServiceBusConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RelayOptsAzureServiceBus) Descriptor() ([]byte, []int)

+ func (*RelayOptsAzureServiceBus) ProtoMessage()

+ func (m *RelayOptsAzureServiceBus) GetArgs() *args.AzureServiceBusReadArgs

+ func (m *RelayOptsAzureServiceBus) GetXConn() *args.AzureServiceBusConn

+ func (m *RelayOptsAzureServiceBus) Reset()

+ func (m *RelayOptsAzureServiceBus) String() string

+ func (m *RelayOptsAzureServiceBus) XXX_DiscardUnknown()

+ func (m *RelayOptsAzureServiceBus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RelayOptsAzureServiceBus) XXX_Merge(src proto.Message)

+ func (m *RelayOptsAzureServiceBus) XXX_Size() int

+ func (m *RelayOptsAzureServiceBus) XXX_Unmarshal(b []byte) error

+ type RelayOptsGCPPubSub struct

+ Args *args.GCPPubSubReadArgs

+ XConn *args.GCPPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RelayOptsGCPPubSub) Descriptor() ([]byte, []int)

+ func (*RelayOptsGCPPubSub) ProtoMessage()

+ func (m *RelayOptsGCPPubSub) GetArgs() *args.GCPPubSubReadArgs

+ func (m *RelayOptsGCPPubSub) GetXConn() *args.GCPPubSubConn

+ func (m *RelayOptsGCPPubSub) Reset()

+ func (m *RelayOptsGCPPubSub) String() string

+ func (m *RelayOptsGCPPubSub) XXX_DiscardUnknown()

+ func (m *RelayOptsGCPPubSub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RelayOptsGCPPubSub) XXX_Merge(src proto.Message)

+ func (m *RelayOptsGCPPubSub) XXX_Size() int

+ func (m *RelayOptsGCPPubSub) XXX_Unmarshal(b []byte) error

+ type RelayOptsKafka struct

+ Args *args.KafkaRelayArgs

+ XConn *args.KafkaConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RelayOptsKafka) Descriptor() ([]byte, []int)

+ func (*RelayOptsKafka) ProtoMessage()

+ func (m *RelayOptsKafka) GetArgs() *args.KafkaRelayArgs

+ func (m *RelayOptsKafka) GetXConn() *args.KafkaConn

+ func (m *RelayOptsKafka) Reset()

+ func (m *RelayOptsKafka) String() string

+ func (m *RelayOptsKafka) XXX_DiscardUnknown()

+ func (m *RelayOptsKafka) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RelayOptsKafka) XXX_Merge(src proto.Message)

+ func (m *RelayOptsKafka) XXX_Size() int

+ func (m *RelayOptsKafka) XXX_Unmarshal(b []byte) error

+ type RelayOptsKubeMQQueue struct

+ Args *args.KubeMQQueueReadArgs

+ XConn *args.KubeMQQueueConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RelayOptsKubeMQQueue) Descriptor() ([]byte, []int)

+ func (*RelayOptsKubeMQQueue) ProtoMessage()

+ func (m *RelayOptsKubeMQQueue) GetArgs() *args.KubeMQQueueReadArgs

+ func (m *RelayOptsKubeMQQueue) GetXConn() *args.KubeMQQueueConn

+ func (m *RelayOptsKubeMQQueue) Reset()

+ func (m *RelayOptsKubeMQQueue) String() string

+ func (m *RelayOptsKubeMQQueue) XXX_DiscardUnknown()

+ func (m *RelayOptsKubeMQQueue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RelayOptsKubeMQQueue) XXX_Merge(src proto.Message)

+ func (m *RelayOptsKubeMQQueue) XXX_Size() int

+ func (m *RelayOptsKubeMQQueue) XXX_Unmarshal(b []byte) error

+ type RelayOptsMQTT struct

+ Args *args.MQTTReadArgs

+ XConn *args.MQTTConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RelayOptsMQTT) Descriptor() ([]byte, []int)

+ func (*RelayOptsMQTT) ProtoMessage()

+ func (m *RelayOptsMQTT) GetArgs() *args.MQTTReadArgs

+ func (m *RelayOptsMQTT) GetXConn() *args.MQTTConn

+ func (m *RelayOptsMQTT) Reset()

+ func (m *RelayOptsMQTT) String() string

+ func (m *RelayOptsMQTT) XXX_DiscardUnknown()

+ func (m *RelayOptsMQTT) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RelayOptsMQTT) XXX_Merge(src proto.Message)

+ func (m *RelayOptsMQTT) XXX_Size() int

+ func (m *RelayOptsMQTT) XXX_Unmarshal(b []byte) error

+ type RelayOptsMongo struct

+ Args *args.MongoReadArgs

+ XConn *args.MongoConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RelayOptsMongo) Descriptor() ([]byte, []int)

+ func (*RelayOptsMongo) ProtoMessage()

+ func (m *RelayOptsMongo) GetArgs() *args.MongoReadArgs

+ func (m *RelayOptsMongo) GetXConn() *args.MongoConn

+ func (m *RelayOptsMongo) Reset()

+ func (m *RelayOptsMongo) String() string

+ func (m *RelayOptsMongo) XXX_DiscardUnknown()

+ func (m *RelayOptsMongo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RelayOptsMongo) XXX_Merge(src proto.Message)

+ func (m *RelayOptsMongo) XXX_Size() int

+ func (m *RelayOptsMongo) XXX_Unmarshal(b []byte) error

+ type RelayOptsNSQ struct

+ Args *args.NSQReadArgs

+ XConn *args.NSQConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RelayOptsNSQ) Descriptor() ([]byte, []int)

+ func (*RelayOptsNSQ) ProtoMessage()

+ func (m *RelayOptsNSQ) GetArgs() *args.NSQReadArgs

+ func (m *RelayOptsNSQ) GetXConn() *args.NSQConn

+ func (m *RelayOptsNSQ) Reset()

+ func (m *RelayOptsNSQ) String() string

+ func (m *RelayOptsNSQ) XXX_DiscardUnknown()

+ func (m *RelayOptsNSQ) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RelayOptsNSQ) XXX_Merge(src proto.Message)

+ func (m *RelayOptsNSQ) XXX_Size() int

+ func (m *RelayOptsNSQ) XXX_Unmarshal(b []byte) error

+ type RelayOptsPostgres struct

+ Args *args.PostgresReadArgs

+ XConn *args.PostgresConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RelayOptsPostgres) Descriptor() ([]byte, []int)

+ func (*RelayOptsPostgres) ProtoMessage()

+ func (m *RelayOptsPostgres) GetArgs() *args.PostgresReadArgs

+ func (m *RelayOptsPostgres) GetXConn() *args.PostgresConn

+ func (m *RelayOptsPostgres) Reset()

+ func (m *RelayOptsPostgres) String() string

+ func (m *RelayOptsPostgres) XXX_DiscardUnknown()

+ func (m *RelayOptsPostgres) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RelayOptsPostgres) XXX_Merge(src proto.Message)

+ func (m *RelayOptsPostgres) XXX_Size() int

+ func (m *RelayOptsPostgres) XXX_Unmarshal(b []byte) error

+ type RelayOptsRabbit struct

+ Args *args.RabbitReadArgs

+ XConn *args.RabbitConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RelayOptsRabbit) Descriptor() ([]byte, []int)

+ func (*RelayOptsRabbit) ProtoMessage()

+ func (m *RelayOptsRabbit) GetArgs() *args.RabbitReadArgs

+ func (m *RelayOptsRabbit) GetXConn() *args.RabbitConn

+ func (m *RelayOptsRabbit) Reset()

+ func (m *RelayOptsRabbit) String() string

+ func (m *RelayOptsRabbit) XXX_DiscardUnknown()

+ func (m *RelayOptsRabbit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RelayOptsRabbit) XXX_Merge(src proto.Message)

+ func (m *RelayOptsRabbit) XXX_Size() int

+ func (m *RelayOptsRabbit) XXX_Unmarshal(b []byte) error

+ type RelayOptsRedisPubSub struct

+ Args *args.RedisPubSubReadArgs

+ XConn *args.RedisPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RelayOptsRedisPubSub) Descriptor() ([]byte, []int)

+ func (*RelayOptsRedisPubSub) ProtoMessage()

+ func (m *RelayOptsRedisPubSub) GetArgs() *args.RedisPubSubReadArgs

+ func (m *RelayOptsRedisPubSub) GetXConn() *args.RedisPubSubConn

+ func (m *RelayOptsRedisPubSub) Reset()

+ func (m *RelayOptsRedisPubSub) String() string

+ func (m *RelayOptsRedisPubSub) XXX_DiscardUnknown()

+ func (m *RelayOptsRedisPubSub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RelayOptsRedisPubSub) XXX_Merge(src proto.Message)

+ func (m *RelayOptsRedisPubSub) XXX_Size() int

+ func (m *RelayOptsRedisPubSub) XXX_Unmarshal(b []byte) error

+ type RelayOptsRedisStreams struct

+ Args *args.RedisStreamsReadArgs

+ XConn *args.RedisStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RelayOptsRedisStreams) Descriptor() ([]byte, []int)

+ func (*RelayOptsRedisStreams) ProtoMessage()

+ func (m *RelayOptsRedisStreams) GetArgs() *args.RedisStreamsReadArgs

+ func (m *RelayOptsRedisStreams) GetXConn() *args.RedisStreamsConn

+ func (m *RelayOptsRedisStreams) Reset()

+ func (m *RelayOptsRedisStreams) String() string

+ func (m *RelayOptsRedisStreams) XXX_DiscardUnknown()

+ func (m *RelayOptsRedisStreams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RelayOptsRedisStreams) XXX_Merge(src proto.Message)

+ func (m *RelayOptsRedisStreams) XXX_Size() int

+ func (m *RelayOptsRedisStreams) XXX_Unmarshal(b []byte) error

+ type Write struct

+ Activemq *WriteOptsActiveMQ

+ Awssns *WriteOptsAWSSNS

+ Awssqs *WriteOptsAWSSQS

+ AzureEventHub *WriteOptsAzureEventHub

+ AzureServiceBus *WriteOptsAzureServiceBus

+ GcpPubsub *WriteOptsGCPPubSub

+ Kafka *WriteOptsKafka

+ KubemqQueue *WriteOptsKubeMQQueue

+ Mqtt *WriteOptsMQTT

+ Nats *WriteOptsNats

+ NatsStreaming *WriteOptsNatsStreaming

+ Nsq *WriteOptsNSQ

+ Pulsar *WriteOptsPulsar

+ Rabbit *WriteOptsRabbit

+ RabbitStreams *WriteOptsRabbitStreams

+ Record *records.WriteRecord

+ RedisPubsub *WriteOptsRedisPubSub

+ RedisStreams *WriteOptsRedisStreams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Write) Descriptor() ([]byte, []int)

+ func (*Write) ProtoMessage()

+ func (m *Write) GetActivemq() *WriteOptsActiveMQ

+ func (m *Write) GetAwssns() *WriteOptsAWSSNS

+ func (m *Write) GetAwssqs() *WriteOptsAWSSQS

+ func (m *Write) GetAzureEventHub() *WriteOptsAzureEventHub

+ func (m *Write) GetAzureServiceBus() *WriteOptsAzureServiceBus

+ func (m *Write) GetGcpPubsub() *WriteOptsGCPPubSub

+ func (m *Write) GetKafka() *WriteOptsKafka

+ func (m *Write) GetKubemqQueue() *WriteOptsKubeMQQueue

+ func (m *Write) GetMqtt() *WriteOptsMQTT

+ func (m *Write) GetNats() *WriteOptsNats

+ func (m *Write) GetNatsStreaming() *WriteOptsNatsStreaming

+ func (m *Write) GetNsq() *WriteOptsNSQ

+ func (m *Write) GetPulsar() *WriteOptsPulsar

+ func (m *Write) GetRabbit() *WriteOptsRabbit

+ func (m *Write) GetRabbitStreams() *WriteOptsRabbitStreams

+ func (m *Write) GetRecord() *records.WriteRecord

+ func (m *Write) GetRedisPubsub() *WriteOptsRedisPubSub

+ func (m *Write) GetRedisStreams() *WriteOptsRedisStreams

+ func (m *Write) Reset()

+ func (m *Write) String() string

+ func (m *Write) XXX_DiscardUnknown()

+ func (m *Write) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Write) XXX_Merge(src proto.Message)

+ func (m *Write) XXX_Size() int

+ func (m *Write) XXX_Unmarshal(b []byte) error

+ type WriteOptsAWSSNS struct

+ Args *args.AWSSNSWriteArgs

+ XConn *args.AWSSNSConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsAWSSNS) Descriptor() ([]byte, []int)

+ func (*WriteOptsAWSSNS) ProtoMessage()

+ func (m *WriteOptsAWSSNS) GetArgs() *args.AWSSNSWriteArgs

+ func (m *WriteOptsAWSSNS) GetXConn() *args.AWSSNSConn

+ func (m *WriteOptsAWSSNS) Reset()

+ func (m *WriteOptsAWSSNS) String() string

+ func (m *WriteOptsAWSSNS) XXX_DiscardUnknown()

+ func (m *WriteOptsAWSSNS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsAWSSNS) XXX_Merge(src proto.Message)

+ func (m *WriteOptsAWSSNS) XXX_Size() int

+ func (m *WriteOptsAWSSNS) XXX_Unmarshal(b []byte) error

+ type WriteOptsAWSSQS struct

+ Args *args.AWSSQSWriteArgs

+ XConn *args.AWSSQSConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsAWSSQS) Descriptor() ([]byte, []int)

+ func (*WriteOptsAWSSQS) ProtoMessage()

+ func (m *WriteOptsAWSSQS) GetArgs() *args.AWSSQSWriteArgs

+ func (m *WriteOptsAWSSQS) GetXConn() *args.AWSSQSConn

+ func (m *WriteOptsAWSSQS) Reset()

+ func (m *WriteOptsAWSSQS) String() string

+ func (m *WriteOptsAWSSQS) XXX_DiscardUnknown()

+ func (m *WriteOptsAWSSQS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsAWSSQS) XXX_Merge(src proto.Message)

+ func (m *WriteOptsAWSSQS) XXX_Size() int

+ func (m *WriteOptsAWSSQS) XXX_Unmarshal(b []byte) error

+ type WriteOptsActiveMQ struct

+ Args *args.ActiveMQWriteArgs

+ XConn *args.ActiveMQConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsActiveMQ) Descriptor() ([]byte, []int)

+ func (*WriteOptsActiveMQ) ProtoMessage()

+ func (m *WriteOptsActiveMQ) GetArgs() *args.ActiveMQWriteArgs

+ func (m *WriteOptsActiveMQ) GetXConn() *args.ActiveMQConn

+ func (m *WriteOptsActiveMQ) Reset()

+ func (m *WriteOptsActiveMQ) String() string

+ func (m *WriteOptsActiveMQ) XXX_DiscardUnknown()

+ func (m *WriteOptsActiveMQ) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsActiveMQ) XXX_Merge(src proto.Message)

+ func (m *WriteOptsActiveMQ) XXX_Size() int

+ func (m *WriteOptsActiveMQ) XXX_Unmarshal(b []byte) error

+ type WriteOptsAzureEventHub struct

+ Args *args.AzureEventHubWriteArgs

+ XConn *args.AzureEventHubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsAzureEventHub) Descriptor() ([]byte, []int)

+ func (*WriteOptsAzureEventHub) ProtoMessage()

+ func (m *WriteOptsAzureEventHub) GetArgs() *args.AzureEventHubWriteArgs

+ func (m *WriteOptsAzureEventHub) GetXConn() *args.AzureEventHubConn

+ func (m *WriteOptsAzureEventHub) Reset()

+ func (m *WriteOptsAzureEventHub) String() string

+ func (m *WriteOptsAzureEventHub) XXX_DiscardUnknown()

+ func (m *WriteOptsAzureEventHub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsAzureEventHub) XXX_Merge(src proto.Message)

+ func (m *WriteOptsAzureEventHub) XXX_Size() int

+ func (m *WriteOptsAzureEventHub) XXX_Unmarshal(b []byte) error

+ type WriteOptsAzureServiceBus struct

+ Args *args.AzureServiceBusWriteArgs

+ XConn *args.AzureServiceBusConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsAzureServiceBus) Descriptor() ([]byte, []int)

+ func (*WriteOptsAzureServiceBus) ProtoMessage()

+ func (m *WriteOptsAzureServiceBus) GetArgs() *args.AzureServiceBusWriteArgs

+ func (m *WriteOptsAzureServiceBus) GetXConn() *args.AzureServiceBusConn

+ func (m *WriteOptsAzureServiceBus) Reset()

+ func (m *WriteOptsAzureServiceBus) String() string

+ func (m *WriteOptsAzureServiceBus) XXX_DiscardUnknown()

+ func (m *WriteOptsAzureServiceBus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsAzureServiceBus) XXX_Merge(src proto.Message)

+ func (m *WriteOptsAzureServiceBus) XXX_Size() int

+ func (m *WriteOptsAzureServiceBus) XXX_Unmarshal(b []byte) error

+ type WriteOptsGCPPubSub struct

+ Args *args.GCPPubSubWriteArgs

+ XConn *args.GCPPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsGCPPubSub) Descriptor() ([]byte, []int)

+ func (*WriteOptsGCPPubSub) ProtoMessage()

+ func (m *WriteOptsGCPPubSub) GetArgs() *args.GCPPubSubWriteArgs

+ func (m *WriteOptsGCPPubSub) GetXConn() *args.GCPPubSubConn

+ func (m *WriteOptsGCPPubSub) Reset()

+ func (m *WriteOptsGCPPubSub) String() string

+ func (m *WriteOptsGCPPubSub) XXX_DiscardUnknown()

+ func (m *WriteOptsGCPPubSub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsGCPPubSub) XXX_Merge(src proto.Message)

+ func (m *WriteOptsGCPPubSub) XXX_Size() int

+ func (m *WriteOptsGCPPubSub) XXX_Unmarshal(b []byte) error

+ type WriteOptsKafka struct

+ Args *args.KafkaWriteArgs

+ XConn *args.KafkaConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsKafka) Descriptor() ([]byte, []int)

+ func (*WriteOptsKafka) ProtoMessage()

+ func (m *WriteOptsKafka) GetArgs() *args.KafkaWriteArgs

+ func (m *WriteOptsKafka) GetXConn() *args.KafkaConn

+ func (m *WriteOptsKafka) Reset()

+ func (m *WriteOptsKafka) String() string

+ func (m *WriteOptsKafka) XXX_DiscardUnknown()

+ func (m *WriteOptsKafka) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsKafka) XXX_Merge(src proto.Message)

+ func (m *WriteOptsKafka) XXX_Size() int

+ func (m *WriteOptsKafka) XXX_Unmarshal(b []byte) error

+ type WriteOptsKubeMQQueue struct

+ Args *args.KubeMQQueueWriteArgs

+ XConn *args.KubeMQQueueConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsKubeMQQueue) Descriptor() ([]byte, []int)

+ func (*WriteOptsKubeMQQueue) ProtoMessage()

+ func (m *WriteOptsKubeMQQueue) GetArgs() *args.KubeMQQueueWriteArgs

+ func (m *WriteOptsKubeMQQueue) GetXConn() *args.KubeMQQueueConn

+ func (m *WriteOptsKubeMQQueue) Reset()

+ func (m *WriteOptsKubeMQQueue) String() string

+ func (m *WriteOptsKubeMQQueue) XXX_DiscardUnknown()

+ func (m *WriteOptsKubeMQQueue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsKubeMQQueue) XXX_Merge(src proto.Message)

+ func (m *WriteOptsKubeMQQueue) XXX_Size() int

+ func (m *WriteOptsKubeMQQueue) XXX_Unmarshal(b []byte) error

+ type WriteOptsMQTT struct

+ Args *args.MQTTWriteArgs

+ XConn *args.MQTTConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsMQTT) Descriptor() ([]byte, []int)

+ func (*WriteOptsMQTT) ProtoMessage()

+ func (m *WriteOptsMQTT) GetArgs() *args.MQTTWriteArgs

+ func (m *WriteOptsMQTT) GetXConn() *args.MQTTConn

+ func (m *WriteOptsMQTT) Reset()

+ func (m *WriteOptsMQTT) String() string

+ func (m *WriteOptsMQTT) XXX_DiscardUnknown()

+ func (m *WriteOptsMQTT) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsMQTT) XXX_Merge(src proto.Message)

+ func (m *WriteOptsMQTT) XXX_Size() int

+ func (m *WriteOptsMQTT) XXX_Unmarshal(b []byte) error

+ type WriteOptsNSQ struct

+ Args *args.NSQWriteArgs

+ XConn *args.NSQConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsNSQ) Descriptor() ([]byte, []int)

+ func (*WriteOptsNSQ) ProtoMessage()

+ func (m *WriteOptsNSQ) GetArgs() *args.NSQWriteArgs

+ func (m *WriteOptsNSQ) GetXConn() *args.NSQConn

+ func (m *WriteOptsNSQ) Reset()

+ func (m *WriteOptsNSQ) String() string

+ func (m *WriteOptsNSQ) XXX_DiscardUnknown()

+ func (m *WriteOptsNSQ) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsNSQ) XXX_Merge(src proto.Message)

+ func (m *WriteOptsNSQ) XXX_Size() int

+ func (m *WriteOptsNSQ) XXX_Unmarshal(b []byte) error

+ type WriteOptsNats struct

+ Args *args.NatsWriteArgs

+ XConn *args.NatsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsNats) Descriptor() ([]byte, []int)

+ func (*WriteOptsNats) ProtoMessage()

+ func (m *WriteOptsNats) GetArgs() *args.NatsWriteArgs

+ func (m *WriteOptsNats) GetXConn() *args.NatsConn

+ func (m *WriteOptsNats) Reset()

+ func (m *WriteOptsNats) String() string

+ func (m *WriteOptsNats) XXX_DiscardUnknown()

+ func (m *WriteOptsNats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsNats) XXX_Merge(src proto.Message)

+ func (m *WriteOptsNats) XXX_Size() int

+ func (m *WriteOptsNats) XXX_Unmarshal(b []byte) error

+ type WriteOptsNatsStreaming struct

+ Args *args.NatsStreamingWriteArgs

+ XConn *args.NatsStreamingConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsNatsStreaming) Descriptor() ([]byte, []int)

+ func (*WriteOptsNatsStreaming) ProtoMessage()

+ func (m *WriteOptsNatsStreaming) GetArgs() *args.NatsStreamingWriteArgs

+ func (m *WriteOptsNatsStreaming) GetXConn() *args.NatsStreamingConn

+ func (m *WriteOptsNatsStreaming) Reset()

+ func (m *WriteOptsNatsStreaming) String() string

+ func (m *WriteOptsNatsStreaming) XXX_DiscardUnknown()

+ func (m *WriteOptsNatsStreaming) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsNatsStreaming) XXX_Merge(src proto.Message)

+ func (m *WriteOptsNatsStreaming) XXX_Size() int

+ func (m *WriteOptsNatsStreaming) XXX_Unmarshal(b []byte) error

+ type WriteOptsPulsar struct

+ Args *args.PulsarWriteArgs

+ XConn *args.PulsarConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsPulsar) Descriptor() ([]byte, []int)

+ func (*WriteOptsPulsar) ProtoMessage()

+ func (m *WriteOptsPulsar) GetArgs() *args.PulsarWriteArgs

+ func (m *WriteOptsPulsar) GetXConn() *args.PulsarConn

+ func (m *WriteOptsPulsar) Reset()

+ func (m *WriteOptsPulsar) String() string

+ func (m *WriteOptsPulsar) XXX_DiscardUnknown()

+ func (m *WriteOptsPulsar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsPulsar) XXX_Merge(src proto.Message)

+ func (m *WriteOptsPulsar) XXX_Size() int

+ func (m *WriteOptsPulsar) XXX_Unmarshal(b []byte) error

+ type WriteOptsRabbit struct

+ Args *args.RabbitWriteArgs

+ XConn *args.RabbitConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsRabbit) Descriptor() ([]byte, []int)

+ func (*WriteOptsRabbit) ProtoMessage()

+ func (m *WriteOptsRabbit) GetArgs() *args.RabbitWriteArgs

+ func (m *WriteOptsRabbit) GetXConn() *args.RabbitConn

+ func (m *WriteOptsRabbit) Reset()

+ func (m *WriteOptsRabbit) String() string

+ func (m *WriteOptsRabbit) XXX_DiscardUnknown()

+ func (m *WriteOptsRabbit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsRabbit) XXX_Merge(src proto.Message)

+ func (m *WriteOptsRabbit) XXX_Size() int

+ func (m *WriteOptsRabbit) XXX_Unmarshal(b []byte) error

+ type WriteOptsRabbitStreams struct

+ Args *args.RabbitStreamsWriteArgs

+ XConn *args.RabbitStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsRabbitStreams) Descriptor() ([]byte, []int)

+ func (*WriteOptsRabbitStreams) ProtoMessage()

+ func (m *WriteOptsRabbitStreams) GetArgs() *args.RabbitStreamsWriteArgs

+ func (m *WriteOptsRabbitStreams) GetXConn() *args.RabbitStreamsConn

+ func (m *WriteOptsRabbitStreams) Reset()

+ func (m *WriteOptsRabbitStreams) String() string

+ func (m *WriteOptsRabbitStreams) XXX_DiscardUnknown()

+ func (m *WriteOptsRabbitStreams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsRabbitStreams) XXX_Merge(src proto.Message)

+ func (m *WriteOptsRabbitStreams) XXX_Size() int

+ func (m *WriteOptsRabbitStreams) XXX_Unmarshal(b []byte) error

+ type WriteOptsRedisPubSub struct

+ Args *args.RedisPubSubWriteArgs

+ XConn *args.RedisPubSubConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsRedisPubSub) Descriptor() ([]byte, []int)

+ func (*WriteOptsRedisPubSub) ProtoMessage()

+ func (m *WriteOptsRedisPubSub) GetArgs() *args.RedisPubSubWriteArgs

+ func (m *WriteOptsRedisPubSub) GetXConn() *args.RedisPubSubConn

+ func (m *WriteOptsRedisPubSub) Reset()

+ func (m *WriteOptsRedisPubSub) String() string

+ func (m *WriteOptsRedisPubSub) XXX_DiscardUnknown()

+ func (m *WriteOptsRedisPubSub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsRedisPubSub) XXX_Merge(src proto.Message)

+ func (m *WriteOptsRedisPubSub) XXX_Size() int

+ func (m *WriteOptsRedisPubSub) XXX_Unmarshal(b []byte) error

+ type WriteOptsRedisStreams struct

+ Args *args.RedisStreamsWriteArgs

+ XConn *args.RedisStreamsConn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteOptsRedisStreams) Descriptor() ([]byte, []int)

+ func (*WriteOptsRedisStreams) ProtoMessage()

+ func (m *WriteOptsRedisStreams) GetArgs() *args.RedisStreamsWriteArgs

+ func (m *WriteOptsRedisStreams) GetXConn() *args.RedisStreamsConn

+ func (m *WriteOptsRedisStreams) Reset()

+ func (m *WriteOptsRedisStreams) String() string

+ func (m *WriteOptsRedisStreams) XXX_DiscardUnknown()

+ func (m *WriteOptsRedisStreams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WriteOptsRedisStreams) XXX_Merge(src proto.Message)

+ func (m *WriteOptsRedisStreams) XXX_Size() int

+ func (m *WriteOptsRedisStreams) XXX_Unmarshal(b []byte) error