backends

package
v0.0.38 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 22, 2021 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CreateConsumerConfig_OffsetStart_name = map[int32]string{
	0: "Latest",
	1: "Oldest",
}
View Source 
var CreateConsumerConfig_OffsetStart_value = map[string]int32{
	"Latest": 0,
	"Oldest": 1,
}
View Source 
var SubscriptionType_name = map[int32]string{
	0: "Unset",
	1: "Shared",
	2: "Exclusive",
	3: "Failover",
	4: "Keyshared",
}
View Source 
var SubscriptionType_value = map[string]int32{
	"Unset":     0,
	"Shared":    1,
	"Exclusive": 2,
	"Failover":  3,
	"Keyshared": 4,
}

Functions

This section is empty.

Types

type AWSSNS added in v0.0.32 

type AWSSNS struct {
	// Topic ARN to write to
	TopicArn             string   `protobuf:"bytes,1,opt,name=topic_arn,json=topicArn,proto3" json:"topic_arn,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AWSSNS) Descriptor added in v0.0.32 

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

func (*AWSSNS) GetTopicArn added in v0.0.32 

func (m *AWSSNS) GetTopicArn() string

func (*AWSSNS) ProtoMessage added in v0.0.32 

func (*AWSSNS) ProtoMessage()

func (*AWSSNS) Reset added in v0.0.32 

func (m *AWSSNS) Reset()

func (*AWSSNS) String added in v0.0.32 

func (m *AWSSNS) String() string

func (*AWSSNS) XXX_DiscardUnknown added in v0.0.32 

func (m *AWSSNS) XXX_DiscardUnknown()

func (*AWSSNS) XXX_Marshal added in v0.0.32 

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

func (*AWSSNS) XXX_Merge added in v0.0.32 

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

func (*AWSSNS) XXX_Size added in v0.0.32 

func (m *AWSSNS) XXX_Size() int

func (*AWSSNS) XXX_Unmarshal added in v0.0.32 

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

type AWSSQS added in v0.0.32 

type AWSSQS struct {
	QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	// Required if the queue is located in a different account
	RemoteAccountId      string   `protobuf:"bytes,2,opt,name=remote_account_id,json=remoteAccountId,proto3" json:"remote_account_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AWSSQS) Descriptor added in v0.0.32 

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

func (*AWSSQS) GetQueueName added in v0.0.32 

func (m *AWSSQS) GetQueueName() string

func (*AWSSQS) GetRemoteAccountId added in v0.0.32 

func (m *AWSSQS) GetRemoteAccountId() string

func (*AWSSQS) ProtoMessage added in v0.0.32 

func (*AWSSQS) ProtoMessage()

func (*AWSSQS) Reset added in v0.0.32 

func (m *AWSSQS) Reset()

func (*AWSSQS) String added in v0.0.32 

func (m *AWSSQS) String() string

func (*AWSSQS) XXX_DiscardUnknown added in v0.0.32 

func (m *AWSSQS) XXX_DiscardUnknown()

func (*AWSSQS) XXX_Marshal added in v0.0.32 

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

func (*AWSSQS) XXX_Merge added in v0.0.32 

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

func (*AWSSQS) XXX_Size added in v0.0.32 

func (m *AWSSQS) XXX_Size() int

func (*AWSSQS) XXX_Unmarshal added in v0.0.32 

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

type ActiveMQ added in v0.0.32 

type ActiveMQ struct {
	// Required if queue not specified
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Required if topic not specified
	Queue                string   `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActiveMQ) Descriptor added in v0.0.32 

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

func (*ActiveMQ) GetQueue added in v0.0.32 

func (m *ActiveMQ) GetQueue() string

func (*ActiveMQ) GetTopic added in v0.0.32 

func (m *ActiveMQ) GetTopic() string

func (*ActiveMQ) ProtoMessage added in v0.0.32 

func (*ActiveMQ) ProtoMessage()

func (*ActiveMQ) Reset added in v0.0.32 

func (m *ActiveMQ) Reset()

func (*ActiveMQ) String added in v0.0.32 

func (m *ActiveMQ) String() string

func (*ActiveMQ) XXX_DiscardUnknown added in v0.0.32 

func (m *ActiveMQ) XXX_DiscardUnknown()

func (*ActiveMQ) XXX_Marshal added in v0.0.32 

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

func (*ActiveMQ) XXX_Merge added in v0.0.32 

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

func (*ActiveMQ) XXX_Size added in v0.0.32 

func (m *ActiveMQ) XXX_Size() int

func (*ActiveMQ) XXX_Unmarshal added in v0.0.32 

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

type AzureEventHub added in v0.0.32 

type AzureEventHub struct {
	// Optional for writes
	// Ignored for reads
	MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// Optional for writes
	// Ignored for reads
	PartitionKey         string   `protobuf:"bytes,2,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AzureEventHub) Descriptor added in v0.0.32 

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

func (*AzureEventHub) GetMessageId added in v0.0.32 

func (m *AzureEventHub) GetMessageId() string

func (*AzureEventHub) GetPartitionKey added in v0.0.32 

func (m *AzureEventHub) GetPartitionKey() string

func (*AzureEventHub) ProtoMessage added in v0.0.32 

func (*AzureEventHub) ProtoMessage()

func (*AzureEventHub) Reset added in v0.0.32 

func (m *AzureEventHub) Reset()

func (*AzureEventHub) String added in v0.0.32 

func (m *AzureEventHub) String() string

func (*AzureEventHub) XXX_DiscardUnknown added in v0.0.32 

func (m *AzureEventHub) XXX_DiscardUnknown()

func (*AzureEventHub) XXX_Marshal added in v0.0.32 

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

func (*AzureEventHub) XXX_Merge added in v0.0.32 

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

func (*AzureEventHub) XXX_Size added in v0.0.32 

func (m *AzureEventHub) XXX_Size() int

func (*AzureEventHub) XXX_Unmarshal added in v0.0.32 

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

type AzureServiceBus added in v0.0.32 

type AzureServiceBus struct {
	// Required for reads and writes
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// Required for reads
	// Ignored for writes
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// Required for reads
	// Ignored for writes
	SubscriptionName     string   `protobuf:"bytes,3,opt,name=subscription_name,json=subscriptionName,proto3" json:"subscription_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AzureServiceBus) Descriptor added in v0.0.32 

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

func (*AzureServiceBus) GetQueue added in v0.0.32 

func (m *AzureServiceBus) GetQueue() string

func (*AzureServiceBus) GetSubscriptionName added in v0.0.32 

func (m *AzureServiceBus) GetSubscriptionName() string

func (*AzureServiceBus) GetTopic added in v0.0.32 

func (m *AzureServiceBus) GetTopic() string

func (*AzureServiceBus) ProtoMessage added in v0.0.32 

func (*AzureServiceBus) ProtoMessage()

func (*AzureServiceBus) Reset added in v0.0.32 

func (m *AzureServiceBus) Reset()

func (*AzureServiceBus) String added in v0.0.32 

func (m *AzureServiceBus) String() string

func (*AzureServiceBus) XXX_DiscardUnknown added in v0.0.32 

func (m *AzureServiceBus) XXX_DiscardUnknown()

func (*AzureServiceBus) XXX_Marshal added in v0.0.32 

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

func (*AzureServiceBus) XXX_Merge added in v0.0.32 

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

func (*AzureServiceBus) XXX_Size added in v0.0.32 

func (m *AzureServiceBus) XXX_Size() int

func (*AzureServiceBus) XXX_Unmarshal added in v0.0.32 

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

type CreateConsumerConfig added in v0.0.32 

type CreateConsumerConfig struct {
	// Create the streams if we're creating a new consumer group
	CreateStreams bool `protobuf:"varint,3,opt,name=create_streams,json=createStreams,proto3" json:"create_streams,omitempty"`
	// Recreate this consumer group if it doesn't exist
	RecreateConsumerGroup bool `` /* 127-byte string literal not displayed */
	// Required
	OffsetStart          CreateConsumerConfig_OffsetStart `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*CreateConsumerConfig) Descriptor added in v0.0.32 

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

func (*CreateConsumerConfig) GetCreateStreams added in v0.0.32 

func (m *CreateConsumerConfig) GetCreateStreams() bool

func (*CreateConsumerConfig) GetOffsetStart added in v0.0.32 

func (m *CreateConsumerConfig) GetOffsetStart() CreateConsumerConfig_OffsetStart

func (*CreateConsumerConfig) GetRecreateConsumerGroup added in v0.0.32 

func (m *CreateConsumerConfig) GetRecreateConsumerGroup() bool

func (*CreateConsumerConfig) ProtoMessage added in v0.0.32 

func (*CreateConsumerConfig) ProtoMessage()

func (*CreateConsumerConfig) Reset added in v0.0.32 

func (m *CreateConsumerConfig) Reset()

func (*CreateConsumerConfig) String added in v0.0.32 

func (m *CreateConsumerConfig) String() string

func (*CreateConsumerConfig) XXX_DiscardUnknown added in v0.0.32 

func (m *CreateConsumerConfig) XXX_DiscardUnknown()

func (*CreateConsumerConfig) XXX_Marshal added in v0.0.32 

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

func (*CreateConsumerConfig) XXX_Merge added in v0.0.32 

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

func (*CreateConsumerConfig) XXX_Size added in v0.0.32 

func (m *CreateConsumerConfig) XXX_Size() int

func (*CreateConsumerConfig) XXX_Unmarshal added in v0.0.32 

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

type CreateConsumerConfig_OffsetStart added in v0.0.32 

type CreateConsumerConfig_OffsetStart int32
const (
	CreateConsumerConfig_Latest CreateConsumerConfig_OffsetStart = 0
	CreateConsumerConfig_Oldest CreateConsumerConfig_OffsetStart = 1
)

func (CreateConsumerConfig_OffsetStart) EnumDescriptor added in v0.0.32 

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

func (CreateConsumerConfig_OffsetStart) String added in v0.0.32 

func (x CreateConsumerConfig_OffsetStart) String() string

type DeclareStream added in v0.0.32 

type DeclareStream struct {
	// Size capacity to declare the stream with. Ex: 10mb, 3gb, 1024k
	Size                 string   `protobuf:"bytes,1,opt,name=size,proto3" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeclareStream) Descriptor added in v0.0.32 

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

func (*DeclareStream) GetSize added in v0.0.32 

func (m *DeclareStream) GetSize() string

func (*DeclareStream) ProtoMessage added in v0.0.32 

func (*DeclareStream) ProtoMessage()

func (*DeclareStream) Reset added in v0.0.32 

func (m *DeclareStream) Reset()

func (*DeclareStream) String added in v0.0.32 

func (m *DeclareStream) String() string

func (*DeclareStream) XXX_DiscardUnknown added in v0.0.32 

func (m *DeclareStream) XXX_DiscardUnknown()

func (*DeclareStream) XXX_Marshal added in v0.0.32 

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

func (*DeclareStream) XXX_Merge added in v0.0.32 

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

func (*DeclareStream) XXX_Size added in v0.0.32 

func (m *DeclareStream) XXX_Size() int

func (*DeclareStream) XXX_Unmarshal added in v0.0.32 

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

type FirstOffset added in v0.0.32 

type FirstOffset struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FirstOffset) Descriptor added in v0.0.32 

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

func (*FirstOffset) ProtoMessage added in v0.0.32 

func (*FirstOffset) ProtoMessage()

func (*FirstOffset) Reset added in v0.0.32 

func (m *FirstOffset) Reset()

func (*FirstOffset) String added in v0.0.32 

func (m *FirstOffset) String() string

func (*FirstOffset) XXX_DiscardUnknown added in v0.0.32 

func (m *FirstOffset) XXX_DiscardUnknown()

func (*FirstOffset) XXX_Marshal added in v0.0.32 

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

func (*FirstOffset) XXX_Merge added in v0.0.32 

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

func (*FirstOffset) XXX_Size added in v0.0.32 

func (m *FirstOffset) XXX_Size() int

func (*FirstOffset) XXX_Unmarshal added in v0.0.32 

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

type Kafka 

type Kafka struct {
	// Required
	Topics []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// Optional; specify what offset the consumer should read from (only works if '--use-consumer-group' is false)
	ReadOffset int64 `protobuf:"varint,2,opt,name=read_offset,json=readOffset,proto3" json:"read_offset,omitempty"`
	// Optional: (default: true)
	UseConsumerGroup bool `protobuf:"varint,3,opt,name=use_consumer_group,json=useConsumerGroup,proto3" json:"use_consumer_group,omitempty"`
	// Optional; used only if "use_consumer_group" is true
	ConsumerGroupName string `protobuf:"bytes,4,opt,name=consumer_group_name,json=consumerGroupName,proto3" json:"consumer_group_name,omitempty"`
	// Optional; how long to wait for new data when reading batches of messages (default: 1s)
	MaxWaitSeconds int32 `protobuf:"varint,5,opt,name=max_wait_seconds,json=maxWaitSeconds,proto3" json:"max_wait_seconds,omitempty"`
	// Optional; minimum number of bytes to fetch in a single kafka request (throughput optimization)
	MinBytes int32 `protobuf:"varint,6,opt,name=min_bytes,json=minBytes,proto3" json:"min_bytes,omitempty"`
	// Optional; maximum number of bytes to fetch in a single kafka request (throughput optimization)
	MaxBytes int32 `protobuf:"varint,7,opt,name=max_bytes,json=maxBytes,proto3" json:"max_bytes,omitempty"`
	// Optional; how often to commit offsets to broker (default: 0 == synchronous)
	// NOTE: Used only-if "use_consumer_group" is true
	CommitIntervalSeconds int32 `` /* 127-byte string literal not displayed */
	// Optional; how long a coordinator will wait for member joins as part of a rebalance (default: 5s)
	RebalanceTimeoutSeconds int32    `` /* 133-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{} `json:"-"`
	XXX_unrecognized        []byte   `json:"-"`
	XXX_sizecache           int32    `json:"-"`
}

func (*Kafka) Descriptor 

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

func (*Kafka) GetCommitIntervalSeconds 

func (m *Kafka) GetCommitIntervalSeconds() int32

func (*Kafka) GetConsumerGroupName 

func (m *Kafka) GetConsumerGroupName() string

func (*Kafka) GetMaxBytes 

func (m *Kafka) GetMaxBytes() int32

func (*Kafka) GetMaxWaitSeconds 

func (m *Kafka) GetMaxWaitSeconds() int32

func (*Kafka) GetMinBytes 

func (m *Kafka) GetMinBytes() int32

func (*Kafka) GetReadOffset 

func (m *Kafka) GetReadOffset() int64

func (*Kafka) GetRebalanceTimeoutSeconds 

func (m *Kafka) GetRebalanceTimeoutSeconds() int32

func (*Kafka) GetTopics 

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

func (*Kafka) GetUseConsumerGroup 

func (m *Kafka) GetUseConsumerGroup() bool

func (*Kafka) ProtoMessage 

func (*Kafka) ProtoMessage()

func (*Kafka) Reset 

func (m *Kafka) Reset()

func (*Kafka) String 

func (m *Kafka) String() string

func (*Kafka) XXX_DiscardUnknown 

func (m *Kafka) XXX_DiscardUnknown()

func (*Kafka) XXX_Marshal 

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

func (*Kafka) XXX_Merge 

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

func (*Kafka) XXX_Size 

func (m *Kafka) XXX_Size() int

func (*Kafka) XXX_Unmarshal 

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

type LastConsumed added in v0.0.32 

type LastConsumed struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LastConsumed) Descriptor added in v0.0.32 

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

func (*LastConsumed) ProtoMessage added in v0.0.32 

func (*LastConsumed) ProtoMessage()

func (*LastConsumed) Reset added in v0.0.32 

func (m *LastConsumed) Reset()

func (*LastConsumed) String added in v0.0.32 

func (m *LastConsumed) String() string

func (*LastConsumed) XXX_DiscardUnknown added in v0.0.32 

func (m *LastConsumed) XXX_DiscardUnknown()

func (*LastConsumed) XXX_Marshal added in v0.0.32 

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

func (*LastConsumed) XXX_Merge added in v0.0.32 

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

func (*LastConsumed) XXX_Size added in v0.0.32 

func (m *LastConsumed) XXX_Size() int

func (*LastConsumed) XXX_Unmarshal added in v0.0.32 

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

type LastOffset added in v0.0.32 

type LastOffset struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LastOffset) Descriptor added in v0.0.32 

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

func (*LastOffset) ProtoMessage added in v0.0.32 

func (*LastOffset) ProtoMessage()

func (*LastOffset) Reset added in v0.0.32 

func (m *LastOffset) Reset()

func (*LastOffset) String added in v0.0.32 

func (m *LastOffset) String() string

func (*LastOffset) XXX_DiscardUnknown added in v0.0.32 

func (m *LastOffset) XXX_DiscardUnknown()

func (*LastOffset) XXX_Marshal added in v0.0.32 

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

func (*LastOffset) XXX_Merge added in v0.0.32 

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

func (*LastOffset) XXX_Size added in v0.0.32 

func (m *LastOffset) XXX_Size() int

func (*LastOffset) XXX_Unmarshal added in v0.0.32 

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

type Mongo added in v0.0.32 

type Mongo struct {
	// Optional
	// Specify to limit CDC changes to a single database of the mongo instance
	// Leave empty to get CDC changes from all databases
	Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	// Optional
	// Specify to limit CDC changes to a single collection.
	// Leave blank to get changes from all collections in the specified database
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// Include full document in update in update changes.
	// Default is to return deltas only
	IncludeFullDocument  bool     `protobuf:"varint,3,opt,name=include_full_document,json=includeFullDocument,proto3" json:"include_full_document,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Mongo) Descriptor added in v0.0.32 

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

func (*Mongo) GetCollection added in v0.0.32 

func (m *Mongo) GetCollection() string

func (*Mongo) GetDatabase added in v0.0.32 

func (m *Mongo) GetDatabase() string

func (*Mongo) GetIncludeFullDocument added in v0.0.32 

func (m *Mongo) GetIncludeFullDocument() bool

func (*Mongo) ProtoMessage added in v0.0.32 

func (*Mongo) ProtoMessage()

func (*Mongo) Reset added in v0.0.32 

func (m *Mongo) Reset()

func (*Mongo) String added in v0.0.32 

func (m *Mongo) String() string

func (*Mongo) XXX_DiscardUnknown added in v0.0.32 

func (m *Mongo) XXX_DiscardUnknown()

func (*Mongo) XXX_Marshal added in v0.0.32 

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

func (*Mongo) XXX_Merge added in v0.0.32 

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

func (*Mongo) XXX_Size added in v0.0.32 

func (m *Mongo) XXX_Size() int

func (*Mongo) XXX_Unmarshal added in v0.0.32 

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

type NSQ added in v0.0.32 

type NSQ struct {
	// Required
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Required for reads
	// Ignored for writes
	Channel              string   `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NSQ) Descriptor added in v0.0.32 

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

func (*NSQ) GetChannel added in v0.0.32 

func (m *NSQ) GetChannel() string

func (*NSQ) GetTopic added in v0.0.32 

func (m *NSQ) GetTopic() string

func (*NSQ) ProtoMessage added in v0.0.32 

func (*NSQ) ProtoMessage()

func (*NSQ) Reset added in v0.0.32 

func (m *NSQ) Reset()

func (*NSQ) String added in v0.0.32 

func (m *NSQ) String() string

func (*NSQ) XXX_DiscardUnknown added in v0.0.32 

func (m *NSQ) XXX_DiscardUnknown()

func (*NSQ) XXX_Marshal added in v0.0.32 

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

func (*NSQ) XXX_Merge added in v0.0.32 

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

func (*NSQ) XXX_Size added in v0.0.32 

func (m *NSQ) XXX_Size() int

func (*NSQ) XXX_Unmarshal added in v0.0.32 

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

type Nats added in v0.0.32 

type Nats struct {
	// Subject to read from/write to. Ex: "foo.bar.*"
	Subject              string   `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Nats) Descriptor added in v0.0.32 

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

func (*Nats) GetSubject added in v0.0.32 

func (m *Nats) GetSubject() string

func (*Nats) ProtoMessage added in v0.0.32 

func (*Nats) ProtoMessage()

func (*Nats) Reset added in v0.0.32 

func (m *Nats) Reset()

func (*Nats) String added in v0.0.32 

func (m *Nats) String() string

func (*Nats) XXX_DiscardUnknown added in v0.0.32 

func (m *Nats) XXX_DiscardUnknown()

func (*Nats) XXX_Marshal added in v0.0.32 

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

func (*Nats) XXX_Merge added in v0.0.32 

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

func (*Nats) XXX_Size added in v0.0.32 

func (m *Nats) XXX_Size() int

func (*Nats) XXX_Unmarshal added in v0.0.32 

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

type NatsStreaming added in v0.0.32 

type NatsStreaming struct {
	// Required
	// Channel name to read from/write to
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// Optional
	// Create a durable subscription with this name for the given channel
	DurableName string `protobuf:"bytes,2,opt,name=durable_name,json=durableName,proto3" json:"durable_name,omitempty"`
	// Types that are valid to be assigned to ReadOption:
	//	*NatsStreaming_LastAvailable
	//	*NatsStreaming_ReadSequenceNumber
	//	*NatsStreaming_ReadSince
	//	*NatsStreaming_All
	ReadOption           isNatsStreaming_ReadOption `protobuf_oneof:"read_option"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*NatsStreaming) Descriptor added in v0.0.32 

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

func (*NatsStreaming) GetAll added in v0.0.32 

func (m *NatsStreaming) GetAll() *ReadAll

func (*NatsStreaming) GetChannel added in v0.0.32 

func (m *NatsStreaming) GetChannel() string

func (*NatsStreaming) GetDurableName added in v0.0.32 

func (m *NatsStreaming) GetDurableName() string

func (*NatsStreaming) GetLastAvailable added in v0.0.32 

func (m *NatsStreaming) GetLastAvailable() *ReadLastAvailable

func (*NatsStreaming) GetReadOption added in v0.0.32 

func (m *NatsStreaming) GetReadOption() isNatsStreaming_ReadOption

func (*NatsStreaming) GetReadSequenceNumber added in v0.0.32 

func (m *NatsStreaming) GetReadSequenceNumber() *ReadSequenceNumber

func (*NatsStreaming) GetReadSince added in v0.0.32 

func (m *NatsStreaming) GetReadSince() *ReadSince

func (*NatsStreaming) ProtoMessage added in v0.0.32 

func (*NatsStreaming) ProtoMessage()

func (*NatsStreaming) Reset added in v0.0.32 

func (m *NatsStreaming) Reset()

func (*NatsStreaming) String added in v0.0.32 

func (m *NatsStreaming) String() string

func (*NatsStreaming) XXX_DiscardUnknown added in v0.0.32 

func (m *NatsStreaming) XXX_DiscardUnknown()

func (*NatsStreaming) XXX_Marshal added in v0.0.32 

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

func (*NatsStreaming) XXX_Merge added in v0.0.32 

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

func (*NatsStreaming) XXX_OneofWrappers added in v0.0.32 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*NatsStreaming) XXX_Size added in v0.0.32 

func (m *NatsStreaming) XXX_Size() int

func (*NatsStreaming) XXX_Unmarshal added in v0.0.32 

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

type NatsStreaming_All added in v0.0.32 

type NatsStreaming_All struct {
	All *ReadAll `protobuf:"bytes,103,opt,name=all,proto3,oneof"`
}

type NatsStreaming_LastAvailable added in v0.0.32 

type NatsStreaming_LastAvailable struct {
	LastAvailable *ReadLastAvailable `protobuf:"bytes,100,opt,name=last_available,json=lastAvailable,proto3,oneof"`
}

type NatsStreaming_ReadSequenceNumber added in v0.0.32 

type NatsStreaming_ReadSequenceNumber struct {
	ReadSequenceNumber *ReadSequenceNumber `protobuf:"bytes,101,opt,name=read_sequence_number,json=readSequenceNumber,proto3,oneof"`
}

type NatsStreaming_ReadSince added in v0.0.32 

type NatsStreaming_ReadSince struct {
	ReadSince *ReadSince `protobuf:"bytes,102,opt,name=read_since,json=readSince,proto3,oneof"`
}

type NextOffset added in v0.0.32 

type NextOffset struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NextOffset) Descriptor added in v0.0.32 

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

func (*NextOffset) ProtoMessage added in v0.0.32 

func (*NextOffset) ProtoMessage()

func (*NextOffset) Reset added in v0.0.32 

func (m *NextOffset) Reset()

func (*NextOffset) String added in v0.0.32 

func (m *NextOffset) String() string

func (*NextOffset) XXX_DiscardUnknown added in v0.0.32 

func (m *NextOffset) XXX_DiscardUnknown()

func (*NextOffset) XXX_Marshal added in v0.0.32 

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

func (*NextOffset) XXX_Merge added in v0.0.32 

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

func (*NextOffset) XXX_Size added in v0.0.32 

func (m *NextOffset) XXX_Size() int

func (*NextOffset) XXX_Unmarshal added in v0.0.32 

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

type Postgres added in v0.0.32 

type Postgres struct {
	ReplicationSlotName  string   `protobuf:"bytes,2,opt,name=replication_slot_name,json=replicationSlotName,proto3" json:"replication_slot_name,omitempty"`
	PublisherName        string   `protobuf:"bytes,3,opt,name=publisher_name,json=publisherName,proto3" json:"publisher_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Postgres) Descriptor added in v0.0.32 

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

func (*Postgres) GetPublisherName added in v0.0.32 

func (m *Postgres) GetPublisherName() string

func (*Postgres) GetReplicationSlotName added in v0.0.32 

func (m *Postgres) GetReplicationSlotName() string

func (*Postgres) ProtoMessage added in v0.0.32 

func (*Postgres) ProtoMessage()

func (*Postgres) Reset added in v0.0.32 

func (m *Postgres) Reset()

func (*Postgres) String added in v0.0.32 

func (m *Postgres) String() string

func (*Postgres) XXX_DiscardUnknown added in v0.0.32 

func (m *Postgres) XXX_DiscardUnknown()

func (*Postgres) XXX_Marshal added in v0.0.32 

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

func (*Postgres) XXX_Merge added in v0.0.32 

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

func (*Postgres) XXX_Size added in v0.0.32 

func (m *Postgres) XXX_Size() int

func (*Postgres) XXX_Unmarshal added in v0.0.32 

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

type Pulsar added in v0.0.32 

type Pulsar struct {
	// Required
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Required for reads
	// Ignored for writes
	SubscriptionName string `protobuf:"bytes,2,opt,name=subscription_name,json=subscriptionName,proto3" json:"subscription_name,omitempty"`
	// Required for reads
	// Ignored for writes
	SubscriptionType     SubscriptionType `` /* 148-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Pulsar) Descriptor added in v0.0.32 

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

func (*Pulsar) GetSubscriptionName added in v0.0.32 

func (m *Pulsar) GetSubscriptionName() string

func (*Pulsar) GetSubscriptionType added in v0.0.32 

func (m *Pulsar) GetSubscriptionType() SubscriptionType

func (*Pulsar) GetTopic added in v0.0.32 

func (m *Pulsar) GetTopic() string

func (*Pulsar) ProtoMessage added in v0.0.32 

func (*Pulsar) ProtoMessage()

func (*Pulsar) Reset added in v0.0.32 

func (m *Pulsar) Reset()

func (*Pulsar) String added in v0.0.32 

func (m *Pulsar) String() string

func (*Pulsar) XXX_DiscardUnknown added in v0.0.32 

func (m *Pulsar) XXX_DiscardUnknown()

func (*Pulsar) XXX_Marshal added in v0.0.32 

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

func (*Pulsar) XXX_Merge added in v0.0.32 

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

func (*Pulsar) XXX_Size added in v0.0.32 

func (m *Pulsar) XXX_Size() int

func (*Pulsar) XXX_Unmarshal added in v0.0.32 

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

type Rabbit added in v0.0.32 

type Rabbit struct {
	// Required for reading and writing
	ExchangeName string `protobuf:"bytes,1,opt,name=exchange_name,json=exchangeName,proto3" json:"exchange_name,omitempty"`
	// Reading only
	// Queue name to read from
	QueueName string `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	// Routing key for topic based exchanges
	RoutingKey string `protobuf:"bytes,3,opt,name=routing_key,json=routingKey,proto3" json:"routing_key,omitempty"`
	// Reading only
	// Whether the queue is exclusive to this connection
	QueueExclusive bool `protobuf:"varint,4,opt,name=queue_exclusive,json=queueExclusive,proto3" json:"queue_exclusive,omitempty"`
	// Reading only
	// Whether to create the queue
	QueueDeclare bool `protobuf:"varint,5,opt,name=queue_declare,json=queueDeclare,proto3" json:"queue_declare,omitempty"`
	// Reading only
	// Whether the queue should survive after disconnect
	QueueDurable bool `protobuf:"varint,6,opt,name=queue_durable,json=queueDurable,proto3" json:"queue_durable,omitempty"`
	// Reading only
	AutoAck bool `protobuf:"varint,7,opt,name=auto_ack,json=autoAck,proto3" json:"auto_ack,omitempty"`
	// Reading only
	AppId                string   `protobuf:"bytes,8,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Rabbit) Descriptor added in v0.0.32 

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

func (*Rabbit) GetAppId added in v0.0.32 

func (m *Rabbit) GetAppId() string

func (*Rabbit) GetAutoAck added in v0.0.32 

func (m *Rabbit) GetAutoAck() bool

func (*Rabbit) GetExchangeName added in v0.0.32 

func (m *Rabbit) GetExchangeName() string

func (*Rabbit) GetQueueDeclare added in v0.0.32 

func (m *Rabbit) GetQueueDeclare() bool

func (*Rabbit) GetQueueDurable added in v0.0.32 

func (m *Rabbit) GetQueueDurable() bool

func (*Rabbit) GetQueueExclusive added in v0.0.32 

func (m *Rabbit) GetQueueExclusive() bool

func (*Rabbit) GetQueueName added in v0.0.32 

func (m *Rabbit) GetQueueName() string

func (*Rabbit) GetRoutingKey added in v0.0.32 

func (m *Rabbit) GetRoutingKey() string

func (*Rabbit) ProtoMessage added in v0.0.32 

func (*Rabbit) ProtoMessage()

func (*Rabbit) Reset added in v0.0.32 

func (m *Rabbit) Reset()

func (*Rabbit) String added in v0.0.32 

func (m *Rabbit) String() string

func (*Rabbit) XXX_DiscardUnknown added in v0.0.32 

func (m *Rabbit) XXX_DiscardUnknown()

func (*Rabbit) XXX_Marshal added in v0.0.32 

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

func (*Rabbit) XXX_Merge added in v0.0.32 

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

func (*Rabbit) XXX_Size added in v0.0.32 

func (m *Rabbit) XXX_Size() int

func (*Rabbit) XXX_Unmarshal added in v0.0.32 

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

type RabbitStreams added in v0.0.32 

type RabbitStreams struct {
	// Required
	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	// Optional
	// If specified, stream will be declared
	DeclareStream *DeclareStream `protobuf:"bytes,2,opt,name=declare_stream,json=declareStream,proto3" json:"declare_stream,omitempty"`
	// Types that are valid to be assigned to OffsetOption:
	//	*RabbitStreams_Offset
	//	*RabbitStreams_LastOffset
	//	*RabbitStreams_LastConsumed
	//	*RabbitStreams_FirstOffset
	//	*RabbitStreams_NextOffset
	OffsetOption         isRabbitStreams_OffsetOption `protobuf_oneof:"offset_option"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*RabbitStreams) Descriptor added in v0.0.32 

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

func (*RabbitStreams) GetDeclareStream added in v0.0.32 

func (m *RabbitStreams) GetDeclareStream() *DeclareStream

func (*RabbitStreams) GetFirstOffset added in v0.0.32 

func (m *RabbitStreams) GetFirstOffset() *FirstOffset

func (*RabbitStreams) GetLastConsumed added in v0.0.32 

func (m *RabbitStreams) GetLastConsumed() *LastConsumed

func (*RabbitStreams) GetLastOffset added in v0.0.32 

func (m *RabbitStreams) GetLastOffset() *LastOffset

func (*RabbitStreams) GetNextOffset added in v0.0.32 

func (m *RabbitStreams) GetNextOffset() *NextOffset

func (*RabbitStreams) GetOffset added in v0.0.32 

func (m *RabbitStreams) GetOffset() *SpecificOffset

func (*RabbitStreams) GetOffsetOption added in v0.0.32 

func (m *RabbitStreams) GetOffsetOption() isRabbitStreams_OffsetOption

func (*RabbitStreams) GetStream added in v0.0.32 

func (m *RabbitStreams) GetStream() string

func (*RabbitStreams) ProtoMessage added in v0.0.32 

func (*RabbitStreams) ProtoMessage()

func (*RabbitStreams) Reset added in v0.0.32 

func (m *RabbitStreams) Reset()

func (*RabbitStreams) String added in v0.0.32 

func (m *RabbitStreams) String() string

func (*RabbitStreams) XXX_DiscardUnknown added in v0.0.32 

func (m *RabbitStreams) XXX_DiscardUnknown()

func (*RabbitStreams) XXX_Marshal added in v0.0.32 

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

func (*RabbitStreams) XXX_Merge added in v0.0.32 

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

func (*RabbitStreams) XXX_OneofWrappers added in v0.0.32 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*RabbitStreams) XXX_Size added in v0.0.32 

func (m *RabbitStreams) XXX_Size() int

func (*RabbitStreams) XXX_Unmarshal added in v0.0.32 

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

type RabbitStreams_FirstOffset added in v0.0.32 

type RabbitStreams_FirstOffset struct {
	FirstOffset *FirstOffset `protobuf:"bytes,104,opt,name=first_offset,json=firstOffset,proto3,oneof"`
}

type RabbitStreams_LastConsumed added in v0.0.32 

type RabbitStreams_LastConsumed struct {
	LastConsumed *LastConsumed `protobuf:"bytes,103,opt,name=last_consumed,json=lastConsumed,proto3,oneof"`
}

type RabbitStreams_LastOffset added in v0.0.32 

type RabbitStreams_LastOffset struct {
	LastOffset *LastOffset `protobuf:"bytes,102,opt,name=last_offset,json=lastOffset,proto3,oneof"`
}

type RabbitStreams_NextOffset added in v0.0.32 

type RabbitStreams_NextOffset struct {
	NextOffset *NextOffset `protobuf:"bytes,105,opt,name=next_offset,json=nextOffset,proto3,oneof"`
}

type RabbitStreams_Offset added in v0.0.32 

type RabbitStreams_Offset struct {
	Offset *SpecificOffset `protobuf:"bytes,101,opt,name=offset,proto3,oneof"`
}

type ReadAll added in v0.0.32 

type ReadAll struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadAll) Descriptor added in v0.0.32 

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

func (*ReadAll) ProtoMessage added in v0.0.32 

func (*ReadAll) ProtoMessage()

func (*ReadAll) Reset added in v0.0.32 

func (m *ReadAll) Reset()

func (*ReadAll) String added in v0.0.32 

func (m *ReadAll) String() string

func (*ReadAll) XXX_DiscardUnknown added in v0.0.32 

func (m *ReadAll) XXX_DiscardUnknown()

func (*ReadAll) XXX_Marshal added in v0.0.32 

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

func (*ReadAll) XXX_Merge added in v0.0.32 

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

func (*ReadAll) XXX_Size added in v0.0.32 

func (m *ReadAll) XXX_Size() int

func (*ReadAll) XXX_Unmarshal added in v0.0.32 

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

type ReadLastAvailable added in v0.0.32 

type ReadLastAvailable struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadLastAvailable) Descriptor added in v0.0.32 

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

func (*ReadLastAvailable) ProtoMessage added in v0.0.32 

func (*ReadLastAvailable) ProtoMessage()

func (*ReadLastAvailable) Reset added in v0.0.32 

func (m *ReadLastAvailable) Reset()

func (*ReadLastAvailable) String added in v0.0.32 

func (m *ReadLastAvailable) String() string

func (*ReadLastAvailable) XXX_DiscardUnknown added in v0.0.32 

func (m *ReadLastAvailable) XXX_DiscardUnknown()

func (*ReadLastAvailable) XXX_Marshal added in v0.0.32 

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

func (*ReadLastAvailable) XXX_Merge added in v0.0.32 

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

func (*ReadLastAvailable) XXX_Size added in v0.0.32 

func (m *ReadLastAvailable) XXX_Size() int

func (*ReadLastAvailable) XXX_Unmarshal added in v0.0.32 

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

type ReadSequenceNumber added in v0.0.32 

type ReadSequenceNumber struct {
	SequenceNumber       uint32   `protobuf:"varint,1,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadSequenceNumber) Descriptor added in v0.0.32 

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

func (*ReadSequenceNumber) GetSequenceNumber added in v0.0.32 

func (m *ReadSequenceNumber) GetSequenceNumber() uint32

func (*ReadSequenceNumber) ProtoMessage added in v0.0.32 

func (*ReadSequenceNumber) ProtoMessage()

func (*ReadSequenceNumber) Reset added in v0.0.32 

func (m *ReadSequenceNumber) Reset()

func (*ReadSequenceNumber) String added in v0.0.32 

func (m *ReadSequenceNumber) String() string

func (*ReadSequenceNumber) XXX_DiscardUnknown added in v0.0.32 

func (m *ReadSequenceNumber) XXX_DiscardUnknown()

func (*ReadSequenceNumber) XXX_Marshal added in v0.0.32 

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

func (*ReadSequenceNumber) XXX_Merge added in v0.0.32 

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

func (*ReadSequenceNumber) XXX_Size added in v0.0.32 

func (m *ReadSequenceNumber) XXX_Size() int

func (*ReadSequenceNumber) XXX_Unmarshal added in v0.0.32 

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

type ReadSince added in v0.0.32 

type ReadSince struct {
	// Ex: 1s, 15m, 3h, 10h
	Since                string   `protobuf:"bytes,1,opt,name=since,proto3" json:"since,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadSince) Descriptor added in v0.0.32 

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

func (*ReadSince) GetSince added in v0.0.32 

func (m *ReadSince) GetSince() string

func (*ReadSince) ProtoMessage added in v0.0.32 

func (*ReadSince) ProtoMessage()

func (*ReadSince) Reset added in v0.0.32 

func (m *ReadSince) Reset()

func (*ReadSince) String added in v0.0.32 

func (m *ReadSince) String() string

func (*ReadSince) XXX_DiscardUnknown added in v0.0.32 

func (m *ReadSince) XXX_DiscardUnknown()

func (*ReadSince) XXX_Marshal added in v0.0.32 

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

func (*ReadSince) XXX_Merge added in v0.0.32 

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

func (*ReadSince) XXX_Size added in v0.0.32 

func (m *ReadSince) XXX_Size() int

func (*ReadSince) XXX_Unmarshal added in v0.0.32 

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

type RedisPubsub added in v0.0.32 

type RedisPubsub struct {
	// Required
	// Database (0-16)
	Database uint32 `protobuf:"varint,1,opt,name=database,proto3" json:"database,omitempty"`
	// Required
	// Channel(s) to read from/write to
	Channel              []string `protobuf:"bytes,2,rep,name=channel,proto3" json:"channel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RedisPubsub) Descriptor added in v0.0.32 

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

func (*RedisPubsub) GetChannel added in v0.0.32 

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

func (*RedisPubsub) GetDatabase added in v0.0.32 

func (m *RedisPubsub) GetDatabase() uint32

func (*RedisPubsub) ProtoMessage added in v0.0.32 

func (*RedisPubsub) ProtoMessage()

func (*RedisPubsub) Reset added in v0.0.32 

func (m *RedisPubsub) Reset()

func (*RedisPubsub) String added in v0.0.32 

func (m *RedisPubsub) String() string

func (*RedisPubsub) XXX_DiscardUnknown added in v0.0.32 

func (m *RedisPubsub) XXX_DiscardUnknown()

func (*RedisPubsub) XXX_Marshal added in v0.0.32 

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

func (*RedisPubsub) XXX_Merge added in v0.0.32 

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

func (*RedisPubsub) XXX_Size added in v0.0.32 

func (m *RedisPubsub) XXX_Size() int

func (*RedisPubsub) XXX_Unmarshal added in v0.0.32 

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

type RedisStreams added in v0.0.32 

type RedisStreams struct {
	// Required
	// Database (0-16)
	Database uint32 `protobuf:"varint,1,opt,name=database,proto3" json:"database,omitempty"`
	// Required
	// Stream(s) to read from/write to
	Stream []string `protobuf:"bytes,2,rep,name=stream,proto3" json:"stream,omitempty"`
	// Optional for Writes
	// Ignored for reads
	// Default is "*", which means redis will auto generate it
	Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// Required for writes
	// Ignored for reads
	Key           string `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	ConsumerGroup string `protobuf:"bytes,5,opt,name=consumer_group,json=consumerGroup,proto3" json:"consumer_group,omitempty"`
	ConsumerName  string `protobuf:"bytes,6,opt,name=consumer_name,json=consumerName,proto3" json:"consumer_name,omitempty"`
	// Optional for reads
	// Ignored for writes
	// Specify if you the user needs to create/recreate a consumer group
	CreateConsumerConfig *CreateConsumerConfig `protobuf:"bytes,7,opt,name=create_consumer_config,json=createConsumerConfig,proto3" json:"create_consumer_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*RedisStreams) Descriptor added in v0.0.32 

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

func (*RedisStreams) GetConsumerGroup added in v0.0.32 

func (m *RedisStreams) GetConsumerGroup() string

func (*RedisStreams) GetConsumerName added in v0.0.32 

func (m *RedisStreams) GetConsumerName() string

func (*RedisStreams) GetCreateConsumerConfig added in v0.0.32 

func (m *RedisStreams) GetCreateConsumerConfig() *CreateConsumerConfig

func (*RedisStreams) GetDatabase added in v0.0.32 

func (m *RedisStreams) GetDatabase() uint32

func (*RedisStreams) GetId added in v0.0.32 

func (m *RedisStreams) GetId() string

func (*RedisStreams) GetKey added in v0.0.32 

func (m *RedisStreams) GetKey() string

func (*RedisStreams) GetStream added in v0.0.32 

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

func (*RedisStreams) ProtoMessage added in v0.0.32 

func (*RedisStreams) ProtoMessage()

func (*RedisStreams) Reset added in v0.0.32 

func (m *RedisStreams) Reset()

func (*RedisStreams) String added in v0.0.32 

func (m *RedisStreams) String() string

func (*RedisStreams) XXX_DiscardUnknown added in v0.0.32 

func (m *RedisStreams) XXX_DiscardUnknown()

func (*RedisStreams) XXX_Marshal added in v0.0.32 

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

func (*RedisStreams) XXX_Merge added in v0.0.32 

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

func (*RedisStreams) XXX_Size added in v0.0.32 

func (m *RedisStreams) XXX_Size() int

func (*RedisStreams) XXX_Unmarshal added in v0.0.32 

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

type SpecificOffset added in v0.0.32 

type SpecificOffset struct {
	Offset               uint64   `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SpecificOffset) Descriptor added in v0.0.32 

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

func (*SpecificOffset) GetOffset added in v0.0.32 

func (m *SpecificOffset) GetOffset() uint64

func (*SpecificOffset) ProtoMessage added in v0.0.32 

func (*SpecificOffset) ProtoMessage()

func (*SpecificOffset) Reset added in v0.0.32 

func (m *SpecificOffset) Reset()

func (*SpecificOffset) String added in v0.0.32 

func (m *SpecificOffset) String() string

func (*SpecificOffset) XXX_DiscardUnknown added in v0.0.32 

func (m *SpecificOffset) XXX_DiscardUnknown()

func (*SpecificOffset) XXX_Marshal added in v0.0.32 

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

func (*SpecificOffset) XXX_Merge added in v0.0.32 

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

func (*SpecificOffset) XXX_Size added in v0.0.32 

func (m *SpecificOffset) XXX_Size() int

func (*SpecificOffset) XXX_Unmarshal added in v0.0.32 

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

type SubscriptionType added in v0.0.32 

type SubscriptionType int32
const (
	SubscriptionType_Unset     SubscriptionType = 0
	SubscriptionType_Shared    SubscriptionType = 1
	SubscriptionType_Exclusive SubscriptionType = 2
	SubscriptionType_Failover  SubscriptionType = 3
	SubscriptionType_Keyshared SubscriptionType = 4
)

func (SubscriptionType) EnumDescriptor added in v0.0.32 

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

func (SubscriptionType) String added in v0.0.32 

func (x SubscriptionType) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.