persistencev1

package
v0.0.0-...-a71f0cf Latest Latest
Warning

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

Go to latest
Published: Apr 22, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_persistence_v1_messages_proto protoreflect.FileDescriptor
View Source
var File_persistence_v1_records_proto protoreflect.FileDescriptor

Functions

This section is empty.

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 deprecated

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"`
	SequenceNumber   uint64                 `protobuf:"varint,5,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	Tags             []string               `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
	StorageTimestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=storage_timestamp,json=storageTimestamp,proto3" json:"storage_timestamp,omitempty"`
	Metadata         map[string]string      `` /* 157-byte string literal not displayed */
	Payload          *anypb.Any             `protobuf:"bytes,9,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*EventRecord) Descriptor deprecated

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) GetSequenceNumber

func (x *EventRecord) GetSequenceNumber() uint64

func (*EventRecord) GetStorageTimestamp

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

func (*EventRecord) GetStreamId

func (x *EventRecord) GetStreamId() string

func (*EventRecord) GetTags

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

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"`
	StorageTimestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=storage_timestamp,json=storageTimestamp,proto3" json:"storage_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 deprecated

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) GetStorageTimestamp

func (x *SnapshotRecord) GetStorageTimestamp() *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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL