records

package
v0.0.80 Latest Latest
Warning

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

 Go to latest Published: Oct 13, 2021 License: Apache-2.0 Imports: 3 Imported by: 31

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AWSSQS added in v0.0.77 

type AWSSQS struct {
	Id                   string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Timestamp            int64             `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	RecipientHandle      string            `protobuf:"bytes,3,opt,name=recipient_handle,json=recipientHandle,proto3" json:"recipient_handle,omitempty"`
	Attributes           map[string]string `` /* 161-byte string literal not displayed */
	Value                []byte            `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*AWSSQS) Descriptor added in v0.0.77 

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

func (*AWSSQS) GetAttributes added in v0.0.77 

func (m *AWSSQS) GetAttributes() map[string]string

func (*AWSSQS) GetId added in v0.0.77 

func (m *AWSSQS) GetId() string

func (*AWSSQS) GetRecipientHandle added in v0.0.77 

func (m *AWSSQS) GetRecipientHandle() string

func (*AWSSQS) GetTimestamp added in v0.0.77 

func (m *AWSSQS) GetTimestamp() int64

func (*AWSSQS) GetValue added in v0.0.77 

func (m *AWSSQS) GetValue() []byte

func (*AWSSQS) ProtoMessage added in v0.0.77 

func (*AWSSQS) ProtoMessage()

func (*AWSSQS) Reset added in v0.0.77 

func (m *AWSSQS) Reset()

func (*AWSSQS) String added in v0.0.77 

func (m *AWSSQS) String() string

func (*AWSSQS) XXX_DiscardUnknown added in v0.0.77 

func (m *AWSSQS) XXX_DiscardUnknown()

func (*AWSSQS) XXX_Marshal added in v0.0.77 

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

func (*AWSSQS) XXX_Merge added in v0.0.77 

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

func (*AWSSQS) XXX_Size added in v0.0.77 

func (m *AWSSQS) XXX_Size() int

func (*AWSSQS) XXX_Unmarshal added in v0.0.77 

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

type ActiveMQ added in v0.0.77 

type ActiveMQ struct {
	Destination          string   `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	ContentType          string   `protobuf:"bytes,2,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	SubscriptionId       string   `protobuf:"bytes,3,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	Timestamp            int64    `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value                []byte   `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActiveMQ) Descriptor added in v0.0.77 

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

func (*ActiveMQ) GetContentType added in v0.0.77 

func (m *ActiveMQ) GetContentType() string

func (*ActiveMQ) GetDestination added in v0.0.77 

func (m *ActiveMQ) GetDestination() string

func (*ActiveMQ) GetSubscriptionId added in v0.0.77 

func (m *ActiveMQ) GetSubscriptionId() string

func (*ActiveMQ) GetTimestamp added in v0.0.77 

func (m *ActiveMQ) GetTimestamp() int64

func (*ActiveMQ) GetValue added in v0.0.77 

func (m *ActiveMQ) GetValue() []byte

func (*ActiveMQ) ProtoMessage added in v0.0.77 

func (*ActiveMQ) ProtoMessage()

func (*ActiveMQ) Reset added in v0.0.77 

func (m *ActiveMQ) Reset()

func (*ActiveMQ) String added in v0.0.77 

func (m *ActiveMQ) String() string

func (*ActiveMQ) XXX_DiscardUnknown added in v0.0.77 

func (m *ActiveMQ) XXX_DiscardUnknown()

func (*ActiveMQ) XXX_Marshal added in v0.0.77 

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

func (*ActiveMQ) XXX_Merge added in v0.0.77 

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

func (*ActiveMQ) XXX_Size added in v0.0.77 

func (m *ActiveMQ) XXX_Size() int

func (*ActiveMQ) XXX_Unmarshal added in v0.0.77 

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

type AzureEventHub added in v0.0.77 

type AzureEventHub struct {
	Id                   string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	SystemProperties     map[string]string `` /* 197-byte string literal not displayed */
	Timestamp            int64             `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value                []byte            `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*AzureEventHub) Descriptor added in v0.0.77 

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

func (*AzureEventHub) GetId added in v0.0.77 

func (m *AzureEventHub) GetId() string

func (*AzureEventHub) GetSystemProperties added in v0.0.77 

func (m *AzureEventHub) GetSystemProperties() map[string]string

func (*AzureEventHub) GetTimestamp added in v0.0.77 

func (m *AzureEventHub) GetTimestamp() int64

func (*AzureEventHub) GetValue added in v0.0.77 

func (m *AzureEventHub) GetValue() []byte

func (*AzureEventHub) ProtoMessage added in v0.0.77 

func (*AzureEventHub) ProtoMessage()

func (*AzureEventHub) Reset added in v0.0.77 

func (m *AzureEventHub) Reset()

func (*AzureEventHub) String added in v0.0.77 

func (m *AzureEventHub) String() string

func (*AzureEventHub) XXX_DiscardUnknown added in v0.0.77 

func (m *AzureEventHub) XXX_DiscardUnknown()

func (*AzureEventHub) XXX_Marshal added in v0.0.77 

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

func (*AzureEventHub) XXX_Merge added in v0.0.77 

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

func (*AzureEventHub) XXX_Size added in v0.0.77 

func (m *AzureEventHub) XXX_Size() int

func (*AzureEventHub) XXX_Unmarshal added in v0.0.77 

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

type AzureServiceBus added in v0.0.77 

