records

package
v0.0.24 Latest Latest
Warning

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

 Go to latest Published: Apr 20, 2023 License: MIT Imports: 4 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_cs_records_amqp_proto protoreflect.FileDescriptor
View Source 
var File_cs_records_azure_proto protoreflect.FileDescriptor
View Source 
var File_cs_records_gcp_proto protoreflect.FileDescriptor
View Source 
var File_cs_records_generic_proto protoreflect.FileDescriptor
View Source 
var File_cs_records_http_proto protoreflect.FileDescriptor
View Source 
var File_cs_records_kafka_proto protoreflect.FileDescriptor
View Source 
var File_cs_records_kubemq_proto protoreflect.FileDescriptor
View Source 
var File_cs_records_mqtt_proto protoreflect.FileDescriptor
View Source 
var File_cs_records_nats_jetstream_proto protoreflect.FileDescriptor
View Source 
var File_cs_records_nats_proto protoreflect.FileDescriptor
View Source 
var File_cs_records_nats_streaming_proto protoreflect.FileDescriptor
View Source 
var File_cs_records_nsq_proto protoreflect.FileDescriptor
View Source 
var File_cs_records_redis_proto protoreflect.FileDescriptor
View Source 
var File_cs_records_redis_streams_proto protoreflect.FileDescriptor
View Source 
var File_cs_records_sqs_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AMQPHeader 

type AMQPHeader 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"`
	// contains filtered or unexported fields
}

func (*AMQPHeader) Descriptor deprecated 

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

Deprecated: Use AMQPHeader.ProtoReflect.Descriptor instead.

func (*AMQPHeader) GetKey 

func (x *AMQPHeader) GetKey() string

func (*AMQPHeader) GetValue 

func (x *AMQPHeader) GetValue() string

func (*AMQPHeader) ProtoMessage 

func (*AMQPHeader) ProtoMessage()

func (*AMQPHeader) ProtoReflect added in v0.0.24 

func (x *AMQPHeader) ProtoReflect() protoreflect.Message

func (*AMQPHeader) Reset 

func (x *AMQPHeader) Reset()

func (*AMQPHeader) String 

func (x *AMQPHeader) String() string

type AMQPSinkRecord 

