proto

Documentation

Index

• Variables
• func SchemaHash(schema map[string]string) string
• type EventSchemaKey
  • func (*EventSchemaKey) Descriptor() ([]byte, []int)
  • func (x *EventSchemaKey) GetEventIdentifier() string
  • func (x *EventSchemaKey) GetEventType() string
  • func (x *EventSchemaKey) GetWriteKey() string
  • func (esk *EventSchemaKey) MustMarshal() []byte
  • func (*EventSchemaKey) ProtoMessage()
  • func (x *EventSchemaKey) ProtoReflect() protoreflect.Message
  • func (x *EventSchemaKey) Reset()
  • func (x *EventSchemaKey) String() string
• type EventSchemaMessage
  • func UnmarshalEventSchemaMessage(raw []byte) (*EventSchemaMessage, error)
  • func (*EventSchemaMessage) Descriptor() ([]byte, []int)
  • func (x *EventSchemaMessage) GetBatchCount() int64
  • func (x *EventSchemaMessage) GetCorrelationID() []byte
  • func (x *EventSchemaMessage) GetHash() string
  • func (x *EventSchemaMessage) GetKey() *EventSchemaKey
  • func (x *EventSchemaMessage) GetObservedAt() *timestamppb.Timestamp
  • func (x *EventSchemaMessage) GetSample() []byte
  • func (x *EventSchemaMessage) GetSchema() map[string]string
  • func (x *EventSchemaMessage) GetWorkspaceID() string
  • func (sm *EventSchemaMessage) Merge(other *EventSchemaMessage)
  • func (esm *EventSchemaMessage) MustMarshal() []byte
  • func (*EventSchemaMessage) ProtoMessage()
  • func (x *EventSchemaMessage) ProtoReflect() protoreflect.Message
  • func (x *EventSchemaMessage) Reset()
  • func (x *EventSchemaMessage) String() string

Variables

var File_proto_event_schema_types_proto protoreflect.FileDescriptor

Functions

func SchemaHash

func SchemaHash(schema map[string]string) string

SchemaHash returns a hash of the schema. Keys are sorted lexicographically during hashing.

Types

type EventSchemaKey

type EventSchemaKey struct {
	WriteKey        string `protobuf:"bytes,1,opt,name=writeKey,proto3" json:"writeKey,omitempty"`
	EventType       string `protobuf:"bytes,2,opt,name=eventType,proto3" json:"eventType,omitempty"`
	EventIdentifier string `protobuf:"bytes,3,opt,name=eventIdentifier,proto3" json:"eventIdentifier,omitempty"`
	// contains filtered or unexported fields
}

func (*EventSchemaKey) Descriptor

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

Deprecated: Use EventSchemaKey.ProtoReflect.Descriptor instead.

func (*EventSchemaKey) GetEventIdentifier

func (x *EventSchemaKey) GetEventIdentifier() string

func (*EventSchemaKey) GetEventType

func (x *EventSchemaKey) GetEventType() string

func (*EventSchemaKey) GetWriteKey

func (x *EventSchemaKey) GetWriteKey() string

func (*EventSchemaKey) MustMarshal

func (esk *EventSchemaKey) MustMarshal() []byte

func (*EventSchemaKey) ProtoMessage

func (*EventSchemaKey) ProtoMessage()

func (*EventSchemaKey) ProtoReflect

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

func (*EventSchemaKey) Reset

func (x *EventSchemaKey) Reset()

func (*EventSchemaKey) String

func (x *EventSchemaKey) String() string

type EventSchemaMessage

type EventSchemaMessage struct {
	WorkspaceID   string                 `protobuf:"bytes,1,opt,name=workspaceID,proto3" json:"workspaceID,omitempty"`
	Key           *EventSchemaKey        `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Schema        map[string]string      `` /* 153-byte string literal not displayed */
	ObservedAt    *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=observedAt,proto3" json:"observedAt,omitempty"`
	Sample        []byte                 `protobuf:"bytes,5,opt,name=sample,proto3" json:"sample,omitempty"`
	CorrelationID []byte                 `protobuf:"bytes,6,opt,name=correlationID,proto3" json:"correlationID,omitempty"`
	Hash          string                 `protobuf:"bytes,7,opt,name=hash,proto3" json:"hash,omitempty"`
	BatchCount    int64                  `protobuf:"varint,8,opt,name=batchCount,proto3" json:"batchCount,omitempty"`
	// contains filtered or unexported fields
}

func UnmarshalEventSchemaMessage

func UnmarshalEventSchemaMessage(raw []byte) (*EventSchemaMessage, error)

UnmarshalEventSchemaMessage creates a new event schema message from the provided protobuf bytes.

func (*EventSchemaMessage) Descriptor

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

Deprecated: Use EventSchemaMessage.ProtoReflect.Descriptor instead.

func (*EventSchemaMessage) GetBatchCount

func (x *EventSchemaMessage) GetBatchCount() int64

func (*EventSchemaMessage) GetCorrelationID

func (x *EventSchemaMessage) GetCorrelationID() []byte

func (*EventSchemaMessage) GetHash

func (x *EventSchemaMessage) GetHash() string

func (*EventSchemaMessage) GetKey

func (x *EventSchemaMessage) GetKey() *EventSchemaKey

func (*EventSchemaMessage) GetObservedAt

func (x *EventSchemaMessage) GetObservedAt() *timestamppb.Timestamp

func (*EventSchemaMessage) GetSample

func (x *EventSchemaMessage) GetSample() []byte

func (*EventSchemaMessage) GetSchema

func (x *EventSchemaMessage) GetSchema() map[string]string

func (*EventSchemaMessage) GetWorkspaceID

func (x *EventSchemaMessage) GetWorkspaceID() string

func (*EventSchemaMessage) Merge

func (sm *EventSchemaMessage) Merge(other *EventSchemaMessage)

Merge merges the other event schema message into this one.

func (*EventSchemaMessage) MustMarshal

func (esm *EventSchemaMessage) MustMarshal() []byte

func (*EventSchemaMessage) ProtoMessage

func (*EventSchemaMessage) ProtoMessage()

func (*EventSchemaMessage) ProtoReflect

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

func (*EventSchemaMessage) Reset

func (x *EventSchemaMessage) Reset()

func (*EventSchemaMessage) String

func (x *EventSchemaMessage) String() string