type AzureServiceBus struct {
	ContentType          string                 `protobuf:"bytes,1,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	CorrelationId        string                 `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Value                []byte                 `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	DeliveryCount        uint32                 `protobuf:"varint,4,opt,name=delivery_count,json=deliveryCount,proto3" json:"delivery_count,omitempty"`
	SessionId            string                 `protobuf:"bytes,5,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	GroupSequence        uint32                 `protobuf:"varint,6,opt,name=group_sequence,json=groupSequence,proto3" json:"group_sequence,omitempty"`
	Id                   string                 `protobuf:"bytes,7,opt,name=id,proto3" json:"id,omitempty"`
	Label                string                 `protobuf:"bytes,8,opt,name=label,proto3" json:"label,omitempty"`
	ReplyTo              string                 `protobuf:"bytes,9,opt,name=reply_to,json=replyTo,proto3" json:"reply_to,omitempty"`
	ReplyToGroupId       string                 `protobuf:"bytes,10,opt,name=reply_to_group_id,json=replyToGroupId,proto3" json:"reply_to_group_id,omitempty"`
	To                   string                 `protobuf:"bytes,11,opt,name=to,proto3" json:"to,omitempty"`
	Ttl                  int64                  `protobuf:"varint,12,opt,name=ttl,proto3" json:"ttl,omitempty"`
	LockToken            string                 `protobuf:"bytes,13,opt,name=lock_token,json=lockToken,proto3" json:"lock_token,omitempty"`
	SystemProperties     *AzureSystemProperties `protobuf:"bytes,14,opt,name=system_properties,json=systemProperties,proto3" json:"system_properties,omitempty"`
	UserProperties       map[string]string      `` /* 192-byte string literal not displayed */
	Format               uint32                 `protobuf:"varint,16,opt,name=format,proto3" json:"format,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*AzureServiceBus) Descriptor added in v0.0.77 

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

func (*AzureServiceBus) GetContentType added in v0.0.77 

func (m *AzureServiceBus) GetContentType() string

func (*AzureServiceBus) GetCorrelationId added in v0.0.77 

func (m *AzureServiceBus) GetCorrelationId() string

func (*AzureServiceBus) GetDeliveryCount added in v0.0.77 

func (m *AzureServiceBus) GetDeliveryCount() uint32

func (*AzureServiceBus) GetFormat added in v0.0.77 

func (m *AzureServiceBus) GetFormat() uint32

func (*AzureServiceBus) GetGroupSequence added in v0.0.77 

func (m *AzureServiceBus) GetGroupSequence() uint32

func (*AzureServiceBus) GetId added in v0.0.77 

func (m *AzureServiceBus) GetId() string

func (*AzureServiceBus) GetLabel added in v0.0.77 

func (m *AzureServiceBus) GetLabel() string

func (*AzureServiceBus) GetLockToken added in v0.0.77 

func (m *AzureServiceBus) GetLockToken() string

func (*AzureServiceBus) GetReplyTo added in v0.0.77 

func (m *AzureServiceBus) GetReplyTo() string

func (*AzureServiceBus) GetReplyToGroupId added in v0.0.77 

func (m *AzureServiceBus) GetReplyToGroupId() string

func (*AzureServiceBus) GetSessionId added in v0.0.77 

func (m *AzureServiceBus) GetSessionId() string

func (*AzureServiceBus) GetSystemProperties added in v0.0.77 

func (m *AzureServiceBus) GetSystemProperties() *AzureSystemProperties

func (*AzureServiceBus) GetTo added in v0.0.77 

func (m *AzureServiceBus) GetTo() string

func (*AzureServiceBus) GetTtl added in v0.0.77 

func (m *AzureServiceBus) GetTtl() int64

func (*AzureServiceBus) GetUserProperties added in v0.0.77 

func (m *AzureServiceBus) GetUserProperties() map[string]string

func (*AzureServiceBus) GetValue added in v0.0.77 

func (m *AzureServiceBus) GetValue() []byte

func (*AzureServiceBus) ProtoMessage added in v0.0.77 

func (*AzureServiceBus) ProtoMessage()

func (*AzureServiceBus) Reset added in v0.0.77 

func (m *AzureServiceBus) Reset()

func (*AzureServiceBus) String added in v0.0.77 

func (m *AzureServiceBus) String() string

func (*AzureServiceBus) XXX_DiscardUnknown added in v0.0.77 

func (m *AzureServiceBus) XXX_DiscardUnknown()

func (*AzureServiceBus) XXX_Marshal added in v0.0.77 

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

func (*AzureServiceBus) XXX_Merge added in v0.0.77 

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

func (*AzureServiceBus) XXX_Size added in v0.0.77 

func (m *AzureServiceBus) XXX_Size() int

func (*AzureServiceBus) XXX_Unmarshal added in v0.0.77 

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

type AzureSystemProperties added in v0.0.77 

type AzureSystemProperties struct {
	LockedUntil            int64             `protobuf:"varint,1,opt,name=locked_until,json=lockedUntil,proto3" json:"locked_until,omitempty"`
	SequenceNumber         int64             `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	PartitionId            int32             `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	PartitionKey           string            `protobuf:"bytes,4,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	EnqueuedTime           int64             `protobuf:"varint,5,opt,name=enqueued_time,json=enqueuedTime,proto3" json:"enqueued_time,omitempty"`
	DeadLetterSource       string            `protobuf:"bytes,6,opt,name=dead_letter_source,json=deadLetterSource,proto3" json:"dead_letter_source,omitempty"`
	ScheduledEnqueueTime   int64             `protobuf:"varint,7,opt,name=scheduled_enqueue_time,json=scheduledEnqueueTime,proto3" json:"scheduled_enqueue_time,omitempty"`
	EnqueuedSequenceNumber int64             `` /* 130-byte string literal not displayed */
	ViaPartitionKey        string            `protobuf:"bytes,9,opt,name=via_partition_key,json=viaPartitionKey,proto3" json:"via_partition_key,omitempty"`
	Annotations            map[string]string `` /* 164-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{}          `json:"-"`
	XXX_unrecognized       []byte            `json:"-"`
	XXX_sizecache          int32             `json:"-"`
}

func (*AzureSystemProperties) Descriptor added in v0.0.77 

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

func (*AzureSystemProperties) GetAnnotations added in v0.0.77 

func (m *AzureSystemProperties) GetAnnotations() map[string]string

func (*AzureSystemProperties) GetDeadLetterSource added in v0.0.77 

func (m *AzureSystemProperties) GetDeadLetterSource() string

func (*AzureSystemProperties) GetEnqueuedSequenceNumber added in v0.0.77 

func (m *AzureSystemProperties) GetEnqueuedSequenceNumber() int64

func (*AzureSystemProperties) GetEnqueuedTime added in v0.0.77 

func (m *AzureSystemProperties) GetEnqueuedTime() int64

func (*AzureSystemProperties) GetLockedUntil added in v0.0.77 

func (m *AzureSystemProperties) GetLockedUntil() int64

func (*AzureSystemProperties) GetPartitionId added in v0.0.77 

func (m *AzureSystemProperties) GetPartitionId() int32

func (*AzureSystemProperties) GetPartitionKey added in v0.0.77 

func (m *AzureSystemProperties) GetPartitionKey() string

func (*AzureSystemProperties) GetScheduledEnqueueTime added in v0.0.77 

func (m *AzureSystemProperties) GetScheduledEnqueueTime() int64

func (*AzureSystemProperties) GetSequenceNumber added in v0.0.77 

func (m *AzureSystemProperties) GetSequenceNumber() int64

func (*AzureSystemProperties) GetViaPartitionKey added in v0.0.77 

func (m *AzureSystemProperties) GetViaPartitionKey() string

func (*AzureSystemProperties) ProtoMessage added in v0.0.77 

func (*AzureSystemProperties) ProtoMessage()

func (*AzureSystemProperties) Reset added in v0.0.77 

func (m *AzureSystemProperties) Reset()

func (*AzureSystemProperties) String added in v0.0.77 

func (m *AzureSystemProperties) String() string

func (*AzureSystemProperties) XXX_DiscardUnknown added in v0.0.77 

func (m *AzureSystemProperties) XXX_DiscardUnknown()

func (*AzureSystemProperties) XXX_Marshal added in v0.0.77 

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

func (*AzureSystemProperties) XXX_Merge added in v0.0.77 

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

func (*AzureSystemProperties) XXX_Size added in v0.0.77 

func (m *AzureSystemProperties) XXX_Size() int

func (*AzureSystemProperties) XXX_Unmarshal added in v0.0.77 

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

type ErrorRecord added in v0.0.35 

type ErrorRecord struct {
	OccurredAtUnixTsUtc  int64             `protobuf:"varint,1,opt,name=occurred_at_unix_ts_utc,json=occurredAtUnixTsUtc,proto3" json:"occurred_at_unix_ts_utc,omitempty"`
	Error                string            `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Metadata             map[string][]byte `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Used for communicating errors that occur during a read, write, relay, etc.

func (*ErrorRecord) Descriptor added in v0.0.35 

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

func (*ErrorRecord) GetError added in v0.0.35 

func (m *ErrorRecord) GetError() string

func (*ErrorRecord) GetMetadata added in v0.0.35 

func (m *ErrorRecord) GetMetadata() map[string][]byte

func (*ErrorRecord) GetOccurredAtUnixTsUtc added in v0.0.35 

func (m *ErrorRecord) GetOccurredAtUnixTsUtc() int64

func (*ErrorRecord) ProtoMessage added in v0.0.35 

func (*ErrorRecord) ProtoMessage()

func (*ErrorRecord) Reset added in v0.0.35 

func (m *ErrorRecord) Reset()

func (*ErrorRecord) String added in v0.0.35 

func (m *ErrorRecord) String() string

func (*ErrorRecord) XXX_DiscardUnknown added in v0.0.35 

func (m *ErrorRecord) XXX_DiscardUnknown()

func (*ErrorRecord) XXX_Marshal added in v0.0.35 

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

func (*ErrorRecord) XXX_Merge added in v0.0.35 

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

func (*ErrorRecord) XXX_Size added in v0.0.35 

func (m *ErrorRecord) XXX_Size() int

func (*ErrorRecord) XXX_Unmarshal added in v0.0.35 

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

type GCPPubSub added in v0.0.77 

type GCPPubSub struct {
	Id                   string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Value                []byte            `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Attributes           map[string]string `` /* 161-byte string literal not displayed */
	PublishTime          int64             `protobuf:"varint,4,opt,name=publish_time,json=publishTime,proto3" json:"publish_time,omitempty"`
	DeliveryAttempt      int32             `protobuf:"varint,5,opt,name=delivery_attempt,json=deliveryAttempt,proto3" json:"delivery_attempt,omitempty"`
	OrderingKey          string            `protobuf:"bytes,6,opt,name=ordering_key,json=orderingKey,proto3" json:"ordering_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GCPPubSub) Descriptor added in v0.0.77 

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

func (*GCPPubSub) GetAttributes added in v0.0.77 

func (m *GCPPubSub) GetAttributes() map[string]string

func (*GCPPubSub) GetDeliveryAttempt added in v0.0.77 

func (m *GCPPubSub) GetDeliveryAttempt() int32

func (*GCPPubSub) GetId added in v0.0.77 

func (m *GCPPubSub) GetId() string

func (*GCPPubSub) GetOrderingKey added in v0.0.77 

func (m *GCPPubSub) GetOrderingKey() string

func (*GCPPubSub) GetPublishTime added in v0.0.77 

func (m *GCPPubSub) GetPublishTime() int64

func (*GCPPubSub) GetValue added in v0.0.77 

func (m *GCPPubSub) GetValue() []byte

func (*GCPPubSub) ProtoMessage added in v0.0.77 

func (*GCPPubSub) ProtoMessage()

func (*GCPPubSub) Reset added in v0.0.77 

func (m *GCPPubSub) Reset()

func (*GCPPubSub) String added in v0.0.77 

func (m *GCPPubSub) String() string

func (*GCPPubSub) XXX_DiscardUnknown added in v0.0.77 

func (m *GCPPubSub) XXX_DiscardUnknown()

func (*GCPPubSub) XXX_Marshal added in v0.0.77 

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

func (*GCPPubSub) XXX_Merge added in v0.0.77 

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

func (*GCPPubSub) XXX_Size added in v0.0.77 

func (m *GCPPubSub) XXX_Size() int

func (*GCPPubSub) XXX_Unmarshal added in v0.0.77 

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

type IsReadRecord_Record added in v0.0.51 

type IsReadRecord_Record = isReadRecord_Record

type Kafka 

type Kafka struct {
	Topic                string         `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Key                  []byte         `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte         `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp            int64          `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Offset               int64          `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	Partition            int32          `protobuf:"varint,6,opt,name=partition,proto3" json:"partition,omitempty"`
	Headers              []*KafkaHeader `protobuf:"bytes,7,rep,name=headers,proto3" json:"headers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Kafka) Descriptor 

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

func (*Kafka) GetHeaders 

func (m *Kafka) GetHeaders() []*KafkaHeader

func (*Kafka) GetKey 

func (m *Kafka) GetKey() []byte

func (*Kafka) GetOffset 

func (m *Kafka) GetOffset() int64

func (*Kafka) GetPartition 

func (m *Kafka) GetPartition() int32

func (*Kafka) GetTimestamp 

func (m *Kafka) GetTimestamp() int64

func (*Kafka) GetTopic 

func (m *Kafka) GetTopic() string

func (*Kafka) GetValue 

func (m *Kafka) GetValue() []byte

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 KafkaHeader 

type KafkaHeader struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KafkaHeader) Descriptor 

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

func (*KafkaHeader) GetKey 

func (m *KafkaHeader) GetKey() string

func (*KafkaHeader) GetValue 

func (m *KafkaHeader) GetValue() string

func (*KafkaHeader) ProtoMessage 

func (*KafkaHeader) ProtoMessage()

func (*KafkaHeader) Reset 

func (m *KafkaHeader) Reset()

func (*KafkaHeader) String 

func (m *KafkaHeader) String() string

func (*KafkaHeader) XXX_DiscardUnknown 

func (m *KafkaHeader) XXX_DiscardUnknown()

func (*KafkaHeader) XXX_Marshal 

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

func (*KafkaHeader) XXX_Merge 

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

func (*KafkaHeader) XXX_Size 

func (m *KafkaHeader) XXX_Size() int

func (*KafkaHeader) XXX_Unmarshal 

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

type KubeMQ added in v0.0.77 

type KubeMQ struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ClientId             string   `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Channel              string   `protobuf:"bytes,3,opt,name=channel,proto3" json:"channel,omitempty"`
	Value                []byte   `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp            int64    `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Sequence             int64    `protobuf:"varint,6,opt,name=sequence,proto3" json:"sequence,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KubeMQ) Descriptor added in v0.0.77 

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

func (*KubeMQ) GetChannel added in v0.0.77 

func (m *KubeMQ) GetChannel() string

func (*KubeMQ) GetClientId added in v0.0.77 

func (m *KubeMQ) GetClientId() string

func (*KubeMQ) GetId added in v0.0.77 

func (m *KubeMQ) GetId() string

func (*KubeMQ) GetSequence added in v0.0.77 

func (m *KubeMQ) GetSequence() int64

func (*KubeMQ) GetTimestamp added in v0.0.77 

func (m *KubeMQ) GetTimestamp() int64

func (*KubeMQ) GetValue added in v0.0.77 

func (m *KubeMQ) GetValue() []byte

func (*KubeMQ) ProtoMessage added in v0.0.77 

func (*KubeMQ) ProtoMessage()

func (*KubeMQ) Reset added in v0.0.77 

func (m *KubeMQ) Reset()

func (*KubeMQ) String added in v0.0.77 

func (m *KubeMQ) String() string

func (*KubeMQ) XXX_DiscardUnknown added in v0.0.77 

func (m *KubeMQ) XXX_DiscardUnknown()

func (*KubeMQ) XXX_Marshal added in v0.0.77 

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

func (*KubeMQ) XXX_Merge added in v0.0.77 

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

func (*KubeMQ) XXX_Size added in v0.0.77 

func (m *KubeMQ) XXX_Size() int

func (*KubeMQ) XXX_Unmarshal added in v0.0.77 

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

type MQTT added in v0.0.77 

type MQTT struct {
	Id                   uint32   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Topic                string   `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Value                []byte   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Duplicate            bool     `protobuf:"varint,4,opt,name=duplicate,proto3" json:"duplicate,omitempty"`
	Retained             bool     `protobuf:"varint,5,opt,name=retained,proto3" json:"retained,omitempty"`
	Qos                  uint32   `protobuf:"varint,6,opt,name=qos,proto3" json:"qos,omitempty"`
	Timestamp            int64    `protobuf:"varint,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MQTT) Descriptor added in v0.0.77 

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

func (*MQTT) GetDuplicate added in v0.0.77 

func (m *MQTT) GetDuplicate() bool

func (*MQTT) GetId added in v0.0.77 

func (m *MQTT) GetId() uint32

func (*MQTT) GetQos added in v0.0.77 

func (m *MQTT) GetQos() uint32

func (*MQTT) GetRetained added in v0.0.77 

func (m *MQTT) GetRetained() bool

func (*MQTT) GetTimestamp added in v0.0.77 

func (m *MQTT) GetTimestamp() int64

func (*MQTT) GetTopic added in v0.0.77 

func (m *MQTT) GetTopic() string

func (*MQTT) GetValue added in v0.0.77 

func (m *MQTT) GetValue() []byte

func (*MQTT) ProtoMessage added in v0.0.77 

func (*MQTT) ProtoMessage()

func (*MQTT) Reset added in v0.0.77 

func (m *MQTT) Reset()

func (*MQTT) String added in v0.0.77 

func (m *MQTT) String() string

func (*MQTT) XXX_DiscardUnknown added in v0.0.77 

func (m *MQTT) XXX_DiscardUnknown()

func (*MQTT) XXX_Marshal added in v0.0.77 

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

func (*MQTT) XXX_Merge added in v0.0.77 

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

func (*MQTT) XXX_Size added in v0.0.77 

func (m *MQTT) XXX_Size() int

func (*MQTT) XXX_Unmarshal added in v0.0.77 

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

type Mongo added in v0.0.77 

type Mongo struct {
	Value                []byte   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp            int64    `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Mongo) Descriptor added in v0.0.77 

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

