Documentation
¶
Index ¶
- Variables
- type Command
- type Publish
- type Published
- func (e *Published) AggregateID() string
- func (*Published) Descriptor() ([]byte, []int)deprecated
- func (e *Published) EventType() string
- func (x *Published) GetDeviceId() string
- func (x *Published) GetEventTimestamp() int64
- func (x *Published) GetEventVersion() uint64
- func (x *Published) GetHref() string
- func (e *Published) GroupID() string
- func (e *Published) IsSnapshot() bool
- func (e *Published) Marshal() ([]byte, error)
- func (*Published) ProtoMessage()
- func (x *Published) ProtoReflect() protoreflect.Message
- func (x *Published) Reset()
- func (x *Published) String() string
- func (e *Published) Timestamp() time.Time
- func (e *Published) Unmarshal(b []byte) error
- func (e *Published) Version() uint64
- type Snapshot
- func (e *Snapshot) AggregateID() string
- func (*Snapshot) Descriptor() ([]byte, []int)deprecated
- func (e *Snapshot) EventType() string
- func (x *Snapshot) GetDeviceId() string
- func (x *Snapshot) GetEventTimestamp() int64
- func (x *Snapshot) GetEventVersion() uint64
- func (x *Snapshot) GetHref() string
- func (x *Snapshot) GetIsPublished() bool
- func (e *Snapshot) GroupID() string
- func (e *Snapshot) GroupId() string
- func (e *Snapshot) Handle(ctx context.Context, iter eventstore.Iter) error
- func (e *Snapshot) HandleCommand(ctx context.Context, cmd Command, newVersion uint64) ([]eventstore.Event, error)
- func (e *Snapshot) IsSnapshot() bool
- func (e *Snapshot) Marshal() ([]byte, error)
- func (*Snapshot) ProtoMessage()
- func (x *Snapshot) ProtoReflect() protoreflect.Message
- func (x *Snapshot) Reset()
- func (x *Snapshot) String() string
- func (e *Snapshot) TakeSnapshot(version uint64) (eventstore.Event, bool)
- func (e *Snapshot) Timestamp() time.Time
- func (e *Snapshot) Unmarshal(b []byte) error
- func (e *Snapshot) Version() uint64
- type Unpublish
- type Unpublished
- func (e *Unpublished) AggregateID() string
- func (*Unpublished) Descriptor() ([]byte, []int)deprecated
- func (e *Unpublished) EventType() string
- func (x *Unpublished) GetDeviceId() string
- func (x *Unpublished) GetEventTimestamp() int64
- func (x *Unpublished) GetEventVersion() uint64
- func (x *Unpublished) GetHref() string
- func (e *Unpublished) GroupID() string
- func (e *Unpublished) IsSnapshot() bool
- func (e *Unpublished) Marshal() ([]byte, error)
- func (*Unpublished) ProtoMessage()
- func (x *Unpublished) ProtoReflect() protoreflect.Message
- func (x *Unpublished) Reset()
- func (x *Unpublished) String() string
- func (e *Unpublished) Timestamp() time.Time
- func (e *Unpublished) Unmarshal(b []byte) error
- func (e *Unpublished) Version() uint64
Constants ¶
This section is empty.
Variables ¶
View Source
var File_resource_aggregate_cqrs_aggregate_test_aggregate_test_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Publish ¶
type Publish struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` Href string `protobuf:"bytes,2,opt,name=href,proto3" json:"href,omitempty"` // contains filtered or unexported fields }
func (*Publish) Descriptor
deprecated
func (*Publish) GetDeviceId ¶
func (*Publish) ProtoMessage ¶
func (*Publish) ProtoMessage()
func (*Publish) ProtoReflect ¶
func (x *Publish) ProtoReflect() protoreflect.Message
type Published ¶
type Published struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` Href string `protobuf:"bytes,2,opt,name=href,proto3" json:"href,omitempty"` EventVersion uint64 `protobuf:"varint,3,opt,name=event_version,json=eventVersion,proto3" json:"event_version,omitempty"` EventTimestamp int64 `protobuf:"varint,4,opt,name=event_timestamp,json=eventTimestamp,proto3" json:"event_timestamp,omitempty"` // contains filtered or unexported fields }
func (*Published) AggregateID ¶
func (*Published) Descriptor
deprecated
func (*Published) GetDeviceId ¶
func (*Published) GetEventTimestamp ¶
func (*Published) GetEventVersion ¶
func (*Published) IsSnapshot ¶
func (*Published) ProtoMessage ¶
func (*Published) ProtoMessage()
func (*Published) ProtoReflect ¶
func (x *Published) ProtoReflect() protoreflect.Message
type Snapshot ¶
type Snapshot struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` Href string `protobuf:"bytes,2,opt,name=href,proto3" json:"href,omitempty"` IsPublished bool `protobuf:"varint,3,opt,name=is_published,json=isPublished,proto3" json:"is_published,omitempty"` EventVersion uint64 `protobuf:"varint,4,opt,name=event_version,json=eventVersion,proto3" json:"event_version,omitempty"` EventTimestamp int64 `protobuf:"varint,5,opt,name=event_timestamp,json=eventTimestamp,proto3" json:"event_timestamp,omitempty"` // contains filtered or unexported fields }
func (*Snapshot) AggregateID ¶
func (*Snapshot) Descriptor
deprecated
func (*Snapshot) GetDeviceId ¶
func (*Snapshot) GetEventTimestamp ¶
func (*Snapshot) GetEventVersion ¶
func (*Snapshot) GetIsPublished ¶
func (*Snapshot) HandleCommand ¶
func (*Snapshot) IsSnapshot ¶
func (*Snapshot) ProtoMessage ¶
func (*Snapshot) ProtoMessage()
func (*Snapshot) ProtoReflect ¶
func (x *Snapshot) ProtoReflect() protoreflect.Message
func (*Snapshot) TakeSnapshot ¶
func (e *Snapshot) TakeSnapshot(version uint64) (eventstore.Event, bool)
type Unpublish ¶
type Unpublish struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` Href string `protobuf:"bytes,2,opt,name=href,proto3" json:"href,omitempty"` // contains filtered or unexported fields }
func (*Unpublish) Descriptor
deprecated
func (*Unpublish) GetDeviceId ¶
func (*Unpublish) ProtoMessage ¶
func (*Unpublish) ProtoMessage()
func (*Unpublish) ProtoReflect ¶
func (x *Unpublish) ProtoReflect() protoreflect.Message
type Unpublished ¶
type Unpublished struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` Href string `protobuf:"bytes,2,opt,name=href,proto3" json:"href,omitempty"` EventVersion uint64 `protobuf:"varint,3,opt,name=event_version,json=eventVersion,proto3" json:"event_version,omitempty"` EventTimestamp int64 `protobuf:"varint,4,opt,name=event_timestamp,json=eventTimestamp,proto3" json:"event_timestamp,omitempty"` // contains filtered or unexported fields }
func (*Unpublished) AggregateID ¶
func (e *Unpublished) AggregateID() string
func (*Unpublished) Descriptor
deprecated
func (*Unpublished) Descriptor() ([]byte, []int)
Deprecated: Use Unpublished.ProtoReflect.Descriptor instead.
func (*Unpublished) EventType ¶
func (e *Unpublished) EventType() string
func (*Unpublished) GetDeviceId ¶
func (x *Unpublished) GetDeviceId() string
func (*Unpublished) GetEventTimestamp ¶
func (x *Unpublished) GetEventTimestamp() int64
func (*Unpublished) GetEventVersion ¶
func (x *Unpublished) GetEventVersion() uint64
func (*Unpublished) GetHref ¶
func (x *Unpublished) GetHref() string
func (*Unpublished) GroupID ¶
func (e *Unpublished) GroupID() string
func (*Unpublished) IsSnapshot ¶
func (e *Unpublished) IsSnapshot() bool
func (*Unpublished) Marshal ¶
func (e *Unpublished) Marshal() ([]byte, error)
func (*Unpublished) ProtoMessage ¶
func (*Unpublished) ProtoMessage()
func (*Unpublished) ProtoReflect ¶
func (x *Unpublished) ProtoReflect() protoreflect.Message
func (*Unpublished) Reset ¶
func (x *Unpublished) Reset()
func (*Unpublished) String ¶
func (x *Unpublished) String() string
func (*Unpublished) Timestamp ¶
func (e *Unpublished) Timestamp() time.Time
func (*Unpublished) Unmarshal ¶
func (e *Unpublished) Unmarshal(b []byte) error
func (*Unpublished) Version ¶
func (e *Unpublished) Version() uint64
Click to show internal directories.
Click to hide internal directories.