persistencev1

Documentation

Index

• Variables
• type ConsiderSnapshot
  • func (*ConsiderSnapshot) Descriptor() ([]byte, []int)
  • func (x *ConsiderSnapshot) GetPayload() *anypb.Any
  • func (*ConsiderSnapshot) ProtoMessage()
  • func (x *ConsiderSnapshot) ProtoReflect() protoreflect.Message
  • func (x *ConsiderSnapshot) Reset()
  • func (x *ConsiderSnapshot) String() string
• type EventRecord
  • func (*EventRecord) Descriptor() ([]byte, []int)
  • func (x *EventRecord) GetId() string
  • func (x *EventRecord) GetMetadata() map[string]string
  • func (x *EventRecord) GetPayload() *anypb.Any
  • func (x *EventRecord) GetStreamId() string
  • func (x *EventRecord) GetTags() []string
  • func (x *EventRecord) GetTimestamp() *timestamppb.Timestamp
  • func (x *EventRecord) GetType() string
  • func (x *EventRecord) GetVersion() uint64
  • func (*EventRecord) ProtoMessage()
  • func (x *EventRecord) ProtoReflect() protoreflect.Message
  • func (x *EventRecord) Reset()
  • func (x *EventRecord) String() string
• type SnapshotRecord
  • func (*SnapshotRecord) Descriptor() ([]byte, []int)
  • func (x *SnapshotRecord) GetId() string
  • func (x *SnapshotRecord) GetMetadata() map[string]string
  • func (x *SnapshotRecord) GetPayload() *anypb.Any
  • func (x *SnapshotRecord) GetTimestamp() *timestamppb.Timestamp
  • func (x *SnapshotRecord) GetType() string
  • func (x *SnapshotRecord) GetVersion() uint64
  • func (*SnapshotRecord) ProtoMessage()
  • func (x *SnapshotRecord) ProtoReflect() protoreflect.Message
  • func (x *SnapshotRecord) Reset()
  • func (x *SnapshotRecord) String() string

Variables

var File_persistence_v1_messages_proto protoreflect.FileDescriptor

var File_persistence_v1_records_proto protoreflect.FileDescriptor

Types

type ConsiderSnapshot

type ConsiderSnapshot struct {
	Payload *anypb.Any `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsiderSnapshot) Descriptor

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

Deprecated: Use ConsiderSnapshot.ProtoReflect.Descriptor instead.

func (*ConsiderSnapshot) GetPayload

func (x *ConsiderSnapshot) GetPayload() *anypb.Any

func (*ConsiderSnapshot) ProtoMessage

func (*ConsiderSnapshot) ProtoMessage()

func (*ConsiderSnapshot) ProtoReflect

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

func (*ConsiderSnapshot) Reset

func (x *ConsiderSnapshot) Reset()

func (*ConsiderSnapshot) String

func (x *ConsiderSnapshot) String() string

type EventRecord

type EventRecord struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type      string                 `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	StreamId  string                 `protobuf:"bytes,3,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Version   uint64                 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	Tags      []string               `protobuf:"bytes,5,rep,name=tags,proto3" json:"tags,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Metadata  map[string]string      `` /* 157-byte string literal not displayed */
	Payload   *anypb.Any             `protobuf:"bytes,8,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

EventRecord represents a single event in the event stream.

func (*EventRecord) Descriptor

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

Deprecated: Use EventRecord.ProtoReflect.Descriptor instead.

func (*EventRecord) GetId

func (x *EventRecord) GetId() string

func (*EventRecord) GetMetadata

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

func (*EventRecord) GetPayload

func (x *EventRecord) GetPayload() *anypb.Any

func (*EventRecord) GetStreamId

func (x *EventRecord) GetStreamId() string

func (*EventRecord) GetTags

func (x *EventRecord) GetTags() []string

func (*EventRecord) GetTimestamp

func (x *EventRecord) GetTimestamp() *timestamppb.Timestamp

func (*EventRecord) GetType

func (x *EventRecord) GetType() string

func (*EventRecord) GetVersion

func (x *EventRecord) GetVersion() uint64

func (*EventRecord) ProtoMessage

func (*EventRecord) ProtoMessage()

func (*EventRecord) ProtoReflect

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

func (*EventRecord) Reset

func (x *EventRecord) Reset()

func (*EventRecord) String

func (x *EventRecord) String() string

type SnapshotRecord

type SnapshotRecord struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type      string                 `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Version   uint64                 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Metadata  map[string]string      `` /* 157-byte string literal not displayed */
	Payload   *anypb.Any             `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotRecord) Descriptor

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

Deprecated: Use SnapshotRecord.ProtoReflect.Descriptor instead.

func (*SnapshotRecord) GetId

func (x *SnapshotRecord) GetId() string

func (*SnapshotRecord) GetMetadata

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

func (*SnapshotRecord) GetPayload

func (x *SnapshotRecord) GetPayload() *anypb.Any

func (*SnapshotRecord) GetTimestamp

func (x *SnapshotRecord) GetTimestamp() *timestamppb.Timestamp

func (*SnapshotRecord) GetType

func (x *SnapshotRecord) GetType() string

func (*SnapshotRecord) GetVersion

func (x *SnapshotRecord) GetVersion() uint64

func (*SnapshotRecord) ProtoMessage

func (*SnapshotRecord) ProtoMessage()

func (*SnapshotRecord) ProtoReflect

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

func (*SnapshotRecord) Reset

func (x *SnapshotRecord) Reset()

func (*SnapshotRecord) String

func (x *SnapshotRecord) String() string