func (*Mongo) GetTimestamp added in v0.0.77 

func (m *Mongo) GetTimestamp() int64

func (*Mongo) GetValue added in v0.0.77 

func (m *Mongo) GetValue() []byte

func (*Mongo) ProtoMessage added in v0.0.77 

func (*Mongo) ProtoMessage()

func (*Mongo) Reset added in v0.0.77 

func (m *Mongo) Reset()

func (*Mongo) String added in v0.0.77 

func (m *Mongo) String() string

func (*Mongo) XXX_DiscardUnknown added in v0.0.77 

func (m *Mongo) XXX_DiscardUnknown()

func (*Mongo) XXX_Marshal added in v0.0.77 

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

func (*Mongo) XXX_Merge added in v0.0.77 

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

func (*Mongo) XXX_Size added in v0.0.77 

func (m *Mongo) XXX_Size() int

func (*Mongo) XXX_Unmarshal added in v0.0.77 

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

type NSQ added in v0.0.77 

type NSQ struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Topic                string   `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Channel              string   `protobuf:"bytes,3,opt,name=channel,proto3" json:"channel,omitempty"`
	Attempts             int32    `protobuf:"varint,4,opt,name=attempts,proto3" json:"attempts,omitempty"`
	NsqdAddress          string   `protobuf:"bytes,5,opt,name=nsqd_address,json=nsqdAddress,proto3" json:"nsqd_address,omitempty"`
	Value                []byte   `protobuf:"bytes,6,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp            int64    `protobuf:"varint,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NSQ) Descriptor added in v0.0.77 

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

