eventsourcingv1

package
v0.0.0-...-d9d87c4 Latest Latest
Warning

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

 Go to latest Published: Dec 30, 2022 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_eventsourcing_v1_eventsourcing_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AppendRequest 

type AppendRequest struct {
	Transaction *ComponentsTransaction `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendRequest) Descriptor deprecated 

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

Deprecated: Use AppendRequest.ProtoReflect.Descriptor instead.

func (*AppendRequest) GetTransaction 

func (x *AppendRequest) GetTransaction() *ComponentsTransaction

func (*AppendRequest) ProtoMessage 

func (*AppendRequest) ProtoMessage()

func (*AppendRequest) ProtoReflect 

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

func (*AppendRequest) Reset 

func (x *AppendRequest) Reset()

func (*AppendRequest) String 

func (x *AppendRequest) String() string

type AppendResponse 

type AppendResponse struct {
	EventId   int64  `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	Integrity []byte `protobuf:"bytes,2,opt,name=integrity,proto3" json:"integrity,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendResponse) Descriptor deprecated 

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

Deprecated: Use AppendResponse.ProtoReflect.Descriptor instead.

func (*AppendResponse) GetEventId 

func (x *AppendResponse) GetEventId() int64

func (*AppendResponse) GetIntegrity 

func (x *AppendResponse) GetIntegrity() []byte

func (*AppendResponse) ProtoMessage 

func (*AppendResponse) ProtoMessage()

func (*AppendResponse) ProtoReflect 

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

func (*AppendResponse) Reset 

func (x *AppendResponse) Reset()

func (*AppendResponse) String 

func (x *AppendResponse) String() string

type ComponentsTransaction 

type ComponentsTransaction struct {
	I64S     []int64                                `protobuf:"varint,1,rep,packed,name=i64s,proto3" json:"i64s,omitempty"`
	F64S     []float64                              `protobuf:"fixed64,2,rep,packed,name=f64s,proto3" json:"f64s,omitempty"`
	Texts    []string                               `protobuf:"bytes,3,rep,name=texts,proto3" json:"texts,omitempty"`
	Binaries [][]byte                               `protobuf:"bytes,4,rep,name=binaries,proto3" json:"binaries,omitempty"`
	Patches  map[int64]*ComponentsTransaction_Patch `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ComponentsTransaction) Descriptor deprecated 

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

Deprecated: Use ComponentsTransaction.ProtoReflect.Descriptor instead.

func (*ComponentsTransaction) GetBinaries 

func (x *ComponentsTransaction) GetBinaries() [][]byte

func (*ComponentsTransaction) GetF64S 

func (x *ComponentsTransaction) GetF64S() []float64

func (*ComponentsTransaction) GetI64S 

func (x *ComponentsTransaction) GetI64S() []int64

func (*ComponentsTransaction) GetPatches 

func (x *ComponentsTransaction) GetPatches() map[int64]*ComponentsTransaction_Patch

func (*ComponentsTransaction) GetTexts 

func (x *ComponentsTransaction) GetTexts() []string

func (*ComponentsTransaction) ProtoMessage 

func (*ComponentsTransaction) ProtoMessage()

func (*ComponentsTransaction) ProtoReflect 

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

func (*ComponentsTransaction) Reset 

func (x *ComponentsTransaction) Reset()

func (*ComponentsTransaction) String 

func (x *ComponentsTransaction) String() string

type ComponentsTransaction_ColumnIndex 

type ComponentsTransaction_ColumnIndex struct {
	TableIndex      uint32 `protobuf:"varint,1,opt,name=table_index,json=tableIndex,proto3" json:"table_index,omitempty"`
	PatchFieldIndex uint32 `protobuf:"varint,2,opt,name=patch_field_index,json=patchFieldIndex,proto3" json:"patch_field_index,omitempty"`
	// contains filtered or unexported fields
}

func (*ComponentsTransaction_ColumnIndex) Descriptor deprecated 

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

Deprecated: Use ComponentsTransaction_ColumnIndex.ProtoReflect.Descriptor instead.

func (*ComponentsTransaction_ColumnIndex) GetPatchFieldIndex 

func (x *ComponentsTransaction_ColumnIndex) GetPatchFieldIndex() uint32

func (*ComponentsTransaction_ColumnIndex) GetTableIndex 

func (x *ComponentsTransaction_ColumnIndex) GetTableIndex() uint32

func (*ComponentsTransaction_ColumnIndex) ProtoMessage 

func (*ComponentsTransaction_ColumnIndex) ProtoMessage()

func (*ComponentsTransaction_ColumnIndex) ProtoReflect 

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