type AMQPSinkRecord 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         []*AMQPHeader `protobuf:"bytes,15,rep,name=headers,proto3" json:"headers,omitempty"`
	ForceDeadLetter bool          `protobuf:"varint,16,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

See: https://godoc.org/github.com/streadway/amqp#Delivery

func (*AMQPSinkRecord) Descriptor deprecated 

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

Deprecated: Use AMQPSinkRecord.ProtoReflect.Descriptor instead.

func (*AMQPSinkRecord) GetAppId 

func (x *AMQPSinkRecord) GetAppId() string

func (*AMQPSinkRecord) GetBody 

func (x *AMQPSinkRecord) GetBody() []byte

func (*AMQPSinkRecord) GetContentEncoding 

func (x *AMQPSinkRecord) GetContentEncoding() string

func (*AMQPSinkRecord) GetContentType 

func (x *AMQPSinkRecord) GetContentType() string

func (*AMQPSinkRecord) GetCorrelationId 

func (x *AMQPSinkRecord) GetCorrelationId() string

func (*AMQPSinkRecord) GetExchange 

func (x *AMQPSinkRecord) GetExchange() string

func (*AMQPSinkRecord) GetExpiration 

func (x *AMQPSinkRecord) GetExpiration() string

func (*AMQPSinkRecord) GetForceDeadLetter added in v0.0.22 

func (x *AMQPSinkRecord) GetForceDeadLetter() bool

func (*AMQPSinkRecord) GetHeaders 

func (x *AMQPSinkRecord) GetHeaders() []*AMQPHeader

func (*AMQPSinkRecord) GetMessageId 

func (x *AMQPSinkRecord) GetMessageId() string

func (*AMQPSinkRecord) GetPriority 

func (x *AMQPSinkRecord) GetPriority() int32

func (*AMQPSinkRecord) GetReplyTo 

func (x *AMQPSinkRecord) GetReplyTo() string

func (*AMQPSinkRecord) GetRoutingKey 

func (x *AMQPSinkRecord) GetRoutingKey() string

func (*AMQPSinkRecord) GetTimestamp 

func (x *AMQPSinkRecord) GetTimestamp() int64

func (*AMQPSinkRecord) GetType 

func (x *AMQPSinkRecord) GetType() string

func (*AMQPSinkRecord) GetUserId 

func (x *AMQPSinkRecord) GetUserId() string

func (*AMQPSinkRecord) ProtoMessage 

func (*AMQPSinkRecord) ProtoMessage()

func (*AMQPSinkRecord) ProtoReflect added in v0.0.24 

func (x *AMQPSinkRecord) ProtoReflect() protoreflect.Message

func (*AMQPSinkRecord) Reset 

func (x *AMQPSinkRecord) Reset()

func (*AMQPSinkRecord) String 

func (x *AMQPSinkRecord) String() string

type AzureSinkRecord 

type AzureSinkRecord 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"`
	Data             []byte                 `protobuf:"bytes,3,opt,name=data,proto3" json:"data,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"`
	ForceDeadLetter  bool                   `protobuf:"varint,17,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

See: https://github.com/Azure/azure-service-bus-go/blob/78c960db000c65f4e32d01371b496d5b33f59c38/message.go#L40

func (*AzureSinkRecord) Descriptor deprecated 

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

Deprecated: Use AzureSinkRecord.ProtoReflect.Descriptor instead.

func (*AzureSinkRecord) GetContentType 

func (x *AzureSinkRecord) GetContentType() string

func (*AzureSinkRecord) GetCorrelationId 

func (x *AzureSinkRecord) GetCorrelationId() string

func (*AzureSinkRecord) GetData 

func (x *AzureSinkRecord) GetData() []byte

func (*AzureSinkRecord) GetDeliveryCount 

func (x *AzureSinkRecord) GetDeliveryCount() uint32

func (*AzureSinkRecord) GetForceDeadLetter added in v0.0.22 

func (x *AzureSinkRecord) GetForceDeadLetter() bool

func (*AzureSinkRecord) GetFormat 

func (x *AzureSinkRecord) GetFormat() uint32

func (*AzureSinkRecord) GetGroupSequence 

func (x *AzureSinkRecord) GetGroupSequence() uint32

func (*AzureSinkRecord) GetId 

func (x *AzureSinkRecord) GetId() string

func (*AzureSinkRecord) GetLabel 

func (x *AzureSinkRecord) GetLabel() string

func (*AzureSinkRecord) GetLockToken 

func (x *AzureSinkRecord) GetLockToken() string

func (*AzureSinkRecord) GetReplyTo 

func (x *AzureSinkRecord) GetReplyTo() string

func (*AzureSinkRecord) GetReplyToGroupId 

func (x *AzureSinkRecord) GetReplyToGroupId() string

func (*AzureSinkRecord) GetSessionId 

func (x *AzureSinkRecord) GetSessionId() string

func (*AzureSinkRecord) GetSystemProperties 

func (x *AzureSinkRecord) GetSystemProperties() *AzureSystemProperties

func (*AzureSinkRecord) GetTo 

func (x *AzureSinkRecord) GetTo() string

func (*AzureSinkRecord) GetTtl 

func (x *AzureSinkRecord) GetTtl() int64

func (*AzureSinkRecord) GetUserProperties 

func (x *AzureSinkRecord) GetUserProperties() map[string]string

func (*AzureSinkRecord) ProtoMessage 

func (*AzureSinkRecord) ProtoMessage()

func (*AzureSinkRecord) ProtoReflect added in v0.0.24 

func (x *AzureSinkRecord) ProtoReflect() protoreflect.Message

func (*AzureSinkRecord) Reset 

func (x *AzureSinkRecord) Reset()

func (*AzureSinkRecord) String 

func (x *AzureSinkRecord) String() string

type AzureSystemProperties 

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 */
	// contains filtered or unexported fields
}

func (*AzureSystemProperties) Descriptor deprecated 

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

Deprecated: Use AzureSystemProperties.ProtoReflect.Descriptor instead.

func (*AzureSystemProperties) GetAnnotations 

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

func (*AzureSystemProperties) GetDeadLetterSource 

func (x *AzureSystemProperties) GetDeadLetterSource() string

func (*AzureSystemProperties) GetEnqueuedSequenceNumber 

func (x *AzureSystemProperties) GetEnqueuedSequenceNumber() int64

func (*AzureSystemProperties) GetEnqueuedTime 

func (x *AzureSystemProperties) GetEnqueuedTime() int64

func (*AzureSystemProperties) GetLockedUntil 

func (x *AzureSystemProperties) GetLockedUntil() int64

func (*AzureSystemProperties) GetPartitionId 

func (x *AzureSystemProperties) GetPartitionId() int32

func (*AzureSystemProperties) GetPartitionKey 

func (x *AzureSystemProperties) GetPartitionKey() string

func (*AzureSystemProperties) GetScheduledEnqueueTime 

func (x *AzureSystemProperties) GetScheduledEnqueueTime() int64

func (*AzureSystemProperties) GetSequenceNumber 

func (x *AzureSystemProperties) GetSequenceNumber() int64

func (*AzureSystemProperties) GetViaPartitionKey 

func (x *AzureSystemProperties) GetViaPartitionKey() string

func (*AzureSystemProperties) ProtoMessage 

func (*AzureSystemProperties) ProtoMessage()

func (*AzureSystemProperties) ProtoReflect added in v0.0.24 

func (x *AzureSystemProperties) ProtoReflect() protoreflect.Message

func (*AzureSystemProperties) Reset 

func (x *AzureSystemProperties) Reset()

func (*AzureSystemProperties) String 

func (x *AzureSystemProperties) String() string

type GCPRecord 

type GCPRecord struct {
	Id              string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Data            []byte            `protobuf:"bytes,2,opt,name=data,proto3" json:"data,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"`
	ForceDeadLetter bool              `protobuf:"varint,7,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