func (*NSQ) GetAttempts added in v0.0.77 

func (m *NSQ) GetAttempts() int32

func (*NSQ) GetChannel added in v0.0.77 

func (m *NSQ) GetChannel() string

func (*NSQ) GetId added in v0.0.77 

func (m *NSQ) GetId() string

func (*NSQ) GetNsqdAddress added in v0.0.77 

func (m *NSQ) GetNsqdAddress() string

func (*NSQ) GetTimestamp added in v0.0.77 

func (m *NSQ) GetTimestamp() int64

func (*NSQ) GetTopic added in v0.0.77 

func (m *NSQ) GetTopic() string

func (*NSQ) GetValue added in v0.0.77 

func (m *NSQ) GetValue() []byte

func (*NSQ) ProtoMessage added in v0.0.77 

func (*NSQ) ProtoMessage()

func (*NSQ) Reset added in v0.0.77 

func (m *NSQ) Reset()

func (*NSQ) String added in v0.0.77 

func (m *NSQ) String() string

func (*NSQ) XXX_DiscardUnknown added in v0.0.77 

func (m *NSQ) XXX_DiscardUnknown()

func (*NSQ) XXX_Marshal added in v0.0.77 

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

func (*NSQ) XXX_Merge added in v0.0.77 

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

func (*NSQ) XXX_Size added in v0.0.77 

func (m *NSQ) XXX_Size() int

func (*NSQ) XXX_Unmarshal added in v0.0.77 

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

type Nats added in v0.0.77 

type Nats struct {
	Subject              string   `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Nats) Descriptor added in v0.0.77 

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

func (*Nats) GetSubject added in v0.0.77 

func (m *Nats) GetSubject() string

func (*Nats) GetValue added in v0.0.77 

func (m *Nats) GetValue() []byte

func (*Nats) ProtoMessage added in v0.0.77 

func (*Nats) ProtoMessage()

func (*Nats) Reset added in v0.0.77 

func (m *Nats) Reset()

func (*Nats) String added in v0.0.77 

func (m *Nats) String() string

func (*Nats) XXX_DiscardUnknown added in v0.0.77 

func (m *Nats) XXX_DiscardUnknown()

func (*Nats) XXX_Marshal added in v0.0.77 

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

func (*Nats) XXX_Merge added in v0.0.77 

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

func (*Nats) XXX_Size added in v0.0.77 

func (m *Nats) XXX_Size() int

func (*Nats) XXX_Unmarshal added in v0.0.77 

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

type NatsStreaming added in v0.0.77 

type NatsStreaming struct {
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	Value                []byte            `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp            int64             `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*NatsStreaming) Descriptor added in v0.0.77 

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

func (*NatsStreaming) GetMetadata added in v0.0.77 

func (m *NatsStreaming) GetMetadata() map[string]string

func (*NatsStreaming) GetTimestamp added in v0.0.77 

func (m *NatsStreaming) GetTimestamp() int64

func (*NatsStreaming) GetValue added in v0.0.77 

func (m *NatsStreaming) GetValue() []byte

func (*NatsStreaming) ProtoMessage added in v0.0.77 

func (*NatsStreaming) ProtoMessage()

func (*NatsStreaming) Reset added in v0.0.77 

func (m *NatsStreaming) Reset()

func (*NatsStreaming) String added in v0.0.77 

func (m *NatsStreaming) String() string

func (*NatsStreaming) XXX_DiscardUnknown added in v0.0.77 

func (m *NatsStreaming) XXX_DiscardUnknown()

func (*NatsStreaming) XXX_Marshal added in v0.0.77 

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

func (*NatsStreaming) XXX_Merge added in v0.0.77 

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

func (*NatsStreaming) XXX_Size added in v0.0.77 

func (m *NatsStreaming) XXX_Size() int

func (*NatsStreaming) XXX_Unmarshal added in v0.0.77 

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

type Postgres added in v0.0.77 

type Postgres struct {
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	Timestamp            int64             `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value                []byte            `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Postgres) Descriptor added in v0.0.77 

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

func (*Postgres) GetMetadata added in v0.0.77 

func (m *Postgres) GetMetadata() map[string]string

func (*Postgres) GetTimestamp added in v0.0.77 

func (m *Postgres) GetTimestamp() int64

func (*Postgres) GetValue added in v0.0.77 

func (m *Postgres) GetValue() []byte

func (*Postgres) ProtoMessage added in v0.0.77 

func (*Postgres) ProtoMessage()

func (*Postgres) Reset added in v0.0.77 

func (m *Postgres) Reset()

func (*Postgres) String added in v0.0.77 

func (m *Postgres) String() string

func (*Postgres) XXX_DiscardUnknown added in v0.0.77 

func (m *Postgres) XXX_DiscardUnknown()

func (*Postgres) XXX_Marshal added in v0.0.77 

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

func (*Postgres) XXX_Merge added in v0.0.77 

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

func (*Postgres) XXX_Size added in v0.0.77 

func (m *Postgres) XXX_Size() int

func (*Postgres) XXX_Unmarshal added in v0.0.77 

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

type Pulsar added in v0.0.77 

type Pulsar struct {
	Id                   string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Key                  string            `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Topic                string            `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Properties           map[string]string `` /* 161-byte string literal not displayed */
	RedeliveryCount      uint32            `protobuf:"varint,5,opt,name=redelivery_count,json=redeliveryCount,proto3" json:"redelivery_count,omitempty"`
	EventTime            string            `protobuf:"bytes,6,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	IsReplicated         bool              `protobuf:"varint,7,opt,name=is_replicated,json=isReplicated,proto3" json:"is_replicated,omitempty"`
	OrderingKey          string            `protobuf:"bytes,8,opt,name=ordering_key,json=orderingKey,proto3" json:"ordering_key,omitempty"`
	ProducerName         string            `protobuf:"bytes,9,opt,name=producer_name,json=producerName,proto3" json:"producer_name,omitempty"`
	PublishTime          string            `protobuf:"bytes,10,opt,name=publish_time,json=publishTime,proto3" json:"publish_time,omitempty"`
	Timestamp            int64             `protobuf:"varint,11,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value                []byte            `protobuf:"bytes,12,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Pulsar) Descriptor added in v0.0.77 

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

func (*Pulsar) GetEventTime added in v0.0.77 

func (m *Pulsar) GetEventTime() string

func (*Pulsar) GetId added in v0.0.77 

func (m *Pulsar) GetId() string

func (*Pulsar) GetIsReplicated added in v0.0.77 

func (m *Pulsar) GetIsReplicated() bool

func (*Pulsar) GetKey added in v0.0.77 

func (m *Pulsar) GetKey() string

func (*Pulsar) GetOrderingKey added in v0.0.77 

func (m *Pulsar) GetOrderingKey() string

func (*Pulsar) GetProducerName added in v0.0.77 

func (m *Pulsar) GetProducerName() string

func (*Pulsar) GetProperties added in v0.0.77 

func (m *Pulsar) GetProperties() map[string]string

func (*Pulsar) GetPublishTime added in v0.0.77 

func (m *Pulsar) GetPublishTime() string

func (*Pulsar) GetRedeliveryCount added in v0.0.77 

func (m *Pulsar) GetRedeliveryCount() uint32

func (*Pulsar) GetTimestamp added in v0.0.77 

func (m *Pulsar) GetTimestamp() int64

func (*Pulsar) GetTopic added in v0.0.77 

func (m *Pulsar) GetTopic() string

func (*Pulsar) GetValue added in v0.0.77 

func (m *Pulsar) GetValue() []byte

func (*Pulsar) ProtoMessage added in v0.0.77 

func (*Pulsar) ProtoMessage()

func (*Pulsar) Reset added in v0.0.77 

func (m *Pulsar) Reset()

func (*Pulsar) String added in v0.0.77 

func (m *Pulsar) String() string

func (*Pulsar) XXX_DiscardUnknown added in v0.0.77 

func (m *Pulsar) XXX_DiscardUnknown()

func (*Pulsar) XXX_Marshal added in v0.0.77 

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

func (*Pulsar) XXX_Merge added in v0.0.77 

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

func (*Pulsar) XXX_Size added in v0.0.77 

func (m *Pulsar) XXX_Size() int

func (*Pulsar) XXX_Unmarshal added in v0.0.77 

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

type Rabbit added in v0.0.77 

type Rabbit struct {
	Body                 []byte          `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	Timestamp            int64           `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Type                 string          `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Exchange             string          `protobuf:"bytes,4,opt,name=exchange,proto3" json:"exchange,omitempty"`
	RoutingKey           string          `protobuf:"bytes,5,opt,name=routing_key,json=routingKey,proto3" json:"routing_key,omitempty"`
	ContentType          string          `protobuf:"bytes,6,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	ContentEncoding      string          `protobuf:"bytes,7,opt,name=content_encoding,json=contentEncoding,proto3" json:"content_encoding,omitempty"`
	Priority             int32           `protobuf:"varint,8,opt,name=priority,proto3" json:"priority,omitempty"`
	Expiration           string          `protobuf:"bytes,9,opt,name=expiration,proto3" json:"expiration,omitempty"`
	MessageId            string          `protobuf:"bytes,10,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	UserId               string          `protobuf:"bytes,11,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	AppId                string          `protobuf:"bytes,12,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	ReplyTo              string          `protobuf:"bytes,13,opt,name=reply_to,json=replyTo,proto3" json:"reply_to,omitempty"`
	CorrelationId        string          `protobuf:"bytes,14,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Headers              []*RabbitHeader `protobuf:"bytes,15,rep,name=headers,proto3" json:"headers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Rabbit) Descriptor added in v0.0.77 

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

func (*Rabbit) GetAppId added in v0.0.77 

func (m *Rabbit) GetAppId() string

func (*Rabbit) GetBody added in v0.0.77 

func (m *Rabbit) GetBody() []byte

func (*Rabbit) GetContentEncoding added in v0.0.77 

func (m *Rabbit) GetContentEncoding() string

func (*Rabbit) GetContentType added in v0.0.77 

func (m *Rabbit) GetContentType() string

func (*Rabbit) GetCorrelationId added in v0.0.77 

func (m *Rabbit) GetCorrelationId() string

func (*Rabbit) GetExchange added in v0.0.77 

func (m *Rabbit) GetExchange() string

func (*Rabbit) GetExpiration added in v0.0.77 

func (m *Rabbit) GetExpiration() string

func (*Rabbit) GetHeaders added in v0.0.77 

func (m *Rabbit) GetHeaders() []*RabbitHeader

func (*Rabbit) GetMessageId added in v0.0.77 

func (m *Rabbit) GetMessageId() string

func (*Rabbit) GetPriority added in v0.0.77 

func (m *Rabbit) GetPriority() int32

func (*Rabbit) GetReplyTo added in v0.0.77 

func (m *Rabbit) GetReplyTo() string

func (*Rabbit) GetRoutingKey added in v0.0.77 

func (m *Rabbit) GetRoutingKey() string

func (*Rabbit) GetTimestamp added in v0.0.77 

func (m *Rabbit) GetTimestamp() int64

func (*Rabbit) GetType added in v0.0.77 

func (m *Rabbit) GetType() string

func (*Rabbit) GetUserId added in v0.0.77 

func (m *Rabbit) GetUserId() string

func (*Rabbit) ProtoMessage added in v0.0.77 

func (*Rabbit) ProtoMessage()

func (*Rabbit) Reset added in v0.0.77 

func (m *Rabbit) Reset()

func (*Rabbit) String added in v0.0.77 

func (m *Rabbit) String() string

func (*Rabbit) XXX_DiscardUnknown added in v0.0.77 

func (m *Rabbit) XXX_DiscardUnknown()

func (*Rabbit) XXX_Marshal added in v0.0.77 

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

func (*Rabbit) XXX_Merge added in v0.0.77 

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

func (*Rabbit) XXX_Size added in v0.0.77 

func (m *Rabbit) XXX_Size() int

func (*Rabbit) XXX_Unmarshal added in v0.0.77 

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

type RabbitHeader added in v0.0.77 

type RabbitHeader struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RabbitHeader) Descriptor added in v0.0.77 

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

func (*RabbitHeader) GetKey added in v0.0.77 

func (m *RabbitHeader) GetKey() string

func (*RabbitHeader) GetValue added in v0.0.77 

func (m *RabbitHeader) GetValue() string

func (*RabbitHeader) ProtoMessage added in v0.0.77 

func (*RabbitHeader) ProtoMessage()

func (*RabbitHeader) Reset added in v0.0.77 

func (m *RabbitHeader) Reset()

func (*RabbitHeader) String added in v0.0.77 

func (m *RabbitHeader) String() string

func (*RabbitHeader) XXX_DiscardUnknown added in v0.0.77 

func (m *RabbitHeader) XXX_DiscardUnknown()

func (*RabbitHeader) XXX_Marshal added in v0.0.77 

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

func (*RabbitHeader) XXX_Merge added in v0.0.77 

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

func (*RabbitHeader) XXX_Size added in v0.0.77 

func (m *RabbitHeader) XXX_Size() int

func (*RabbitHeader) XXX_Unmarshal added in v0.0.77 

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

type RabbitStreams added in v0.0.77 

type RabbitStreams struct {
	DeliveryTag          string               `protobuf:"bytes,1,opt,name=delivery_tag,json=deliveryTag,proto3" json:"delivery_tag,omitempty"`
	Format               uint32               `protobuf:"varint,2,opt,name=format,proto3" json:"format,omitempty"`
	Header               *RabbitStreamsHeader `protobuf:"bytes,3,opt,name=header,proto3" json:"header,omitempty"`
	DeliveryAnnotations  map[string]string    `` /* 206-byte string literal not displayed */
	Footer               map[string]string    `` /* 153-byte string literal not displayed */
	SendSettled          bool                 `protobuf:"varint,6,opt,name=send_settled,json=sendSettled,proto3" json:"send_settled,omitempty"`
	StreamName           string               `protobuf:"bytes,7,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	Timestamp            int64                `protobuf:"varint,8,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value                []byte               `protobuf:"bytes,9,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*RabbitStreams) Descriptor added in v0.0.77 

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

func (*RabbitStreams) GetDeliveryAnnotations added in v0.0.77 

func (m *RabbitStreams) GetDeliveryAnnotations() map[string]string

func (*RabbitStreams) GetDeliveryTag added in v0.0.77 

func (m *RabbitStreams) GetDeliveryTag() string

func (*RabbitStreams) GetFooter added in v0.0.77 

func (m *RabbitStreams) GetFooter() map[string]string

func (*RabbitStreams) GetFormat added in v0.0.77 

func (m *RabbitStreams) GetFormat() uint32

func (*RabbitStreams) GetHeader added in v0.0.77 

func (m *RabbitStreams) GetHeader() *RabbitStreamsHeader

func (*RabbitStreams) GetSendSettled added in v0.0.77 

func (m *RabbitStreams) GetSendSettled() bool

func (*RabbitStreams) GetStreamName added in v0.0.77 

func (m *RabbitStreams) GetStreamName() string

func (*RabbitStreams) GetTimestamp added in v0.0.77 

func (m *RabbitStreams) GetTimestamp() int64

func (*RabbitStreams) GetValue added in v0.0.77 

func (m *RabbitStreams) GetValue() []byte

func (*RabbitStreams) ProtoMessage added in v0.0.77 

func (*RabbitStreams) ProtoMessage()

func (*RabbitStreams) Reset added in v0.0.77 

func (m *RabbitStreams) Reset()

func (*RabbitStreams) String added in v0.0.77 

func (m *RabbitStreams) String() string

func (*RabbitStreams) XXX_DiscardUnknown added in v0.0.77 

func (m *RabbitStreams) XXX_DiscardUnknown()

func (*RabbitStreams) XXX_Marshal added in v0.0.77 

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

func (*RabbitStreams) XXX_Merge added in v0.0.77 

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

func (*RabbitStreams) XXX_Size added in v0.0.77 

func (m *RabbitStreams) XXX_Size() int

func (*RabbitStreams) XXX_Unmarshal added in v0.0.77 

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

type RabbitStreamsHeader added in v0.0.77 

type RabbitStreamsHeader struct {
	MessageId            string   `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	UserId               string   `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	To                   string   `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
	Subject              string   `protobuf:"bytes,4,opt,name=subject,proto3" json:"subject,omitempty"`
	ReplayTo             string   `protobuf:"bytes,5,opt,name=replay_to,json=replayTo,proto3" json:"replay_to,omitempty"`
	CorrelationId        string   `protobuf:"bytes,6,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	ContentType          string   `protobuf:"bytes,7,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	ContentEncoding      string   `protobuf:"bytes,8,opt,name=content_encoding,json=contentEncoding,proto3" json:"content_encoding,omitempty"`
	AbsoluteExpiryTime   string   `protobuf:"bytes,9,opt,name=absolute_expiry_time,json=absoluteExpiryTime,proto3" json:"absolute_expiry_time,omitempty"`
	CreationTime         string   `protobuf:"bytes,10,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
	GroupId              string   `protobuf:"bytes,11,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	GroupSequence        uint32   `protobuf:"varint,12,opt,name=group_sequence,json=groupSequence,proto3" json:"group_sequence,omitempty"`
	ReplayToGroupId      string   `protobuf:"bytes,13,opt,name=replay_to_group_id,json=replayToGroupId,proto3" json:"replay_to_group_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RabbitStreamsHeader) Descriptor added in v0.0.77 

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

func (*RabbitStreamsHeader) GetAbsoluteExpiryTime added in v0.0.77 

func (m *RabbitStreamsHeader) GetAbsoluteExpiryTime() string

func (*RabbitStreamsHeader) GetContentEncoding added in v0.0.77 

func (m *RabbitStreamsHeader) GetContentEncoding() string

func (*RabbitStreamsHeader) GetContentType added in v0.0.77 

func (m *RabbitStreamsHeader) GetContentType() string

func (*RabbitStreamsHeader) GetCorrelationId added in v0.0.77 

func (m *RabbitStreamsHeader) GetCorrelationId() string

func (*RabbitStreamsHeader) GetCreationTime added in v0.0.77 

func (m *RabbitStreamsHeader) GetCreationTime() string

func (*RabbitStreamsHeader) GetGroupId added in v0.0.77 

func (m *RabbitStreamsHeader) GetGroupId() string

func (*RabbitStreamsHeader) GetGroupSequence added in v0.0.77 

func (m *RabbitStreamsHeader) GetGroupSequence() uint32

func (*RabbitStreamsHeader) GetMessageId added in v0.0.77 

func (m *RabbitStreamsHeader) GetMessageId() string

func (*RabbitStreamsHeader) GetReplayTo added in v0.0.77 

func (m *RabbitStreamsHeader) GetReplayTo() string

func (*RabbitStreamsHeader) GetReplayToGroupId added in v0.0.77 

func (m *RabbitStreamsHeader) GetReplayToGroupId() string

func (*RabbitStreamsHeader) GetSubject added in v0.0.77 

func (m *RabbitStreamsHeader) GetSubject() string

func (*RabbitStreamsHeader) GetTo added in v0.0.77 

func (m *RabbitStreamsHeader) GetTo() string

func (*RabbitStreamsHeader) GetUserId added in v0.0.77 

func (m *RabbitStreamsHeader) GetUserId() string

func (*RabbitStreamsHeader) ProtoMessage added in v0.0.77 

func (*RabbitStreamsHeader) ProtoMessage()

func (*RabbitStreamsHeader) Reset added in v0.0.77 

func (m *RabbitStreamsHeader) Reset()

func (*RabbitStreamsHeader) String added in v0.0.77 

func (m *RabbitStreamsHeader) String() string

func (*RabbitStreamsHeader) XXX_DiscardUnknown added in v0.0.77 

func (m *RabbitStreamsHeader) XXX_DiscardUnknown()

func (*RabbitStreamsHeader) XXX_Marshal added in v0.0.77 

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

func (*RabbitStreamsHeader) XXX_Merge added in v0.0.77 

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

func (*RabbitStreamsHeader) XXX_Size added in v0.0.77 

func (m *RabbitStreamsHeader) XXX_Size() int

func (*RabbitStreamsHeader) XXX_Unmarshal added in v0.0.77 

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

type ReadRecord added in v0.0.34 

type ReadRecord struct {
	// Unique id automatically created by plumber
	MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// Plumber counts the number of messages it reads; this number represents
	// the message number (useful for CLI).
	Num int64 `protobuf:"varint,3,opt,name=num,proto3" json:"num,omitempty"`
	// Metadata may contain properties that cannot be found in the Raw message.
	// For example: read lag in Kafka.
	//
	// Metadata may also contain data such as "count" which is an incremental
	// number that plumber assigns to each message it receives. This is used
	// with read via CLI functionality to allow the user to quickly discern
	// whether this is message #1 or #500, etc.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// UTC unix timestamp of when plumber received the message; a backend record
	// entry might have its own timestamp as well. This should be seconds.
	ReceivedAtUnixTsUtc int64 `protobuf:"varint,6,opt,name=received_at_unix_ts_utc,json=receivedAtUnixTsUtc,proto3" json:"received_at_unix_ts_utc,omitempty"`
	// Set _outside_ the backend; will contain the final value, regardless of
	// whether decoding options were specified for a read.
	// _This_ is what both CLI and desktop should display for the payload.
	Payload []byte `protobuf:"bytes,99,opt,name=payload,proto3" json:"payload,omitempty"`
	// Types that are valid to be assigned to Record:
	//	*ReadRecord_Kafka
	//	*ReadRecord_Rabbit
	//	*ReadRecord_Activemq
	//	*ReadRecord_Awssqs
	//	*ReadRecord_AzureEventHub
	//	*ReadRecord_AzureServiceBus
	//	*ReadRecord_GcpPubsub
	//	*ReadRecord_Kubemq
	//	*ReadRecord_Mongo
	//	*ReadRecord_Mqtt
	//	*ReadRecord_Nats
	//	*ReadRecord_NatsStreaming
	//	*ReadRecord_Nsq
	//	*ReadRecord_Postgres
	//	*ReadRecord_Pulsar
	//	*ReadRecord_RabbitStreams
	//	*ReadRecord_RedisPubsub
	//	*ReadRecord_RedisStreams
	Record isReadRecord_Record `protobuf_oneof:"Record"`
	// Original backend message (encoded with gob, ie. *skafka.Message, etc.).
	// In most cases, you should use the oneof record instead of the raw message.
	XRaw []byte `protobuf:"bytes,1000,opt,name=_raw,json=Raw,proto3" json:"_raw,omitempty"`
	// Identifies which plumber instance received the event (set outside the backend)
	XPlumberId           string   `protobuf:"bytes,1001,opt,name=_plumber_id,json=PlumberId,proto3" json:"_plumber_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Returned for read requests (server & cli)

func (*ReadRecord) Descriptor added in v0.0.34 

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

func (*ReadRecord) GetActivemq added in v0.0.77 

func (m *ReadRecord) GetActivemq() *ActiveMQ

func (*ReadRecord) GetAwssqs added in v0.0.77 

func (m *ReadRecord) GetAwssqs() *AWSSQS

func (*ReadRecord) GetAzureEventHub added in v0.0.77 

func (m *ReadRecord) GetAzureEventHub() *AzureEventHub

func (*ReadRecord) GetAzureServiceBus added in v0.0.77 

func (m *ReadRecord) GetAzureServiceBus() *AzureServiceBus

func (*ReadRecord) GetGcpPubsub added in v0.0.77 

func (m *ReadRecord) GetGcpPubsub() *GCPPubSub

func (*ReadRecord) GetKafka added in v0.0.34 

func (m *ReadRecord) GetKafka() *Kafka

func (*ReadRecord) GetKubemq added in v0.0.77 

func (m *ReadRecord) GetKubemq() *KubeMQ

func (*ReadRecord) GetMessageId added in v0.0.34 

func (m *ReadRecord) GetMessageId() string

func (*ReadRecord) GetMetadata added in v0.0.34 

func (m *ReadRecord) GetMetadata() map[string]string

func (*ReadRecord) GetMongo added in v0.0.77 

func (m *ReadRecord) GetMongo() *Mongo

func (*ReadRecord) GetMqtt added in v0.0.77 

func (m *ReadRecord) GetMqtt() *MQTT

func (*ReadRecord) GetNats added in v0.0.77 

func (m *ReadRecord) GetNats() *Nats

func (*ReadRecord) GetNatsStreaming added in v0.0.77 

func (m *ReadRecord) GetNatsStreaming() *NatsStreaming

func (*ReadRecord) GetNsq added in v0.0.77 

func (m *ReadRecord) GetNsq() *NSQ

func (*ReadRecord) GetNum added in v0.0.51 

func (m *ReadRecord) GetNum() int64

func (*ReadRecord) GetPayload added in v0.0.51 

func (m *ReadRecord) GetPayload() []byte

func (*ReadRecord) GetPostgres added in v0.0.77 

func (m *ReadRecord) GetPostgres() *Postgres

func (*ReadRecord) GetPulsar added in v0.0.77 

func (m *ReadRecord) GetPulsar() *Pulsar

func (*ReadRecord) GetRabbit added in v0.0.77 

func (m *ReadRecord) GetRabbit() *Rabbit

func (*ReadRecord) GetRabbitStreams added in v0.0.77 

func (m *ReadRecord) GetRabbitStreams() *RabbitStreams

func (*ReadRecord) GetReceivedAtUnixTsUtc added in v0.0.35 

func (m *ReadRecord) GetReceivedAtUnixTsUtc() int64

func (*ReadRecord) GetRecord added in v0.0.34 

func (m *ReadRecord) GetRecord() isReadRecord_Record

func (*ReadRecord) GetRedisPubsub added in v0.0.77 

func (m *ReadRecord) GetRedisPubsub() *RedisPubsub

func (*ReadRecord) GetRedisStreams added in v0.0.77 

func (m *ReadRecord) GetRedisStreams() *RedisStreams

func (*ReadRecord) GetXPlumberId added in v0.0.51 

func (m *ReadRecord) GetXPlumberId() string

func (*ReadRecord) GetXRaw added in v0.0.51 

func (m *ReadRecord) GetXRaw() []byte

func (*ReadRecord) ProtoMessage added in v0.0.34 

func (*ReadRecord) ProtoMessage()

func (*ReadRecord) Reset added in v0.0.34 

func (m *ReadRecord) Reset()

func (*ReadRecord) String added in v0.0.34 

func (m *ReadRecord) String() string

func (*ReadRecord) XXX_DiscardUnknown added in v0.0.34 

func (m *ReadRecord) XXX_DiscardUnknown()

func (*ReadRecord) XXX_Marshal added in v0.0.34 

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

func (*ReadRecord) XXX_Merge added in v0.0.34 

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

func (*ReadRecord) XXX_OneofWrappers added in v0.0.34 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ReadRecord) XXX_Size added in v0.0.34 

func (m *ReadRecord) XXX_Size() int

func (*ReadRecord) XXX_Unmarshal added in v0.0.34 

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

type ReadRecord_Activemq added in v0.0.77 

type ReadRecord_Activemq struct {
	Activemq *ActiveMQ `protobuf:"bytes,102,opt,name=activemq,proto3,oneof"`
}

type ReadRecord_Awssqs added in v0.0.77 

type ReadRecord_Awssqs struct {
	Awssqs *AWSSQS `protobuf:"bytes,103,opt,name=awssqs,proto3,oneof"`
}

type ReadRecord_AzureEventHub added in v0.0.77 

type ReadRecord_AzureEventHub struct {
	AzureEventHub *AzureEventHub `protobuf:"bytes,104,opt,name=azure_event_hub,json=azureEventHub,proto3,oneof"`
}

type ReadRecord_AzureServiceBus added in v0.0.77 

type ReadRecord_AzureServiceBus struct {
	AzureServiceBus *AzureServiceBus `protobuf:"bytes,105,opt,name=azure_service_bus,json=azureServiceBus,proto3,oneof"`
}

type ReadRecord_GcpPubsub added in v0.0.77 

type ReadRecord_GcpPubsub struct {
	GcpPubsub *GCPPubSub `protobuf:"bytes,106,opt,name=gcp_pubsub,json=gcpPubsub,proto3,oneof"`
}

type ReadRecord_Kafka added in v0.0.34 

type ReadRecord_Kafka struct {
	Kafka *Kafka `protobuf:"bytes,100,opt,name=kafka,proto3,oneof"`
}

type ReadRecord_Kubemq added in v0.0.77 

type ReadRecord_Kubemq struct {
	Kubemq *KubeMQ `protobuf:"bytes,107,opt,name=kubemq,proto3,oneof"`
}

type ReadRecord_Mongo added in v0.0.77 

type ReadRecord_Mongo struct {
	Mongo *Mongo `protobuf:"bytes,108,opt,name=mongo,proto3,oneof"`
}

type ReadRecord_Mqtt added in v0.0.77 

type ReadRecord_Mqtt struct {
	Mqtt *MQTT `protobuf:"bytes,109,opt,name=mqtt,proto3,oneof"`
}

type ReadRecord_Nats added in v0.0.77 

type ReadRecord_Nats struct {
	Nats *Nats `protobuf:"bytes,110,opt,name=nats,proto3,oneof"`
}

type ReadRecord_NatsStreaming added in v0.0.77 

type ReadRecord_NatsStreaming struct {
	NatsStreaming *NatsStreaming `protobuf:"bytes,111,opt,name=nats_streaming,json=natsStreaming,proto3,oneof"`
}

type ReadRecord_Nsq added in v0.0.77 

type ReadRecord_Nsq struct {
	Nsq *NSQ `protobuf:"bytes,112,opt,name=nsq,proto3,oneof"`
}

type ReadRecord_Postgres added in v0.0.77 

type ReadRecord_Postgres struct {
	Postgres *Postgres `protobuf:"bytes,113,opt,name=postgres,proto3,oneof"`
}

type ReadRecord_Pulsar added in v0.0.77 

type ReadRecord_Pulsar struct {
	Pulsar *Pulsar `protobuf:"bytes,114,opt,name=pulsar,proto3,oneof"`
}

type ReadRecord_Rabbit added in v0.0.77 

type ReadRecord_Rabbit struct {
	Rabbit *Rabbit `protobuf:"bytes,101,opt,name=rabbit,proto3,oneof"`
}

type ReadRecord_RabbitStreams added in v0.0.77 

type ReadRecord_RabbitStreams struct {
	RabbitStreams *RabbitStreams `protobuf:"bytes,115,opt,name=rabbit_streams,json=rabbitStreams,proto3,oneof"`
}

type ReadRecord_RedisPubsub added in v0.0.77 

type ReadRecord_RedisPubsub struct {
	RedisPubsub *RedisPubsub `protobuf:"bytes,116,opt,name=redis_pubsub,json=redisPubsub,proto3,oneof"`
}

type ReadRecord_RedisStreams added in v0.0.77 

type ReadRecord_RedisStreams struct {
	RedisStreams *RedisStreams `protobuf:"bytes,117,opt,name=redis_streams,json=redisStreams,proto3,oneof"`
}

type RedisPubsub added in v0.0.77 

type RedisPubsub struct {
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	Value                []byte            `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp            int64             `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RedisPubsub) Descriptor added in v0.0.77 

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

func (*RedisPubsub) GetMetadata added in v0.0.77 

func (m *RedisPubsub) GetMetadata() map[string]string

func (*RedisPubsub) GetTimestamp added in v0.0.77 

func (m *RedisPubsub) GetTimestamp() int64

func (*RedisPubsub) GetValue added in v0.0.77 

func (m *RedisPubsub) GetValue() []byte

func (*RedisPubsub) ProtoMessage added in v0.0.77 

func (*RedisPubsub) ProtoMessage()

func (*RedisPubsub) Reset added in v0.0.77 

func (m *RedisPubsub) Reset()

func (*RedisPubsub) String added in v0.0.77 

func (m *RedisPubsub) String() string

func (*RedisPubsub) XXX_DiscardUnknown added in v0.0.77 

func (m *RedisPubsub) XXX_DiscardUnknown()

func (*RedisPubsub) XXX_Marshal added in v0.0.77 

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

func (*RedisPubsub) XXX_Merge added in v0.0.77 

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

func (*RedisPubsub) XXX_Size added in v0.0.77 

func (m *RedisPubsub) XXX_Size() int

func (*RedisPubsub) XXX_Unmarshal added in v0.0.77 

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

type RedisStreams added in v0.0.77 

type RedisStreams struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Key                  string   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Stream               string   `protobuf:"bytes,4,opt,name=stream,proto3" json:"stream,omitempty"`
	Timestamp            int64    `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RedisStreams) Descriptor added in v0.0.77 

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

func (*RedisStreams) GetId added in v0.0.77 

func (m *RedisStreams) GetId() string

func (*RedisStreams) GetKey added in v0.0.77 

func (m *RedisStreams) GetKey() string

func (*RedisStreams) GetStream added in v0.0.77 

func (m *RedisStreams) GetStream() string

func (*RedisStreams) GetTimestamp added in v0.0.77 

func (m *RedisStreams) GetTimestamp() int64

func (*RedisStreams) GetValue added in v0.0.77 

func (m *RedisStreams) GetValue() string

func (*RedisStreams) ProtoMessage added in v0.0.77 

func (*RedisStreams) ProtoMessage()

func (*RedisStreams) Reset added in v0.0.77 

func (m *RedisStreams) Reset()

func (*RedisStreams) String added in v0.0.77 

func (m *RedisStreams) String() string

func (*RedisStreams) XXX_DiscardUnknown added in v0.0.77 

func (m *RedisStreams) XXX_DiscardUnknown()

func (*RedisStreams) XXX_Marshal added in v0.0.77 

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

func (*RedisStreams) XXX_Merge added in v0.0.77 

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

func (*RedisStreams) XXX_Size added in v0.0.77 

func (m *RedisStreams) XXX_Size() int

func (*RedisStreams) XXX_Unmarshal added in v0.0.77 

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

type WriteRecord added in v0.0.34 

type WriteRecord struct {
	// If encoding options are provided, this value will be updated by plumber
	// to contain the encoded payload _before_ passing it to the backend.
	// @gotags: kong:"help='Input string',name=input,xor=input,default"
	Input string `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty" kong:"help='Input string',name=input,xor=input,default"`
	// @gotags: kong:"help='Optional metadata a backend may use (key1:value,key2:value,etc)',name=input-metadata"
	InputMetadata        map[string]string `` /* 286-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Used as an arg for write requests (server & cli)

func (*WriteRecord) Descriptor added in v0.0.34 

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

func (*WriteRecord) GetInput added in v0.0.46 

func (m *WriteRecord) GetInput() string

func (*WriteRecord) GetInputMetadata added in v0.0.46 

func (m *WriteRecord) GetInputMetadata() map[string]string

func (*WriteRecord) ProtoMessage added in v0.0.34 

func (*WriteRecord) ProtoMessage()

func (*WriteRecord) Reset added in v0.0.34 

func (m *WriteRecord) Reset()

func (*WriteRecord) String added in v0.0.34 

func (m *WriteRecord) String() string

func (*WriteRecord) XXX_DiscardUnknown added in v0.0.34 

func (m *WriteRecord) XXX_DiscardUnknown()

func (*WriteRecord) XXX_Marshal added in v0.0.34 

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

func (*WriteRecord) XXX_Merge added in v0.0.34 

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

func (*WriteRecord) XXX_Size added in v0.0.34 

func (m *WriteRecord) XXX_Size() int

func (*WriteRecord) XXX_Unmarshal added in v0.0.34 

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

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.