func (*ComponentsTransaction_ColumnIndex) Reset 

func (x *ComponentsTransaction_ColumnIndex) Reset()

func (*ComponentsTransaction_ColumnIndex) String 

func (x *ComponentsTransaction_ColumnIndex) String() string

type ComponentsTransaction_PairLastEvent 

type ComponentsTransaction_PairLastEvent struct {
	Pair              *EntityPair `protobuf:"bytes,1,opt,name=pair,proto3" json:"pair,omitempty"`
	LastEventLedgerId int64       `protobuf:"varint,2,opt,name=last_event_ledger_id,json=lastEventLedgerId,proto3" json:"last_event_ledger_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ComponentsTransaction_PairLastEvent) Descriptor deprecated 

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

Deprecated: Use ComponentsTransaction_PairLastEvent.ProtoReflect.Descriptor instead.

func (*ComponentsTransaction_PairLastEvent) GetLastEventLedgerId 

func (x *ComponentsTransaction_PairLastEvent) GetLastEventLedgerId() int64

func (*ComponentsTransaction_PairLastEvent) GetPair 

func (x *ComponentsTransaction_PairLastEvent) GetPair() *EntityPair

func (*ComponentsTransaction_PairLastEvent) ProtoMessage 

func (*ComponentsTransaction_PairLastEvent) ProtoMessage()

func (*ComponentsTransaction_PairLastEvent) ProtoReflect 

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

func (*ComponentsTransaction_PairLastEvent) Reset 

func (x *ComponentsTransaction_PairLastEvent) Reset()

func (*ComponentsTransaction_PairLastEvent) String 

func (x *ComponentsTransaction_PairLastEvent) String() string

type ComponentsTransaction_PairPatch 

type ComponentsTransaction_PairPatch struct {
	PairLastEvent *ComponentsTransaction_PairLastEvent `protobuf:"bytes,1,opt,name=pair_last_event,json=pairLastEvent,proto3" json:"pair_last_event,omitempty"`
	ColumnIndices []*ComponentsTransaction_ColumnIndex `protobuf:"bytes,2,rep,name=column_indices,json=columnIndices,proto3" json:"column_indices,omitempty"`
	// contains filtered or unexported fields
}

func (*ComponentsTransaction_PairPatch) Descriptor deprecated 

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

Deprecated: Use ComponentsTransaction_PairPatch.ProtoReflect.Descriptor instead.

func (*ComponentsTransaction_PairPatch) GetColumnIndices 

func (x *ComponentsTransaction_PairPatch) GetColumnIndices() []*ComponentsTransaction_ColumnIndex

func (*ComponentsTransaction_PairPatch) GetPairLastEvent 

func (x *ComponentsTransaction_PairPatch) GetPairLastEvent() *ComponentsTransaction_PairLastEvent

func (*ComponentsTransaction_PairPatch) ProtoMessage 

func (*ComponentsTransaction_PairPatch) ProtoMessage()

func (*ComponentsTransaction_PairPatch) ProtoReflect 

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

func (*ComponentsTransaction_PairPatch) Reset 

func (x *ComponentsTransaction_PairPatch) Reset()

func (*ComponentsTransaction_PairPatch) String 

func (x *ComponentsTransaction_PairPatch) String() string

type ComponentsTransaction_Patch 

type ComponentsTransaction_Patch struct {
	AddedPairs         []*EntityPair                          `protobuf:"bytes,1,rep,name=added_pairs,json=addedPairs,proto3" json:"added_pairs,omitempty"`
	RemovedPairs       []*ComponentsTransaction_PairLastEvent `protobuf:"bytes,2,rep,name=removed_pairs,json=removedPairs,proto3" json:"removed_pairs,omitempty"`
	UpdatedPairPatches []*ComponentsTransaction_PairPatch     `protobuf:"bytes,3,rep,name=updated_pair_patches,json=updatedPairPatches,proto3" json:"updated_pair_patches,omitempty"`
	// contains filtered or unexported fields
}

func (*ComponentsTransaction_Patch) Descriptor deprecated 

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

Deprecated: Use ComponentsTransaction_Patch.ProtoReflect.Descriptor instead.

func (*ComponentsTransaction_Patch) GetAddedPairs 

func (x *ComponentsTransaction_Patch) GetAddedPairs() []*EntityPair

func (*ComponentsTransaction_Patch) GetRemovedPairs 

func (x *ComponentsTransaction_Patch) GetRemovedPairs() []*ComponentsTransaction_PairLastEvent

func (*ComponentsTransaction_Patch) GetUpdatedPairPatches 

func (x *ComponentsTransaction_Patch) GetUpdatedPairPatches() []*ComponentsTransaction_PairPatch

func (*ComponentsTransaction_Patch) ProtoMessage 

func (*ComponentsTransaction_Patch) ProtoMessage()

func (*ComponentsTransaction_Patch) ProtoReflect 

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

func (*ComponentsTransaction_Patch) Reset 

func (x *ComponentsTransaction_Patch) Reset()

func (*ComponentsTransaction_Patch) String 

func (x *ComponentsTransaction_Patch) String() string

type EntityPair 

type EntityPair struct {
	FromEntity int64 `protobuf:"varint,1,opt,name=from_entity,json=fromEntity,proto3" json:"from_entity,omitempty"`
	ToEntity   int64 `protobuf:"varint,2,opt,name=to_entity,json=toEntity,proto3" json:"to_entity,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityPair) Descriptor deprecated 

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

Deprecated: Use EntityPair.ProtoReflect.Descriptor instead.

func (*EntityPair) GetFromEntity 

func (x *EntityPair) GetFromEntity() int64

func (*EntityPair) GetToEntity 

func (x *EntityPair) GetToEntity() int64

func (*EntityPair) ProtoMessage 

func (*EntityPair) ProtoMessage()

func (*EntityPair) ProtoReflect 

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

func (*EntityPair) Reset 

func (x *EntityPair) Reset()

func (*EntityPair) String 

func (x *EntityPair) String() string

type EventsRequest 

type EventsRequest struct {
	LastEventId          int64   `protobuf:"varint,1,opt,name=last_event_id,json=lastEventId,proto3" json:"last_event_id,omitempty"`
	Limit                uint32  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	EffectedComponentIds []int64 `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EventsRequest) Descriptor deprecated 

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

Deprecated: Use EventsRequest.ProtoReflect.Descriptor instead.

func (*EventsRequest) GetEffectedComponentIds 

func (x *EventsRequest) GetEffectedComponentIds() []int64

func (*EventsRequest) GetLastEventId 

func (x *EventsRequest) GetLastEventId() int64

func (*EventsRequest) GetLimit 

func (x *EventsRequest) GetLimit() uint32

func (*EventsRequest) ProtoMessage 

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) ProtoReflect 

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

func (*EventsRequest) Reset 

func (x *EventsRequest) Reset()

func (*EventsRequest) String 

func (x *EventsRequest) String() string

type EventsResponse 

type EventsResponse struct {
	Events  []*EventsResponse_Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	HasMore bool                    `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
	Count   int64                   `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*EventsResponse) Descriptor deprecated 

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

Deprecated: Use EventsResponse.ProtoReflect.Descriptor instead.

func (*EventsResponse) GetCount 

func (x *EventsResponse) GetCount() int64

func (*EventsResponse) GetEvents 

func (x *EventsResponse) GetEvents() []*EventsResponse_Event

func (*EventsResponse) GetHasMore 

func (x *EventsResponse) GetHasMore() bool

func (*EventsResponse) ProtoMessage 

func (*EventsResponse) ProtoMessage()

func (*EventsResponse) ProtoReflect 

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

func (*EventsResponse) Reset 

func (x *EventsResponse) Reset()

func (*EventsResponse) String 

func (x *EventsResponse) String() string

type EventsResponse_Event 

type EventsResponse_Event struct {
	Id          int64                  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Integrity   []byte                 `protobuf:"bytes,2,opt,name=integrity,proto3" json:"integrity,omitempty"`
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Transaction *ComponentsTransaction `protobuf:"bytes,4,opt,name=transaction,proto3" json:"transaction,omitempty"`
	// contains filtered or unexported fields
}

func (*EventsResponse_Event) Descriptor deprecated 

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

Deprecated: Use EventsResponse_Event.ProtoReflect.Descriptor instead.

func (*EventsResponse_Event) GetCreatedAt 

func (x *EventsResponse_Event) GetCreatedAt() *timestamppb.Timestamp

func (*EventsResponse_Event) GetId 

func (x *EventsResponse_Event) GetId() int64

func (*EventsResponse_Event) GetIntegrity 

func (x *EventsResponse_Event) GetIntegrity() []byte

func (*EventsResponse_Event) GetTransaction 

func (x *EventsResponse_Event) GetTransaction() *ComponentsTransaction

func (*EventsResponse_Event) ProtoMessage 

func (*EventsResponse_Event) ProtoMessage()

func (*EventsResponse_Event) ProtoReflect 

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

func (*EventsResponse_Event) Reset 

func (x *EventsResponse_Event) Reset()

func (*EventsResponse_Event) String 

func (x *EventsResponse_Event) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.