func (*GCPRecord) Descriptor deprecated 

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

Deprecated: Use GCPRecord.ProtoReflect.Descriptor instead.

func (*GCPRecord) GetAttributes 

func (x *GCPRecord) GetAttributes() map[string]string

func (*GCPRecord) GetData 

func (x *GCPRecord) GetData() []byte

func (*GCPRecord) GetDeliveryAttempt 

func (x *GCPRecord) GetDeliveryAttempt() int32

func (*GCPRecord) GetForceDeadLetter added in v0.0.22 

func (x *GCPRecord) GetForceDeadLetter() bool

func (*GCPRecord) GetId 

func (x *GCPRecord) GetId() string

func (*GCPRecord) GetOrderingKey 

func (x *GCPRecord) GetOrderingKey() string

func (*GCPRecord) GetPublishTime 

func (x *GCPRecord) GetPublishTime() int64

func (*GCPRecord) ProtoMessage 

func (*GCPRecord) ProtoMessage()

func (*GCPRecord) ProtoReflect added in v0.0.24 

func (x *GCPRecord) ProtoReflect() protoreflect.Message

func (*GCPRecord) Reset 

func (x *GCPRecord) Reset()

func (*GCPRecord) String 

func (x *GCPRecord) String() string

type GenericRecord 

type GenericRecord struct {
	Body            []byte            `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	Source          string            `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Timestamp       int64             `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // client unix nano
	Metadata        map[string]string ``                                                                         /* 157-byte string literal not displayed */
	ForceDeadLetter bool              `protobuf:"varint,5,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

func (*GenericRecord) Descriptor deprecated 

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

Deprecated: Use GenericRecord.ProtoReflect.Descriptor instead.

func (*GenericRecord) GetBody 

func (x *GenericRecord) GetBody() []byte

func (*GenericRecord) GetForceDeadLetter added in v0.0.22 

func (x *GenericRecord) GetForceDeadLetter() bool

func (*GenericRecord) GetMetadata 

func (x *GenericRecord) GetMetadata() map[string]string

func (*GenericRecord) GetSource 

func (x *GenericRecord) GetSource() string

func (*GenericRecord) GetTimestamp 

func (x *GenericRecord) GetTimestamp() int64

func (*GenericRecord) ProtoMessage 

func (*GenericRecord) ProtoMessage()

func (*GenericRecord) ProtoReflect added in v0.0.24 

func (x *GenericRecord) ProtoReflect() protoreflect.Message

func (*GenericRecord) Reset 

func (x *GenericRecord) Reset()

func (*GenericRecord) String 

func (x *GenericRecord) String() string

type HTTPRecord 

type HTTPRecord struct {
	Method          string            `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Headers         map[string]string `` /* 155-byte string literal not displayed */
	Path            string            `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Source          string            `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	Body            []byte            `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	Timestamp       int64             `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ForceDeadLetter bool              `protobuf:"varint,7,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPRecord) Descriptor deprecated 

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

Deprecated: Use HTTPRecord.ProtoReflect.Descriptor instead.

func (*HTTPRecord) GetBody 

func (x *HTTPRecord) GetBody() []byte

func (*HTTPRecord) GetForceDeadLetter added in v0.0.22 

func (x *HTTPRecord) GetForceDeadLetter() bool

func (*HTTPRecord) GetHeaders 

func (x *HTTPRecord) GetHeaders() map[string]string

func (*HTTPRecord) GetMethod 

func (x *HTTPRecord) GetMethod() string

func (*HTTPRecord) GetPath 

func (x *HTTPRecord) GetPath() string

func (*HTTPRecord) GetSource 

func (x *HTTPRecord) GetSource() string

func (*HTTPRecord) GetTimestamp 

func (x *HTTPRecord) GetTimestamp() int64

func (*HTTPRecord) ProtoMessage 

func (*HTTPRecord) ProtoMessage()

func (*HTTPRecord) ProtoReflect added in v0.0.24 

func (x *HTTPRecord) ProtoReflect() protoreflect.Message

func (*HTTPRecord) Reset 

func (x *HTTPRecord) Reset()

func (*HTTPRecord) String 

func (x *HTTPRecord) String() string

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"`
	// contains filtered or unexported fields
}

func (*KafkaHeader) Descriptor deprecated 

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

Deprecated: Use KafkaHeader.ProtoReflect.Descriptor instead.

func (*KafkaHeader) GetKey 

func (x *KafkaHeader) GetKey() string

func (*KafkaHeader) GetValue 

func (x *KafkaHeader) GetValue() string

func (*KafkaHeader) ProtoMessage 

func (*KafkaHeader) ProtoMessage()

func (*KafkaHeader) ProtoReflect added in v0.0.24 

func (x *KafkaHeader) ProtoReflect() protoreflect.Message

func (*KafkaHeader) Reset 

func (x *KafkaHeader) Reset()

func (*KafkaHeader) String 

func (x *KafkaHeader) String() string

type KafkaSinkRecord 

type KafkaSinkRecord 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"`
	ForceDeadLetter bool           `protobuf:"varint,8,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

func (*KafkaSinkRecord) Descriptor deprecated 

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

Deprecated: Use KafkaSinkRecord.ProtoReflect.Descriptor instead.

func (*KafkaSinkRecord) GetForceDeadLetter added in v0.0.22 

func (x *KafkaSinkRecord) GetForceDeadLetter() bool

func (*KafkaSinkRecord) GetHeaders 

func (x *KafkaSinkRecord) GetHeaders() []*KafkaHeader

func (*KafkaSinkRecord) GetKey 

func (x *KafkaSinkRecord) GetKey() []byte

func (*KafkaSinkRecord) GetOffset 

func (x *KafkaSinkRecord) GetOffset() int64

func (*KafkaSinkRecord) GetPartition 

func (x *KafkaSinkRecord) GetPartition() int32

func (*KafkaSinkRecord) GetTimestamp 

func (x *KafkaSinkRecord) GetTimestamp() int64

func (*KafkaSinkRecord) GetTopic 

func (x *KafkaSinkRecord) GetTopic() string

func (*KafkaSinkRecord) GetValue 

func (x *KafkaSinkRecord) GetValue() []byte

func (*KafkaSinkRecord) ProtoMessage 

func (*KafkaSinkRecord) ProtoMessage()

func (*KafkaSinkRecord) ProtoReflect added in v0.0.24 

func (x *KafkaSinkRecord) ProtoReflect() protoreflect.Message

func (*KafkaSinkRecord) Reset 

func (x *KafkaSinkRecord) Reset()

func (*KafkaSinkRecord) String 

func (x *KafkaSinkRecord) String() string

type KubeMQRecord 

type KubeMQRecord 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"`
	ForceDeadLetter bool   `protobuf:"varint,7,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

func (*KubeMQRecord) Descriptor deprecated 

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

Deprecated: Use KubeMQRecord.ProtoReflect.Descriptor instead.

func (*KubeMQRecord) GetChannel 

func (x *KubeMQRecord) GetChannel() string

func (*KubeMQRecord) GetClientId 

func (x *KubeMQRecord) GetClientId() string

func (*KubeMQRecord) GetForceDeadLetter added in v0.0.22 

func (x *KubeMQRecord) GetForceDeadLetter() bool

func (*KubeMQRecord) GetId 

func (x *KubeMQRecord) GetId() string

func (*KubeMQRecord) GetSequence 

func (x *KubeMQRecord) GetSequence() int64

func (*KubeMQRecord) GetTimestamp 

func (x *KubeMQRecord) GetTimestamp() int64

func (*KubeMQRecord) GetValue 

func (x *KubeMQRecord) GetValue() []byte

func (*KubeMQRecord) ProtoMessage 

func (*KubeMQRecord) ProtoMessage()

func (*KubeMQRecord) ProtoReflect added in v0.0.24 

func (x *KubeMQRecord) ProtoReflect() protoreflect.Message

func (*KubeMQRecord) Reset 

func (x *KubeMQRecord) Reset()

func (*KubeMQRecord) String 

func (x *KubeMQRecord) String() string

type MQTTRecord 

type MQTTRecord 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"` // unix nano
	ForceDeadLetter bool   `protobuf:"varint,8,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

func (*MQTTRecord) Descriptor deprecated 

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

Deprecated: Use MQTTRecord.ProtoReflect.Descriptor instead.

func (*MQTTRecord) GetDuplicate 

func (x *MQTTRecord) GetDuplicate() bool

func (*MQTTRecord) GetForceDeadLetter added in v0.0.22 

func (x *MQTTRecord) GetForceDeadLetter() bool

func (*MQTTRecord) GetId 

func (x *MQTTRecord) GetId() uint32

func (*MQTTRecord) GetQos 

func (x *MQTTRecord) GetQos() uint32

func (*MQTTRecord) GetRetained 

func (x *MQTTRecord) GetRetained() bool

func (*MQTTRecord) GetTimestamp 

func (x *MQTTRecord) GetTimestamp() int64

func (*MQTTRecord) GetTopic 

func (x *MQTTRecord) GetTopic() string

func (*MQTTRecord) GetValue 

func (x *MQTTRecord) GetValue() []byte

func (*MQTTRecord) ProtoMessage 

func (*MQTTRecord) ProtoMessage()

func (*MQTTRecord) ProtoReflect added in v0.0.24 

func (x *MQTTRecord) ProtoReflect() protoreflect.Message

func (*MQTTRecord) Reset 

func (x *MQTTRecord) Reset()

func (*MQTTRecord) String 

func (x *MQTTRecord) String() string

type NATSJetStreamRecord added in v0.0.7 

type NATSJetStreamRecord struct {
	Stream          string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	Value           []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp       int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // unix nano
	ForceDeadLetter bool   `protobuf:"varint,4,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

func (*NATSJetStreamRecord) Descriptor deprecated added in v0.0.7 

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

Deprecated: Use NATSJetStreamRecord.ProtoReflect.Descriptor instead.

func (*NATSJetStreamRecord) GetForceDeadLetter added in v0.0.22 

func (x *NATSJetStreamRecord) GetForceDeadLetter() bool

func (*NATSJetStreamRecord) GetStream added in v0.0.7 

func (x *NATSJetStreamRecord) GetStream() string

func (*NATSJetStreamRecord) GetTimestamp added in v0.0.7 

func (x *NATSJetStreamRecord) GetTimestamp() int64

func (*NATSJetStreamRecord) GetValue added in v0.0.7 

func (x *NATSJetStreamRecord) GetValue() []byte

func (*NATSJetStreamRecord) ProtoMessage added in v0.0.7 

func (*NATSJetStreamRecord) ProtoMessage()

func (*NATSJetStreamRecord) ProtoReflect added in v0.0.24 

func (x *NATSJetStreamRecord) ProtoReflect() protoreflect.Message

func (*NATSJetStreamRecord) Reset added in v0.0.7 

func (x *NATSJetStreamRecord) Reset()

func (*NATSJetStreamRecord) String added in v0.0.7 

func (x *NATSJetStreamRecord) String() string

type NATSRecord added in v0.0.7 

type NATSRecord 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"`
	Timestamp       int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // unix nano
	ForceDeadLetter bool   `protobuf:"varint,4,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

func (*NATSRecord) Descriptor deprecated added in v0.0.7 

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

Deprecated: Use NATSRecord.ProtoReflect.Descriptor instead.

func (*NATSRecord) GetForceDeadLetter added in v0.0.22 

func (x *NATSRecord) GetForceDeadLetter() bool

func (*NATSRecord) GetSubject added in v0.0.7 

func (x *NATSRecord) GetSubject() string

func (*NATSRecord) GetTimestamp added in v0.0.7 

func (x *NATSRecord) GetTimestamp() int64

func (*NATSRecord) GetValue added in v0.0.7 

func (x *NATSRecord) GetValue() []byte

func (*NATSRecord) ProtoMessage added in v0.0.7 

func (*NATSRecord) ProtoMessage()

func (*NATSRecord) ProtoReflect added in v0.0.24 

func (x *NATSRecord) ProtoReflect() protoreflect.Message

func (*NATSRecord) Reset added in v0.0.7 

func (x *NATSRecord) Reset()

func (*NATSRecord) String added in v0.0.7 

func (x *NATSRecord) String() string

type NATSStreamingRecord added in v0.0.7 

type NATSStreamingRecord struct {
	Channel         string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Value           []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Sequence        uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Subject         string `protobuf:"bytes,4,opt,name=subject,proto3" json:"subject,omitempty"`
	Redelivered     bool   `protobuf:"varint,5,opt,name=redelivered,proto3" json:"redelivered,omitempty"`
	RedeliveryCount uint32 `protobuf:"varint,6,opt,name=redelivery_count,json=redeliveryCount,proto3" json:"redelivery_count,omitempty"`
	Crc32           uint32 `protobuf:"varint,7,opt,name=crc32,proto3" json:"crc32,omitempty"`
	Timestamp       int64  `protobuf:"varint,8,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // unix nano
	ForceDeadLetter bool   `protobuf:"varint,9,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

func (*NATSStreamingRecord) Descriptor deprecated added in v0.0.7 

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

Deprecated: Use NATSStreamingRecord.ProtoReflect.Descriptor instead.

func (*NATSStreamingRecord) GetChannel added in v0.0.8 

func (x *NATSStreamingRecord) GetChannel() string

func (*NATSStreamingRecord) GetCrc32 added in v0.0.7 

func (x *NATSStreamingRecord) GetCrc32() uint32

func (*NATSStreamingRecord) GetForceDeadLetter added in v0.0.22 

func (x *NATSStreamingRecord) GetForceDeadLetter() bool

func (*NATSStreamingRecord) GetRedelivered added in v0.0.7 

func (x *NATSStreamingRecord) GetRedelivered() bool

func (*NATSStreamingRecord) GetRedeliveryCount added in v0.0.7 

func (x *NATSStreamingRecord) GetRedeliveryCount() uint32

func (*NATSStreamingRecord) GetSequence added in v0.0.7 

func (x *NATSStreamingRecord) GetSequence() uint64

func (*NATSStreamingRecord) GetSubject added in v0.0.7 

func (x *NATSStreamingRecord) GetSubject() string

func (*NATSStreamingRecord) GetTimestamp added in v0.0.7 

func (x *NATSStreamingRecord) GetTimestamp() int64

func (*NATSStreamingRecord) GetValue added in v0.0.7 

func (x *NATSStreamingRecord) GetValue() []byte

func (*NATSStreamingRecord) ProtoMessage added in v0.0.7 

func (*NATSStreamingRecord) ProtoMessage()

func (*NATSStreamingRecord) ProtoReflect added in v0.0.24 

func (x *NATSStreamingRecord) ProtoReflect() protoreflect.Message

func (*NATSStreamingRecord) Reset added in v0.0.7 

func (x *NATSStreamingRecord) Reset()

func (*NATSStreamingRecord) String added in v0.0.7 

func (x *NATSStreamingRecord) String() string

type NSQRecord 

type NSQRecord 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"` // unix nano
	ForceDeadLetter bool   `protobuf:"varint,8,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

func (*NSQRecord) Descriptor deprecated 

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

Deprecated: Use NSQRecord.ProtoReflect.Descriptor instead.

func (*NSQRecord) GetAttempts 

func (x *NSQRecord) GetAttempts() int32

func (*NSQRecord) GetChannel 

func (x *NSQRecord) GetChannel() string

func (*NSQRecord) GetForceDeadLetter added in v0.0.22 

func (x *NSQRecord) GetForceDeadLetter() bool

func (*NSQRecord) GetId 

func (x *NSQRecord) GetId() string

func (*NSQRecord) GetNsqdAddress 

func (x *NSQRecord) GetNsqdAddress() string

func (*NSQRecord) GetTimestamp 

func (x *NSQRecord) GetTimestamp() int64

func (*NSQRecord) GetTopic 

func (x *NSQRecord) GetTopic() string

func (*NSQRecord) GetValue 

func (x *NSQRecord) GetValue() []byte

func (*NSQRecord) ProtoMessage 

func (*NSQRecord) ProtoMessage()

func (*NSQRecord) ProtoReflect added in v0.0.24 

func (x *NSQRecord) ProtoReflect() protoreflect.Message

func (*NSQRecord) Reset 

func (x *NSQRecord) Reset()

func (*NSQRecord) String 

func (x *NSQRecord) String() string

type RedisRecord 

type RedisRecord struct {
	Payload         string `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Channel         string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	Timestamp       int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // unix nano
	ForceDeadLetter bool   `protobuf:"varint,4,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

func (*RedisRecord) Descriptor deprecated 

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

Deprecated: Use RedisRecord.ProtoReflect.Descriptor instead.

func (*RedisRecord) GetChannel 

func (x *RedisRecord) GetChannel() string

func (*RedisRecord) GetForceDeadLetter added in v0.0.22 

func (x *RedisRecord) GetForceDeadLetter() bool

func (*RedisRecord) GetPayload 

func (x *RedisRecord) GetPayload() string

func (*RedisRecord) GetTimestamp 

func (x *RedisRecord) GetTimestamp() int64

func (*RedisRecord) ProtoMessage 

func (*RedisRecord) ProtoMessage()

func (*RedisRecord) ProtoReflect added in v0.0.24 

func (x *RedisRecord) ProtoReflect() protoreflect.Message

func (*RedisRecord) Reset 

func (x *RedisRecord) Reset()

func (*RedisRecord) String 

func (x *RedisRecord) String() string

type RedisStreamsRecord 

type RedisStreamsRecord 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"` // unix nano
	ForceDeadLetter bool   `protobuf:"varint,6,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

func (*RedisStreamsRecord) Descriptor deprecated 

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

Deprecated: Use RedisStreamsRecord.ProtoReflect.Descriptor instead.

func (*RedisStreamsRecord) GetForceDeadLetter added in v0.0.22 

func (x *RedisStreamsRecord) GetForceDeadLetter() bool

func (*RedisStreamsRecord) GetId 

func (x *RedisStreamsRecord) GetId() string

func (*RedisStreamsRecord) GetKey 

func (x *RedisStreamsRecord) GetKey() string

func (*RedisStreamsRecord) GetStream 

func (x *RedisStreamsRecord) GetStream() string

func (*RedisStreamsRecord) GetTimestamp 

func (x *RedisStreamsRecord) GetTimestamp() int64

func (*RedisStreamsRecord) GetValue 

func (x *RedisStreamsRecord) GetValue() string

func (*RedisStreamsRecord) ProtoMessage 

func (*RedisStreamsRecord) ProtoMessage()

func (*RedisStreamsRecord) ProtoReflect added in v0.0.24 

func (x *RedisStreamsRecord) ProtoReflect() protoreflect.Message

func (*RedisStreamsRecord) Reset 

func (x *RedisStreamsRecord) Reset()

func (*RedisStreamsRecord) String 

func (x *RedisStreamsRecord) String() string

type SQSRecord 

type SQSRecord struct {
	Attributes        map[string]string                     `` /* 161-byte string literal not displayed */
	Messageattributes map[string]*SQSRecordMessageAttribute `` /* 175-byte string literal not displayed */
	Messageid         string                                `protobuf:"bytes,3,opt,name=messageid,proto3" json:"messageid,omitempty"`
	Receipt           string                                `protobuf:"bytes,4,opt,name=receipt,proto3" json:"receipt,omitempty"`
	Body              []byte                                `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	Timestamp         int64                                 `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ForceDeadLetter   bool                                  `protobuf:"varint,7,opt,name=force_dead_letter,json=forceDeadLetter,proto3" json:"force_dead_letter,omitempty"`
	// contains filtered or unexported fields
}

See: https://godoc.org/github.com/datacratic/aws-sdk-go/service/sqs#Message

func (*SQSRecord) Descriptor deprecated 

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

Deprecated: Use SQSRecord.ProtoReflect.Descriptor instead.

func (*SQSRecord) GetAttributes 

func (x *SQSRecord) GetAttributes() map[string]string

func (*SQSRecord) GetBody 

func (x *SQSRecord) GetBody() []byte

func (*SQSRecord) GetForceDeadLetter added in v0.0.22 

func (x *SQSRecord) GetForceDeadLetter() bool

func (*SQSRecord) GetMessageattributes 

func (x *SQSRecord) GetMessageattributes() map[string]*SQSRecordMessageAttribute

func (*SQSRecord) GetMessageid 

func (x *SQSRecord) GetMessageid() string

func (*SQSRecord) GetReceipt 

func (x *SQSRecord) GetReceipt() string

func (*SQSRecord) GetTimestamp 

func (x *SQSRecord) GetTimestamp() int64

func (*SQSRecord) ProtoMessage 

func (*SQSRecord) ProtoMessage()

func (*SQSRecord) ProtoReflect added in v0.0.24 

func (x *SQSRecord) ProtoReflect() protoreflect.Message

func (*SQSRecord) Reset 

func (x *SQSRecord) Reset()

func (*SQSRecord) String 

func (x *SQSRecord) String() string

type SQSRecordMessageAttribute 

type SQSRecordMessageAttribute struct {
	Datatype    string `protobuf:"bytes,1,opt,name=datatype,proto3" json:"datatype,omitempty"`
	Stringvalue string `protobuf:"bytes,2,opt,name=stringvalue,proto3" json:"stringvalue,omitempty"`
	Binaryvalue []byte `protobuf:"bytes,3,opt,name=binaryvalue,proto3" json:"binaryvalue,omitempty"`
	// contains filtered or unexported fields
}

func (*SQSRecordMessageAttribute) Descriptor deprecated 

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

Deprecated: Use SQSRecordMessageAttribute.ProtoReflect.Descriptor instead.

func (*SQSRecordMessageAttribute) GetBinaryvalue 

func (x *SQSRecordMessageAttribute) GetBinaryvalue() []byte

func (*SQSRecordMessageAttribute) GetDatatype 

func (x *SQSRecordMessageAttribute) GetDatatype() string

func (*SQSRecordMessageAttribute) GetStringvalue 

func (x *SQSRecordMessageAttribute) GetStringvalue() string

func (*SQSRecordMessageAttribute) ProtoMessage 

func (*SQSRecordMessageAttribute) ProtoMessage()

func (*SQSRecordMessageAttribute) ProtoReflect added in v0.0.24 

func (x *SQSRecordMessageAttribute) ProtoReflect() protoreflect.Message

func (*SQSRecordMessageAttribute) Reset 

func (x *SQSRecordMessageAttribute) Reset()

func (*SQSRecordMessageAttribute) String 

func (x *SQSRecordMessageAttribute) 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.