Documentation ¶
Index ¶
- Variables
- func EqualResource(x, y *commands.Resource) bool
- func EqualStringSlice(x, y []string) bool
- func IsExpired(now time.Time, validUntil time.Time) bool
- func RemoveIndex(s []int, index int) []int
- type DeviceMetadataSnapshotTaken
- func (d *DeviceMetadataSnapshotTaken) AggregateID() string
- func (d *DeviceMetadataSnapshotTaken) CancelPendingMetadataUpdates(ctx context.Context, userID string, ...) ([]eventstore.Event, error)
- func (d *DeviceMetadataSnapshotTaken) CheckInitialized() bool
- func (d *DeviceMetadataSnapshotTaken) Clone() *DeviceMetadataSnapshotTaken
- func (d *DeviceMetadataSnapshotTaken) ConfirmDeviceMetadataUpdate(ctx context.Context, userID string, ...) ([]eventstore.Event, error)
- func (d *DeviceMetadataSnapshotTaken) CopyData(event *DeviceMetadataSnapshotTaken)
- func (*DeviceMetadataSnapshotTaken) Descriptor() ([]byte, []int)deprecated
- func (d *DeviceMetadataSnapshotTaken) EventType() string
- func (x *DeviceMetadataSnapshotTaken) GetDeviceId() string
- func (x *DeviceMetadataSnapshotTaken) GetDeviceMetadataUpdated() *DeviceMetadataUpdated
- func (x *DeviceMetadataSnapshotTaken) GetEventMetadata() *EventMetadata
- func (x *DeviceMetadataSnapshotTaken) GetUpdatePendings() []*DeviceMetadataUpdatePending
- func (d *DeviceMetadataSnapshotTaken) GroupID() string
- func (d *DeviceMetadataSnapshotTaken) Handle(ctx context.Context, iter eventstore.Iter) error
- func (d *DeviceMetadataSnapshotTaken) HandleCommand(ctx context.Context, cmd aggregate.Command, newVersion uint64) ([]eventstore.Event, error)
- func (d *DeviceMetadataSnapshotTaken) HandleDeviceMetadataSnapshotTaken(ctx context.Context, s *DeviceMetadataSnapshotTaken)
- func (d *DeviceMetadataSnapshotTaken) HandleDeviceMetadataUpdatePending(ctx context.Context, updatePending *DeviceMetadataUpdatePending) error
- func (d *DeviceMetadataSnapshotTaken) HandleDeviceMetadataUpdated(ctx context.Context, upd *DeviceMetadataUpdated, confirm bool) (bool, error)
- func (d *DeviceMetadataSnapshotTaken) IsSnapshot() bool
- func (d *DeviceMetadataSnapshotTaken) Marshal() ([]byte, error)
- func (*DeviceMetadataSnapshotTaken) ProtoMessage()
- func (x *DeviceMetadataSnapshotTaken) ProtoReflect() protoreflect.Message
- func (x *DeviceMetadataSnapshotTaken) Reset()
- func (x *DeviceMetadataSnapshotTaken) String() string
- func (d *DeviceMetadataSnapshotTaken) TakeSnapshot(version uint64) (eventstore.Event, bool)
- func (d *DeviceMetadataSnapshotTaken) Timestamp() time.Time
- func (d *DeviceMetadataSnapshotTaken) Unmarshal(b []byte) error
- func (d *DeviceMetadataSnapshotTaken) Version() uint64
- type DeviceMetadataUpdatePending
- func (d *DeviceMetadataUpdatePending) AggregateID() string
- func (d *DeviceMetadataUpdatePending) CheckInitialized() bool
- func (d *DeviceMetadataUpdatePending) Clone() *DeviceMetadataUpdatePending
- func (d *DeviceMetadataUpdatePending) CopyData(event *DeviceMetadataUpdatePending)
- func (*DeviceMetadataUpdatePending) Descriptor() ([]byte, []int)deprecated
- func (d *DeviceMetadataUpdatePending) EventType() string
- func (x *DeviceMetadataUpdatePending) GetAuditContext() *commands.AuditContext
- func (x *DeviceMetadataUpdatePending) GetDeviceId() string
- func (x *DeviceMetadataUpdatePending) GetEventMetadata() *EventMetadata
- func (x *DeviceMetadataUpdatePending) GetOpenTelemetryCarrier() map[string]string
- func (x *DeviceMetadataUpdatePending) GetShadowSynchronization() commands.ShadowSynchronization
- func (m *DeviceMetadataUpdatePending) GetUpdatePending() isDeviceMetadataUpdatePending_UpdatePending
- func (x *DeviceMetadataUpdatePending) GetValidUntil() int64
- func (d *DeviceMetadataUpdatePending) GroupID() string
- func (d *DeviceMetadataUpdatePending) IsExpired(now time.Time) bool
- func (d *DeviceMetadataUpdatePending) IsSnapshot() bool
- func (d *DeviceMetadataUpdatePending) Marshal() ([]byte, error)
- func (*DeviceMetadataUpdatePending) ProtoMessage()
- func (x *DeviceMetadataUpdatePending) ProtoReflect() protoreflect.Message
- func (x *DeviceMetadataUpdatePending) Reset()
- func (x *DeviceMetadataUpdatePending) String() string
- func (d *DeviceMetadataUpdatePending) Timestamp() time.Time
- func (d *DeviceMetadataUpdatePending) Unmarshal(b []byte) error
- func (d *DeviceMetadataUpdatePending) ValidUntilTime() time.Time
- func (d *DeviceMetadataUpdatePending) Version() uint64
- type DeviceMetadataUpdatePending_ShadowSynchronization
- type DeviceMetadataUpdated
- func (d *DeviceMetadataUpdated) AggregateID() string
- func (d *DeviceMetadataUpdated) CheckInitialized() bool
- func (d *DeviceMetadataUpdated) Clone() *DeviceMetadataUpdated
- func (d *DeviceMetadataUpdated) CopyData(event *DeviceMetadataUpdated)
- func (*DeviceMetadataUpdated) Descriptor() ([]byte, []int)deprecated
- func (d *DeviceMetadataUpdated) Equal(upd *DeviceMetadataUpdated) bool
- func (d *DeviceMetadataUpdated) EventType() string
- func (x *DeviceMetadataUpdated) GetAuditContext() *commands.AuditContext
- func (x *DeviceMetadataUpdated) GetCanceled() bool
- func (x *DeviceMetadataUpdated) GetDeviceId() string
- func (x *DeviceMetadataUpdated) GetEventMetadata() *EventMetadata
- func (x *DeviceMetadataUpdated) GetOpenTelemetryCarrier() map[string]string
- func (x *DeviceMetadataUpdated) GetShadowSynchronization() commands.ShadowSynchronization
- func (x *DeviceMetadataUpdated) GetStatus() *commands.ConnectionStatus
- func (d *DeviceMetadataUpdated) GroupID() string
- func (d *DeviceMetadataUpdated) IsSnapshot() bool
- func (d *DeviceMetadataUpdated) Marshal() ([]byte, error)
- func (*DeviceMetadataUpdated) ProtoMessage()
- func (x *DeviceMetadataUpdated) ProtoReflect() protoreflect.Message
- func (x *DeviceMetadataUpdated) Reset()
- func (x *DeviceMetadataUpdated) String() string
- func (d *DeviceMetadataUpdated) Timestamp() time.Time
- func (d *DeviceMetadataUpdated) Unmarshal(b []byte) error
- func (d *DeviceMetadataUpdated) Version() uint64
- type EventMetadata
- func (e *EventMetadata) Clone() *EventMetadata
- func (*EventMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *EventMetadata) GetConnectionId() string
- func (x *EventMetadata) GetSequence() uint64
- func (x *EventMetadata) GetTimestamp() int64
- func (x *EventMetadata) GetVersion() uint64
- func (*EventMetadata) ProtoMessage()
- func (x *EventMetadata) ProtoReflect() protoreflect.Message
- func (x *EventMetadata) Reset()
- func (x *EventMetadata) String() string
- type ResourceChanged
- func (rc *ResourceChanged) AggregateID() string
- func (rc *ResourceChanged) CheckInitialized() bool
- func (rc *ResourceChanged) CopyData(event *ResourceChanged)
- func (*ResourceChanged) Descriptor() ([]byte, []int)deprecated
- func (rc *ResourceChanged) Equal(changed *ResourceChanged) bool
- func (rc *ResourceChanged) EventType() string
- func (x *ResourceChanged) GetAuditContext() *commands.AuditContext
- func (x *ResourceChanged) GetContent() *commands.Content
- func (x *ResourceChanged) GetEventMetadata() *EventMetadata
- func (x *ResourceChanged) GetOpenTelemetryCarrier() map[string]string
- func (x *ResourceChanged) GetResourceId() *commands.ResourceId
- func (x *ResourceChanged) GetStatus() commands.Status
- func (rc *ResourceChanged) GroupID() string
- func (rc *ResourceChanged) IsSnapshot() bool
- func (rc *ResourceChanged) Marshal() ([]byte, error)
- func (*ResourceChanged) ProtoMessage()
- func (x *ResourceChanged) ProtoReflect() protoreflect.Message
- func (x *ResourceChanged) Reset()
- func (x *ResourceChanged) String() string
- func (rc *ResourceChanged) Timestamp() time.Time
- func (rc *ResourceChanged) Unmarshal(b []byte) error
- func (rc *ResourceChanged) Version() uint64
- type ResourceCreatePending
- func (e *ResourceCreatePending) AggregateID() string
- func (e *ResourceCreatePending) CheckInitialized() bool
- func (e *ResourceCreatePending) CopyData(event *ResourceCreatePending)
- func (*ResourceCreatePending) Descriptor() ([]byte, []int)deprecated
- func (e *ResourceCreatePending) EventType() string
- func (x *ResourceCreatePending) GetAuditContext() *commands.AuditContext
- func (x *ResourceCreatePending) GetContent() *commands.Content
- func (x *ResourceCreatePending) GetEventMetadata() *EventMetadata
- func (x *ResourceCreatePending) GetOpenTelemetryCarrier() map[string]string
- func (x *ResourceCreatePending) GetResourceId() *commands.ResourceId
- func (x *ResourceCreatePending) GetValidUntil() int64
- func (e *ResourceCreatePending) GroupID() string
- func (e *ResourceCreatePending) IsExpired(now time.Time) bool
- func (e *ResourceCreatePending) IsSnapshot() bool
- func (e *ResourceCreatePending) Marshal() ([]byte, error)
- func (*ResourceCreatePending) ProtoMessage()
- func (x *ResourceCreatePending) ProtoReflect() protoreflect.Message
- func (x *ResourceCreatePending) Reset()
- func (x *ResourceCreatePending) String() string
- func (e *ResourceCreatePending) Timestamp() time.Time
- func (e *ResourceCreatePending) Unmarshal(b []byte) error
- func (e *ResourceCreatePending) ValidUntilTime() time.Time
- func (e *ResourceCreatePending) Version() uint64
- type ResourceCreated
- func (e *ResourceCreated) AggregateID() string
- func (e *ResourceCreated) CheckInitialized() bool
- func (e *ResourceCreated) CopyData(event *ResourceCreated)
- func (*ResourceCreated) Descriptor() ([]byte, []int)deprecated
- func (e *ResourceCreated) EventType() string
- func (x *ResourceCreated) GetAuditContext() *commands.AuditContext
- func (x *ResourceCreated) GetContent() *commands.Content
- func (x *ResourceCreated) GetEventMetadata() *EventMetadata
- func (x *ResourceCreated) GetOpenTelemetryCarrier() map[string]string
- func (x *ResourceCreated) GetResourceId() *commands.ResourceId
- func (x *ResourceCreated) GetStatus() commands.Status
- func (e *ResourceCreated) GroupID() string
- func (e *ResourceCreated) IsSnapshot() bool
- func (e *ResourceCreated) Marshal() ([]byte, error)
- func (*ResourceCreated) ProtoMessage()
- func (x *ResourceCreated) ProtoReflect() protoreflect.Message
- func (x *ResourceCreated) Reset()
- func (x *ResourceCreated) String() string
- func (e *ResourceCreated) Timestamp() time.Time
- func (e *ResourceCreated) Unmarshal(b []byte) error
- func (e *ResourceCreated) Version() uint64
- type ResourceDeletePending
- func (e *ResourceDeletePending) AggregateID() string
- func (e *ResourceDeletePending) CheckInitialized() bool
- func (e *ResourceDeletePending) CopyData(event *ResourceDeletePending)
- func (*ResourceDeletePending) Descriptor() ([]byte, []int)deprecated
- func (e *ResourceDeletePending) EventType() string
- func (x *ResourceDeletePending) GetAuditContext() *commands.AuditContext
- func (x *ResourceDeletePending) GetEventMetadata() *EventMetadata
- func (x *ResourceDeletePending) GetOpenTelemetryCarrier() map[string]string
- func (x *ResourceDeletePending) GetResourceId() *commands.ResourceId
- func (x *ResourceDeletePending) GetValidUntil() int64
- func (e *ResourceDeletePending) GroupID() string
- func (e *ResourceDeletePending) IsExpired(now time.Time) bool
- func (e *ResourceDeletePending) IsSnapshot() bool
- func (e *ResourceDeletePending) Marshal() ([]byte, error)
- func (*ResourceDeletePending) ProtoMessage()
- func (x *ResourceDeletePending) ProtoReflect() protoreflect.Message
- func (x *ResourceDeletePending) Reset()
- func (x *ResourceDeletePending) String() string
- func (e *ResourceDeletePending) Timestamp() time.Time
- func (e *ResourceDeletePending) Unmarshal(b []byte) error
- func (e *ResourceDeletePending) ValidUntilTime() time.Time
- func (e *ResourceDeletePending) Version() uint64
- type ResourceDeleted
- func (e *ResourceDeleted) AggregateID() string
- func (e *ResourceDeleted) CheckInitialized() bool
- func (e *ResourceDeleted) CopyData(event *ResourceDeleted)
- func (*ResourceDeleted) Descriptor() ([]byte, []int)deprecated
- func (e *ResourceDeleted) EventType() string
- func (x *ResourceDeleted) GetAuditContext() *commands.AuditContext
- func (x *ResourceDeleted) GetContent() *commands.Content
- func (x *ResourceDeleted) GetEventMetadata() *EventMetadata
- func (x *ResourceDeleted) GetOpenTelemetryCarrier() map[string]string
- func (x *ResourceDeleted) GetResourceId() *commands.ResourceId
- func (x *ResourceDeleted) GetStatus() commands.Status
- func (e *ResourceDeleted) GroupID() string
- func (e *ResourceDeleted) IsSnapshot() bool
- func (e *ResourceDeleted) Marshal() ([]byte, error)
- func (*ResourceDeleted) ProtoMessage()
- func (x *ResourceDeleted) ProtoReflect() protoreflect.Message
- func (x *ResourceDeleted) Reset()
- func (x *ResourceDeleted) String() string
- func (e *ResourceDeleted) Timestamp() time.Time
- func (e *ResourceDeleted) Unmarshal(b []byte) error
- func (e *ResourceDeleted) Version() uint64
- type ResourceLinksPublished
- func (e *ResourceLinksPublished) AggregateID() string
- func (e *ResourceLinksPublished) CheckInitialized() bool
- func (e *ResourceLinksPublished) CopyData(event *ResourceLinksPublished)
- func (*ResourceLinksPublished) Descriptor() ([]byte, []int)deprecated
- func (e *ResourceLinksPublished) EventType() string
- func (x *ResourceLinksPublished) GetAuditContext() *commands.AuditContext
- func (x *ResourceLinksPublished) GetDeviceId() string
- func (x *ResourceLinksPublished) GetEventMetadata() *EventMetadata
- func (x *ResourceLinksPublished) GetOpenTelemetryCarrier() map[string]string
- func (x *ResourceLinksPublished) GetResources() []*commands.Resource
- func (e *ResourceLinksPublished) GroupID() string
- func (e *ResourceLinksPublished) IsSnapshot() bool
- func (e *ResourceLinksPublished) Marshal() ([]byte, error)
- func (*ResourceLinksPublished) ProtoMessage()
- func (x *ResourceLinksPublished) ProtoReflect() protoreflect.Message
- func (x *ResourceLinksPublished) Reset()
- func (x *ResourceLinksPublished) String() string
- func (e *ResourceLinksPublished) Timestamp() time.Time
- func (e *ResourceLinksPublished) Unmarshal(b []byte) error
- func (e *ResourceLinksPublished) Version() uint64
- type ResourceLinksSnapshotTaken
- func (e *ResourceLinksSnapshotTaken) AggregateID() string
- func (e *ResourceLinksSnapshotTaken) CheckInitialized() bool
- func (e *ResourceLinksSnapshotTaken) CloneData(event *ResourceLinksSnapshotTaken)
- func (e *ResourceLinksSnapshotTaken) CopyData(event *ResourceLinksSnapshotTaken)
- func (*ResourceLinksSnapshotTaken) Descriptor() ([]byte, []int)deprecated
- func (e *ResourceLinksSnapshotTaken) EventType() string
- func (x *ResourceLinksSnapshotTaken) GetAuditContext() *commands.AuditContext
- func (x *ResourceLinksSnapshotTaken) GetDeviceId() string
- func (x *ResourceLinksSnapshotTaken) GetEventMetadata() *EventMetadata
- func (e *ResourceLinksSnapshotTaken) GetNewPublishedLinks(pub *ResourceLinksPublished) []*commands.Resource
- func (x *ResourceLinksSnapshotTaken) GetResources() map[string]*commands.Resource
- func (e *ResourceLinksSnapshotTaken) GroupID() string
- func (e *ResourceLinksSnapshotTaken) Handle(ctx context.Context, iter eventstore.Iter) error
- func (e *ResourceLinksSnapshotTaken) HandleCommand(ctx context.Context, cmd aggregate.Command, newVersion uint64) ([]eventstore.Event, error)
- func (e *ResourceLinksSnapshotTaken) HandleEventResourceLinksPublished(pub *ResourceLinksPublished) []*commands.Resource
- func (e *ResourceLinksSnapshotTaken) HandleEventResourceLinksSnapshotTaken(s *ResourceLinksSnapshotTaken)
- func (e *ResourceLinksSnapshotTaken) HandleEventResourceLinksUnpublished(instanceIDs []int64, upub *ResourceLinksUnpublished) []string
- func (e *ResourceLinksSnapshotTaken) IsSnapshot() bool
- func (e *ResourceLinksSnapshotTaken) Marshal() ([]byte, error)
- func (*ResourceLinksSnapshotTaken) ProtoMessage()
- func (x *ResourceLinksSnapshotTaken) ProtoReflect() protoreflect.Message
- func (x *ResourceLinksSnapshotTaken) Reset()
- func (x *ResourceLinksSnapshotTaken) String() string
- func (e *ResourceLinksSnapshotTaken) TakeSnapshot(version uint64) (eventstore.Event, bool)
- func (e *ResourceLinksSnapshotTaken) Timestamp() time.Time
- func (e *ResourceLinksSnapshotTaken) ToResourceLinksPublished() *ResourceLinksPublished
- func (e *ResourceLinksSnapshotTaken) Unmarshal(b []byte) error
- func (e *ResourceLinksSnapshotTaken) Version() uint64
- type ResourceLinksUnpublished
- func (e *ResourceLinksUnpublished) AggregateID() string
- func (e *ResourceLinksUnpublished) CheckInitialized() bool
- func (e *ResourceLinksUnpublished) CopyData(event *ResourceLinksUnpublished)
- func (*ResourceLinksUnpublished) Descriptor() ([]byte, []int)deprecated
- func (e *ResourceLinksUnpublished) EventType() string
- func (x *ResourceLinksUnpublished) GetAuditContext() *commands.AuditContext
- func (x *ResourceLinksUnpublished) GetDeviceId() string
- func (x *ResourceLinksUnpublished) GetEventMetadata() *EventMetadata
- func (x *ResourceLinksUnpublished) GetHrefs() []string
- func (x *ResourceLinksUnpublished) GetOpenTelemetryCarrier() map[string]string
- func (e *ResourceLinksUnpublished) GroupID() string
- func (e *ResourceLinksUnpublished) IsSnapshot() bool
- func (e *ResourceLinksUnpublished) Marshal() ([]byte, error)
- func (*ResourceLinksUnpublished) ProtoMessage()
- func (x *ResourceLinksUnpublished) ProtoReflect() protoreflect.Message
- func (x *ResourceLinksUnpublished) Reset()
- func (x *ResourceLinksUnpublished) String() string
- func (e *ResourceLinksUnpublished) Timestamp() time.Time
- func (e *ResourceLinksUnpublished) Unmarshal(b []byte) error
- func (e *ResourceLinksUnpublished) Version() uint64
- type ResourceRetrievePending
- func (e *ResourceRetrievePending) AggregateID() string
- func (e *ResourceRetrievePending) CheckInitialized() bool
- func (e *ResourceRetrievePending) CopyData(event *ResourceRetrievePending)
- func (*ResourceRetrievePending) Descriptor() ([]byte, []int)deprecated
- func (e *ResourceRetrievePending) EventType() string
- func (x *ResourceRetrievePending) GetAuditContext() *commands.AuditContext
- func (x *ResourceRetrievePending) GetEventMetadata() *EventMetadata
- func (x *ResourceRetrievePending) GetOpenTelemetryCarrier() map[string]string
- func (x *ResourceRetrievePending) GetResourceId() *commands.ResourceId
- func (x *ResourceRetrievePending) GetResourceInterface() string
- func (x *ResourceRetrievePending) GetValidUntil() int64
- func (e *ResourceRetrievePending) GroupID() string
- func (e *ResourceRetrievePending) IsExpired(now time.Time) bool
- func (e *ResourceRetrievePending) IsSnapshot() bool
- func (e *ResourceRetrievePending) Marshal() ([]byte, error)
- func (*ResourceRetrievePending) ProtoMessage()
- func (x *ResourceRetrievePending) ProtoReflect() protoreflect.Message
- func (x *ResourceRetrievePending) Reset()
- func (x *ResourceRetrievePending) String() string
- func (e *ResourceRetrievePending) Timestamp() time.Time
- func (e *ResourceRetrievePending) Unmarshal(b []byte) error
- func (e *ResourceRetrievePending) ValidUntilTime() time.Time
- func (e *ResourceRetrievePending) Version() uint64
- type ResourceRetrieved
- func (e *ResourceRetrieved) AggregateID() string
- func (e *ResourceRetrieved) CheckInitialized() bool
- func (e *ResourceRetrieved) CopyData(event *ResourceRetrieved)
- func (*ResourceRetrieved) Descriptor() ([]byte, []int)deprecated
- func (e *ResourceRetrieved) EventType() string
- func (x *ResourceRetrieved) GetAuditContext() *commands.AuditContext
- func (x *ResourceRetrieved) GetContent() *commands.Content
- func (x *ResourceRetrieved) GetEventMetadata() *EventMetadata
- func (x *ResourceRetrieved) GetOpenTelemetryCarrier() map[string]string
- func (x *ResourceRetrieved) GetResourceId() *commands.ResourceId
- func (x *ResourceRetrieved) GetStatus() commands.Status
- func (e *ResourceRetrieved) GroupID() string
- func (e *ResourceRetrieved) IsSnapshot() bool
- func (e *ResourceRetrieved) Marshal() ([]byte, error)
- func (*ResourceRetrieved) ProtoMessage()
- func (x *ResourceRetrieved) ProtoReflect() protoreflect.Message
- func (x *ResourceRetrieved) Reset()
- func (x *ResourceRetrieved) String() string
- func (e *ResourceRetrieved) Timestamp() time.Time
- func (e *ResourceRetrieved) Unmarshal(b []byte) error
- func (e *ResourceRetrieved) Version() uint64
- type ResourceStateSnapshotTaken
- func (e *ResourceStateSnapshotTaken) AggregateID() string
- func (e *ResourceStateSnapshotTaken) CancelPendingCommands(ctx context.Context, userID string, req *commands.CancelPendingCommandsRequest, ...) ([]eventstore.Event, error)
- func (e *ResourceStateSnapshotTaken) CheckInitialized() bool
- func (e *ResourceStateSnapshotTaken) ConfirmResourceCreateCommand(ctx context.Context, userID string, req *commands.ConfirmResourceCreateRequest, ...) ([]eventstore.Event, error)
- func (e *ResourceStateSnapshotTaken) ConfirmResourceDeleteCommand(ctx context.Context, userID string, req *commands.ConfirmResourceDeleteRequest, ...) ([]eventstore.Event, error)
- func (e *ResourceStateSnapshotTaken) ConfirmResourceRetrieveCommand(ctx context.Context, userID string, ...) ([]eventstore.Event, error)
- func (e *ResourceStateSnapshotTaken) ConfirmResourceUpdateCommand(ctx context.Context, userID string, req *commands.ConfirmResourceUpdateRequest, ...) ([]eventstore.Event, error)
- func (e *ResourceStateSnapshotTaken) CopyData(event *ResourceStateSnapshotTaken)
- func (*ResourceStateSnapshotTaken) Descriptor() ([]byte, []int)deprecated
- func (e *ResourceStateSnapshotTaken) EventType() string
- func (x *ResourceStateSnapshotTaken) GetAuditContext() *commands.AuditContext
- func (x *ResourceStateSnapshotTaken) GetEventMetadata() *EventMetadata
- func (x *ResourceStateSnapshotTaken) GetLatestResourceChange() *ResourceChanged
- func (x *ResourceStateSnapshotTaken) GetResourceCreatePendings() []*ResourceCreatePending
- func (x *ResourceStateSnapshotTaken) GetResourceDeletePendings() []*ResourceDeletePending
- func (x *ResourceStateSnapshotTaken) GetResourceId() *commands.ResourceId
- func (x *ResourceStateSnapshotTaken) GetResourceRetrievePendings() []*ResourceRetrievePending
- func (x *ResourceStateSnapshotTaken) GetResourceUpdatePendings() []*ResourceUpdatePending
- func (e *ResourceStateSnapshotTaken) GroupID() string
- func (e *ResourceStateSnapshotTaken) Handle(ctx context.Context, iter eventstore.Iter) error
- func (e *ResourceStateSnapshotTaken) HandleCommand(ctx context.Context, cmd aggregate.Command, newVersion uint64) ([]eventstore.Event, error)
- func (e *ResourceStateSnapshotTaken) HandleEventResourceChanged(ctx context.Context, changed *ResourceChanged) (bool, error)
- func (e *ResourceStateSnapshotTaken) HandleEventResourceCreatePending(ctx context.Context, createPending *ResourceCreatePending) error
- func (e *ResourceStateSnapshotTaken) HandleEventResourceCreated(ctx context.Context, created *ResourceCreated) error
- func (e *ResourceStateSnapshotTaken) HandleEventResourceDeletePending(ctx context.Context, deletePending *ResourceDeletePending) error
- func (e *ResourceStateSnapshotTaken) HandleEventResourceDeleted(ctx context.Context, deleted *ResourceDeleted) error
- func (e *ResourceStateSnapshotTaken) HandleEventResourceRetrievePending(ctx context.Context, retrievePending *ResourceRetrievePending) error
- func (e *ResourceStateSnapshotTaken) HandleEventResourceRetrieved(ctx context.Context, retrieved *ResourceRetrieved) error
- func (e *ResourceStateSnapshotTaken) HandleEventResourceStateSnapshotTaken(ctx context.Context, snapshot *ResourceStateSnapshotTaken)
- func (e *ResourceStateSnapshotTaken) HandleEventResourceUpdatePending(ctx context.Context, updatePending *ResourceUpdatePending) error
- func (e *ResourceStateSnapshotTaken) HandleEventResourceUpdated(ctx context.Context, updated *ResourceUpdated) error
- func (e *ResourceStateSnapshotTaken) IsSnapshot() bool
- func (e *ResourceStateSnapshotTaken) Marshal() ([]byte, error)
- func (*ResourceStateSnapshotTaken) ProtoMessage()
- func (x *ResourceStateSnapshotTaken) ProtoReflect() protoreflect.Message
- func (x *ResourceStateSnapshotTaken) Reset()
- func (x *ResourceStateSnapshotTaken) String() string
- func (e *ResourceStateSnapshotTaken) TakeSnapshot(version uint64) (eventstore.Event, bool)
- func (e *ResourceStateSnapshotTaken) Timestamp() time.Time
- func (e *ResourceStateSnapshotTaken) Unmarshal(b []byte) error
- func (e *ResourceStateSnapshotTaken) ValidateSequence(eventMetadata *EventMetadata) bool
- func (e *ResourceStateSnapshotTaken) Version() uint64
- type ResourceUpdatePending
- func (e *ResourceUpdatePending) AggregateID() string
- func (e *ResourceUpdatePending) CheckInitialized() bool
- func (e *ResourceUpdatePending) CopyData(event *ResourceUpdatePending)
- func (*ResourceUpdatePending) Descriptor() ([]byte, []int)deprecated
- func (e *ResourceUpdatePending) EventType() string
- func (x *ResourceUpdatePending) GetAuditContext() *commands.AuditContext
- func (x *ResourceUpdatePending) GetContent() *commands.Content
- func (x *ResourceUpdatePending) GetEventMetadata() *EventMetadata
- func (x *ResourceUpdatePending) GetOpenTelemetryCarrier() map[string]string
- func (x *ResourceUpdatePending) GetResourceId() *commands.ResourceId
- func (x *ResourceUpdatePending) GetResourceInterface() string
- func (x *ResourceUpdatePending) GetValidUntil() int64
- func (e *ResourceUpdatePending) GroupID() string
- func (e *ResourceUpdatePending) IsExpired(now time.Time) bool
- func (e *ResourceUpdatePending) IsSnapshot() bool
- func (e *ResourceUpdatePending) Marshal() ([]byte, error)
- func (*ResourceUpdatePending) ProtoMessage()
- func (x *ResourceUpdatePending) ProtoReflect() protoreflect.Message
- func (x *ResourceUpdatePending) Reset()
- func (x *ResourceUpdatePending) String() string
- func (e *ResourceUpdatePending) Timestamp() time.Time
- func (e *ResourceUpdatePending) Unmarshal(b []byte) error
- func (e *ResourceUpdatePending) ValidUntilTime() time.Time
- func (e *ResourceUpdatePending) Version() uint64
- type ResourceUpdated
- func (e *ResourceUpdated) AggregateID() string
- func (e *ResourceUpdated) CheckInitialized() bool
- func (e *ResourceUpdated) CopyData(event *ResourceUpdated)
- func (*ResourceUpdated) Descriptor() ([]byte, []int)deprecated
- func (e *ResourceUpdated) EventType() string
- func (x *ResourceUpdated) GetAuditContext() *commands.AuditContext
- func (x *ResourceUpdated) GetContent() *commands.Content
- func (x *ResourceUpdated) GetEventMetadata() *EventMetadata
- func (x *ResourceUpdated) GetOpenTelemetryCarrier() map[string]string
- func (x *ResourceUpdated) GetResourceId() *commands.ResourceId
- func (x *ResourceUpdated) GetStatus() commands.Status
- func (e *ResourceUpdated) GroupID() string
- func (e *ResourceUpdated) IsSnapshot() bool
- func (e *ResourceUpdated) Marshal() ([]byte, error)
- func (*ResourceUpdated) ProtoMessage()
- func (x *ResourceUpdated) ProtoReflect() protoreflect.Message
- func (x *ResourceUpdated) Reset()
- func (x *ResourceUpdated) String() string
- func (e *ResourceUpdated) Timestamp() time.Time
- func (e *ResourceUpdated) Unmarshal(b []byte) error
- func (e *ResourceUpdated) Version() uint64
Constants ¶
This section is empty.
Variables ¶
var File_resource_aggregate_pb_events_proto protoreflect.FileDescriptor
Functions ¶
func EqualResource ¶
func EqualStringSlice ¶
func RemoveIndex ¶
Types ¶
type DeviceMetadataSnapshotTaken ¶
type DeviceMetadataSnapshotTaken struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` DeviceMetadataUpdated *DeviceMetadataUpdated `` /* 126-byte string literal not displayed */ UpdatePendings []*DeviceMetadataUpdatePending `protobuf:"bytes,3,rep,name=update_pendings,json=updatePendings,proto3" json:"update_pendings,omitempty"` // expired events will be removed by creating a new snapshot. EventMetadata *EventMetadata `protobuf:"bytes,4,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` // contains filtered or unexported fields }
func NewDeviceMetadataSnapshotTaken ¶
func NewDeviceMetadataSnapshotTaken() *DeviceMetadataSnapshotTaken
func (*DeviceMetadataSnapshotTaken) AggregateID ¶
func (d *DeviceMetadataSnapshotTaken) AggregateID() string
func (*DeviceMetadataSnapshotTaken) CancelPendingMetadataUpdates ¶
func (d *DeviceMetadataSnapshotTaken) CancelPendingMetadataUpdates(ctx context.Context, userID string, req *commands.CancelPendingMetadataUpdatesRequest, newVersion uint64) ([]eventstore.Event, error)
func (*DeviceMetadataSnapshotTaken) CheckInitialized ¶
func (d *DeviceMetadataSnapshotTaken) CheckInitialized() bool
func (*DeviceMetadataSnapshotTaken) Clone ¶
func (d *DeviceMetadataSnapshotTaken) Clone() *DeviceMetadataSnapshotTaken
func (*DeviceMetadataSnapshotTaken) ConfirmDeviceMetadataUpdate ¶
func (d *DeviceMetadataSnapshotTaken) ConfirmDeviceMetadataUpdate(ctx context.Context, userID string, req *commands.ConfirmDeviceMetadataUpdateRequest, newVersion uint64, cancel bool) ([]eventstore.Event, error)
func (*DeviceMetadataSnapshotTaken) CopyData ¶
func (d *DeviceMetadataSnapshotTaken) CopyData(event *DeviceMetadataSnapshotTaken)
func (*DeviceMetadataSnapshotTaken) Descriptor
deprecated
func (*DeviceMetadataSnapshotTaken) Descriptor() ([]byte, []int)
Deprecated: Use DeviceMetadataSnapshotTaken.ProtoReflect.Descriptor instead.
func (*DeviceMetadataSnapshotTaken) EventType ¶
func (d *DeviceMetadataSnapshotTaken) EventType() string
func (*DeviceMetadataSnapshotTaken) GetDeviceId ¶
func (x *DeviceMetadataSnapshotTaken) GetDeviceId() string
func (*DeviceMetadataSnapshotTaken) GetDeviceMetadataUpdated ¶
func (x *DeviceMetadataSnapshotTaken) GetDeviceMetadataUpdated() *DeviceMetadataUpdated
func (*DeviceMetadataSnapshotTaken) GetEventMetadata ¶
func (x *DeviceMetadataSnapshotTaken) GetEventMetadata() *EventMetadata
func (*DeviceMetadataSnapshotTaken) GetUpdatePendings ¶
func (x *DeviceMetadataSnapshotTaken) GetUpdatePendings() []*DeviceMetadataUpdatePending
func (*DeviceMetadataSnapshotTaken) GroupID ¶
func (d *DeviceMetadataSnapshotTaken) GroupID() string
func (*DeviceMetadataSnapshotTaken) Handle ¶
func (d *DeviceMetadataSnapshotTaken) Handle(ctx context.Context, iter eventstore.Iter) error
func (*DeviceMetadataSnapshotTaken) HandleCommand ¶
func (d *DeviceMetadataSnapshotTaken) HandleCommand(ctx context.Context, cmd aggregate.Command, newVersion uint64) ([]eventstore.Event, error)
func (*DeviceMetadataSnapshotTaken) HandleDeviceMetadataSnapshotTaken ¶
func (d *DeviceMetadataSnapshotTaken) HandleDeviceMetadataSnapshotTaken(ctx context.Context, s *DeviceMetadataSnapshotTaken)
func (*DeviceMetadataSnapshotTaken) HandleDeviceMetadataUpdatePending ¶
func (d *DeviceMetadataSnapshotTaken) HandleDeviceMetadataUpdatePending(ctx context.Context, updatePending *DeviceMetadataUpdatePending) error
func (*DeviceMetadataSnapshotTaken) HandleDeviceMetadataUpdated ¶
func (d *DeviceMetadataSnapshotTaken) HandleDeviceMetadataUpdated(ctx context.Context, upd *DeviceMetadataUpdated, confirm bool) (bool, error)
func (*DeviceMetadataSnapshotTaken) IsSnapshot ¶
func (d *DeviceMetadataSnapshotTaken) IsSnapshot() bool
func (*DeviceMetadataSnapshotTaken) Marshal ¶
func (d *DeviceMetadataSnapshotTaken) Marshal() ([]byte, error)
func (*DeviceMetadataSnapshotTaken) ProtoMessage ¶
func (*DeviceMetadataSnapshotTaken) ProtoMessage()
func (*DeviceMetadataSnapshotTaken) ProtoReflect ¶
func (x *DeviceMetadataSnapshotTaken) ProtoReflect() protoreflect.Message
func (*DeviceMetadataSnapshotTaken) Reset ¶
func (x *DeviceMetadataSnapshotTaken) Reset()
func (*DeviceMetadataSnapshotTaken) String ¶
func (x *DeviceMetadataSnapshotTaken) String() string
func (*DeviceMetadataSnapshotTaken) TakeSnapshot ¶
func (d *DeviceMetadataSnapshotTaken) TakeSnapshot(version uint64) (eventstore.Event, bool)
func (*DeviceMetadataSnapshotTaken) Timestamp ¶
func (d *DeviceMetadataSnapshotTaken) Timestamp() time.Time
func (*DeviceMetadataSnapshotTaken) Unmarshal ¶
func (d *DeviceMetadataSnapshotTaken) Unmarshal(b []byte) error
func (*DeviceMetadataSnapshotTaken) Version ¶
func (d *DeviceMetadataSnapshotTaken) Version() uint64
type DeviceMetadataUpdatePending ¶
type DeviceMetadataUpdatePending struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` // Types that are assignable to UpdatePending: // *DeviceMetadataUpdatePending_ShadowSynchronization UpdatePending isDeviceMetadataUpdatePending_UpdatePending `protobuf_oneof:"update_pending"` AuditContext *commands.AuditContext `protobuf:"bytes,3,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` EventMetadata *EventMetadata `protobuf:"bytes,4,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` ValidUntil int64 `protobuf:"varint,5,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when pending event is considered as expired. 0 means forever. // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DeviceMetadataUpdatePending) AggregateID ¶
func (d *DeviceMetadataUpdatePending) AggregateID() string
func (*DeviceMetadataUpdatePending) CheckInitialized ¶
func (d *DeviceMetadataUpdatePending) CheckInitialized() bool
func (*DeviceMetadataUpdatePending) Clone ¶
func (d *DeviceMetadataUpdatePending) Clone() *DeviceMetadataUpdatePending
func (*DeviceMetadataUpdatePending) CopyData ¶
func (d *DeviceMetadataUpdatePending) CopyData(event *DeviceMetadataUpdatePending)
func (*DeviceMetadataUpdatePending) Descriptor
deprecated
func (*DeviceMetadataUpdatePending) Descriptor() ([]byte, []int)
Deprecated: Use DeviceMetadataUpdatePending.ProtoReflect.Descriptor instead.
func (*DeviceMetadataUpdatePending) EventType ¶
func (d *DeviceMetadataUpdatePending) EventType() string
func (*DeviceMetadataUpdatePending) GetAuditContext ¶
func (x *DeviceMetadataUpdatePending) GetAuditContext() *commands.AuditContext
func (*DeviceMetadataUpdatePending) GetDeviceId ¶
func (x *DeviceMetadataUpdatePending) GetDeviceId() string
func (*DeviceMetadataUpdatePending) GetEventMetadata ¶
func (x *DeviceMetadataUpdatePending) GetEventMetadata() *EventMetadata
func (*DeviceMetadataUpdatePending) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *DeviceMetadataUpdatePending) GetOpenTelemetryCarrier() map[string]string
func (*DeviceMetadataUpdatePending) GetShadowSynchronization ¶
func (x *DeviceMetadataUpdatePending) GetShadowSynchronization() commands.ShadowSynchronization
func (*DeviceMetadataUpdatePending) GetUpdatePending ¶
func (m *DeviceMetadataUpdatePending) GetUpdatePending() isDeviceMetadataUpdatePending_UpdatePending
func (*DeviceMetadataUpdatePending) GetValidUntil ¶
func (x *DeviceMetadataUpdatePending) GetValidUntil() int64
func (*DeviceMetadataUpdatePending) GroupID ¶
func (d *DeviceMetadataUpdatePending) GroupID() string
func (*DeviceMetadataUpdatePending) IsExpired ¶
func (d *DeviceMetadataUpdatePending) IsExpired(now time.Time) bool
func (*DeviceMetadataUpdatePending) IsSnapshot ¶
func (d *DeviceMetadataUpdatePending) IsSnapshot() bool
func (*DeviceMetadataUpdatePending) Marshal ¶
func (d *DeviceMetadataUpdatePending) Marshal() ([]byte, error)
func (*DeviceMetadataUpdatePending) ProtoMessage ¶
func (*DeviceMetadataUpdatePending) ProtoMessage()
func (*DeviceMetadataUpdatePending) ProtoReflect ¶
func (x *DeviceMetadataUpdatePending) ProtoReflect() protoreflect.Message
func (*DeviceMetadataUpdatePending) Reset ¶
func (x *DeviceMetadataUpdatePending) Reset()
func (*DeviceMetadataUpdatePending) String ¶
func (x *DeviceMetadataUpdatePending) String() string
func (*DeviceMetadataUpdatePending) Timestamp ¶
func (d *DeviceMetadataUpdatePending) Timestamp() time.Time
func (*DeviceMetadataUpdatePending) Unmarshal ¶
func (d *DeviceMetadataUpdatePending) Unmarshal(b []byte) error
func (*DeviceMetadataUpdatePending) ValidUntilTime ¶
func (d *DeviceMetadataUpdatePending) ValidUntilTime() time.Time
func (*DeviceMetadataUpdatePending) Version ¶
func (d *DeviceMetadataUpdatePending) Version() uint64
type DeviceMetadataUpdatePending_ShadowSynchronization ¶
type DeviceMetadataUpdatePending_ShadowSynchronization struct {
ShadowSynchronization commands.ShadowSynchronization `` /* 139-byte string literal not displayed */
}
type DeviceMetadataUpdated ¶
type DeviceMetadataUpdated struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` Status *commands.ConnectionStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` ShadowSynchronization commands.ShadowSynchronization `` /* 173-byte string literal not displayed */ AuditContext *commands.AuditContext `protobuf:"bytes,4,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` EventMetadata *EventMetadata `protobuf:"bytes,5,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` Canceled bool `protobuf:"varint,6,opt,name=canceled,proto3" json:"canceled,omitempty"` // it true then the command with audit_context.correlation_id was canceled. // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DeviceMetadataUpdated) AggregateID ¶
func (d *DeviceMetadataUpdated) AggregateID() string
func (*DeviceMetadataUpdated) CheckInitialized ¶
func (d *DeviceMetadataUpdated) CheckInitialized() bool
func (*DeviceMetadataUpdated) Clone ¶
func (d *DeviceMetadataUpdated) Clone() *DeviceMetadataUpdated
func (*DeviceMetadataUpdated) CopyData ¶
func (d *DeviceMetadataUpdated) CopyData(event *DeviceMetadataUpdated)
func (*DeviceMetadataUpdated) Descriptor
deprecated
func (*DeviceMetadataUpdated) Descriptor() ([]byte, []int)
Deprecated: Use DeviceMetadataUpdated.ProtoReflect.Descriptor instead.
func (*DeviceMetadataUpdated) Equal ¶
func (d *DeviceMetadataUpdated) Equal(upd *DeviceMetadataUpdated) bool
Equal checks if two DeviceMetadataUpdated events are equal.
func (*DeviceMetadataUpdated) EventType ¶
func (d *DeviceMetadataUpdated) EventType() string
func (*DeviceMetadataUpdated) GetAuditContext ¶
func (x *DeviceMetadataUpdated) GetAuditContext() *commands.AuditContext
func (*DeviceMetadataUpdated) GetCanceled ¶
func (x *DeviceMetadataUpdated) GetCanceled() bool
func (*DeviceMetadataUpdated) GetDeviceId ¶
func (x *DeviceMetadataUpdated) GetDeviceId() string
func (*DeviceMetadataUpdated) GetEventMetadata ¶
func (x *DeviceMetadataUpdated) GetEventMetadata() *EventMetadata
func (*DeviceMetadataUpdated) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *DeviceMetadataUpdated) GetOpenTelemetryCarrier() map[string]string
func (*DeviceMetadataUpdated) GetShadowSynchronization ¶
func (x *DeviceMetadataUpdated) GetShadowSynchronization() commands.ShadowSynchronization
func (*DeviceMetadataUpdated) GetStatus ¶
func (x *DeviceMetadataUpdated) GetStatus() *commands.ConnectionStatus
func (*DeviceMetadataUpdated) GroupID ¶
func (d *DeviceMetadataUpdated) GroupID() string
func (*DeviceMetadataUpdated) IsSnapshot ¶
func (d *DeviceMetadataUpdated) IsSnapshot() bool
func (*DeviceMetadataUpdated) Marshal ¶
func (d *DeviceMetadataUpdated) Marshal() ([]byte, error)
func (*DeviceMetadataUpdated) ProtoMessage ¶
func (*DeviceMetadataUpdated) ProtoMessage()
func (*DeviceMetadataUpdated) ProtoReflect ¶
func (x *DeviceMetadataUpdated) ProtoReflect() protoreflect.Message
func (*DeviceMetadataUpdated) Reset ¶
func (x *DeviceMetadataUpdated) Reset()
func (*DeviceMetadataUpdated) String ¶
func (x *DeviceMetadataUpdated) String() string
func (*DeviceMetadataUpdated) Timestamp ¶
func (d *DeviceMetadataUpdated) Timestamp() time.Time
func (*DeviceMetadataUpdated) Unmarshal ¶
func (d *DeviceMetadataUpdated) Unmarshal(b []byte) error
func (*DeviceMetadataUpdated) Version ¶
func (d *DeviceMetadataUpdated) Version() uint64
type EventMetadata ¶
type EventMetadata struct { Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` ConnectionId string `protobuf:"bytes,3,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` Sequence uint64 `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty"` // sequence number within the same connection_id; the ResourceChanged event uses the value to skip old events, other event types might not fill the value // contains filtered or unexported fields }
func MakeEventMeta ¶
func MakeEventMeta(connectionID string, sequence, version uint64) *EventMetadata
MakeEventMeta for creating EventMetadata for event.
func (*EventMetadata) Clone ¶
func (e *EventMetadata) Clone() *EventMetadata
func (*EventMetadata) Descriptor
deprecated
func (*EventMetadata) Descriptor() ([]byte, []int)
Deprecated: Use EventMetadata.ProtoReflect.Descriptor instead.
func (*EventMetadata) GetConnectionId ¶
func (x *EventMetadata) GetConnectionId() string
func (*EventMetadata) GetSequence ¶
func (x *EventMetadata) GetSequence() uint64
func (*EventMetadata) GetTimestamp ¶
func (x *EventMetadata) GetTimestamp() int64
func (*EventMetadata) GetVersion ¶
func (x *EventMetadata) GetVersion() uint64
func (*EventMetadata) ProtoMessage ¶
func (*EventMetadata) ProtoMessage()
func (*EventMetadata) ProtoReflect ¶
func (x *EventMetadata) ProtoReflect() protoreflect.Message
func (*EventMetadata) Reset ¶
func (x *EventMetadata) Reset()
func (*EventMetadata) String ¶
func (x *EventMetadata) String() string
type ResourceChanged ¶
type ResourceChanged struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` Content *commands.Content `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` Status commands.Status `protobuf:"varint,3,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"` AuditContext *commands.AuditContext `protobuf:"bytes,4,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` EventMetadata *EventMetadata `protobuf:"bytes,5,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ResourceChanged) AggregateID ¶
func (rc *ResourceChanged) AggregateID() string
func (*ResourceChanged) CheckInitialized ¶
func (rc *ResourceChanged) CheckInitialized() bool
func (*ResourceChanged) CopyData ¶
func (rc *ResourceChanged) CopyData(event *ResourceChanged)
func (*ResourceChanged) Descriptor
deprecated
func (*ResourceChanged) Descriptor() ([]byte, []int)
Deprecated: Use ResourceChanged.ProtoReflect.Descriptor instead.
func (*ResourceChanged) Equal ¶
func (rc *ResourceChanged) Equal(changed *ResourceChanged) bool
func (*ResourceChanged) EventType ¶
func (rc *ResourceChanged) EventType() string
func (*ResourceChanged) GetAuditContext ¶
func (x *ResourceChanged) GetAuditContext() *commands.AuditContext
func (*ResourceChanged) GetContent ¶
func (x *ResourceChanged) GetContent() *commands.Content
func (*ResourceChanged) GetEventMetadata ¶
func (x *ResourceChanged) GetEventMetadata() *EventMetadata
func (*ResourceChanged) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *ResourceChanged) GetOpenTelemetryCarrier() map[string]string
func (*ResourceChanged) GetResourceId ¶
func (x *ResourceChanged) GetResourceId() *commands.ResourceId
func (*ResourceChanged) GetStatus ¶
func (x *ResourceChanged) GetStatus() commands.Status
func (*ResourceChanged) GroupID ¶
func (rc *ResourceChanged) GroupID() string
func (*ResourceChanged) IsSnapshot ¶
func (rc *ResourceChanged) IsSnapshot() bool
func (*ResourceChanged) Marshal ¶
func (rc *ResourceChanged) Marshal() ([]byte, error)
func (*ResourceChanged) ProtoMessage ¶
func (*ResourceChanged) ProtoMessage()
func (*ResourceChanged) ProtoReflect ¶
func (x *ResourceChanged) ProtoReflect() protoreflect.Message
func (*ResourceChanged) Reset ¶
func (x *ResourceChanged) Reset()
func (*ResourceChanged) String ¶
func (x *ResourceChanged) String() string
func (*ResourceChanged) Timestamp ¶
func (rc *ResourceChanged) Timestamp() time.Time
func (*ResourceChanged) Unmarshal ¶
func (rc *ResourceChanged) Unmarshal(b []byte) error
func (*ResourceChanged) Version ¶
func (rc *ResourceChanged) Version() uint64
type ResourceCreatePending ¶
type ResourceCreatePending struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` Content *commands.Content `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` AuditContext *commands.AuditContext `protobuf:"bytes,3,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` EventMetadata *EventMetadata `protobuf:"bytes,4,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` ValidUntil int64 `protobuf:"varint,5,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when pending event is considered as expired. 0 means forever. // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ResourceCreatePending) AggregateID ¶
func (e *ResourceCreatePending) AggregateID() string
func (*ResourceCreatePending) CheckInitialized ¶
func (e *ResourceCreatePending) CheckInitialized() bool
func (*ResourceCreatePending) CopyData ¶
func (e *ResourceCreatePending) CopyData(event *ResourceCreatePending)
func (*ResourceCreatePending) Descriptor
deprecated
func (*ResourceCreatePending) Descriptor() ([]byte, []int)
Deprecated: Use ResourceCreatePending.ProtoReflect.Descriptor instead.
func (*ResourceCreatePending) EventType ¶
func (e *ResourceCreatePending) EventType() string
func (*ResourceCreatePending) GetAuditContext ¶
func (x *ResourceCreatePending) GetAuditContext() *commands.AuditContext
func (*ResourceCreatePending) GetContent ¶
func (x *ResourceCreatePending) GetContent() *commands.Content
func (*ResourceCreatePending) GetEventMetadata ¶
func (x *ResourceCreatePending) GetEventMetadata() *EventMetadata
func (*ResourceCreatePending) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *ResourceCreatePending) GetOpenTelemetryCarrier() map[string]string
func (*ResourceCreatePending) GetResourceId ¶
func (x *ResourceCreatePending) GetResourceId() *commands.ResourceId
func (*ResourceCreatePending) GetValidUntil ¶
func (x *ResourceCreatePending) GetValidUntil() int64
func (*ResourceCreatePending) GroupID ¶
func (e *ResourceCreatePending) GroupID() string
func (*ResourceCreatePending) IsExpired ¶
func (e *ResourceCreatePending) IsExpired(now time.Time) bool
func (*ResourceCreatePending) IsSnapshot ¶
func (e *ResourceCreatePending) IsSnapshot() bool
func (*ResourceCreatePending) Marshal ¶
func (e *ResourceCreatePending) Marshal() ([]byte, error)
func (*ResourceCreatePending) ProtoMessage ¶
func (*ResourceCreatePending) ProtoMessage()
func (*ResourceCreatePending) ProtoReflect ¶
func (x *ResourceCreatePending) ProtoReflect() protoreflect.Message
func (*ResourceCreatePending) Reset ¶
func (x *ResourceCreatePending) Reset()
func (*ResourceCreatePending) String ¶
func (x *ResourceCreatePending) String() string
func (*ResourceCreatePending) Timestamp ¶
func (e *ResourceCreatePending) Timestamp() time.Time
func (*ResourceCreatePending) Unmarshal ¶
func (e *ResourceCreatePending) Unmarshal(b []byte) error
func (*ResourceCreatePending) ValidUntilTime ¶
func (e *ResourceCreatePending) ValidUntilTime() time.Time
func (*ResourceCreatePending) Version ¶
func (e *ResourceCreatePending) Version() uint64
type ResourceCreated ¶
type ResourceCreated struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` Status commands.Status `protobuf:"varint,2,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"` Content *commands.Content `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"` AuditContext *commands.AuditContext `protobuf:"bytes,4,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` EventMetadata *EventMetadata `protobuf:"bytes,5,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ResourceCreated) AggregateID ¶
func (e *ResourceCreated) AggregateID() string
func (*ResourceCreated) CheckInitialized ¶
func (e *ResourceCreated) CheckInitialized() bool
func (*ResourceCreated) CopyData ¶
func (e *ResourceCreated) CopyData(event *ResourceCreated)
func (*ResourceCreated) Descriptor
deprecated
func (*ResourceCreated) Descriptor() ([]byte, []int)
Deprecated: Use ResourceCreated.ProtoReflect.Descriptor instead.
func (*ResourceCreated) EventType ¶
func (e *ResourceCreated) EventType() string
func (*ResourceCreated) GetAuditContext ¶
func (x *ResourceCreated) GetAuditContext() *commands.AuditContext
func (*ResourceCreated) GetContent ¶
func (x *ResourceCreated) GetContent() *commands.Content
func (*ResourceCreated) GetEventMetadata ¶
func (x *ResourceCreated) GetEventMetadata() *EventMetadata
func (*ResourceCreated) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *ResourceCreated) GetOpenTelemetryCarrier() map[string]string
func (*ResourceCreated) GetResourceId ¶
func (x *ResourceCreated) GetResourceId() *commands.ResourceId
func (*ResourceCreated) GetStatus ¶
func (x *ResourceCreated) GetStatus() commands.Status
func (*ResourceCreated) GroupID ¶
func (e *ResourceCreated) GroupID() string
func (*ResourceCreated) IsSnapshot ¶
func (e *ResourceCreated) IsSnapshot() bool
func (*ResourceCreated) Marshal ¶
func (e *ResourceCreated) Marshal() ([]byte, error)
func (*ResourceCreated) ProtoMessage ¶
func (*ResourceCreated) ProtoMessage()
func (*ResourceCreated) ProtoReflect ¶
func (x *ResourceCreated) ProtoReflect() protoreflect.Message
func (*ResourceCreated) Reset ¶
func (x *ResourceCreated) Reset()
func (*ResourceCreated) String ¶
func (x *ResourceCreated) String() string
func (*ResourceCreated) Timestamp ¶
func (e *ResourceCreated) Timestamp() time.Time
func (*ResourceCreated) Unmarshal ¶
func (e *ResourceCreated) Unmarshal(b []byte) error
func (*ResourceCreated) Version ¶
func (e *ResourceCreated) Version() uint64
type ResourceDeletePending ¶
type ResourceDeletePending struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` AuditContext *commands.AuditContext `protobuf:"bytes,2,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` EventMetadata *EventMetadata `protobuf:"bytes,3,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` ValidUntil int64 `protobuf:"varint,4,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when pending event is considered as expired. 0 means forever. // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ResourceDeletePending) AggregateID ¶
func (e *ResourceDeletePending) AggregateID() string
func (*ResourceDeletePending) CheckInitialized ¶
func (e *ResourceDeletePending) CheckInitialized() bool
func (*ResourceDeletePending) CopyData ¶
func (e *ResourceDeletePending) CopyData(event *ResourceDeletePending)
func (*ResourceDeletePending) Descriptor
deprecated
func (*ResourceDeletePending) Descriptor() ([]byte, []int)
Deprecated: Use ResourceDeletePending.ProtoReflect.Descriptor instead.
func (*ResourceDeletePending) EventType ¶
func (e *ResourceDeletePending) EventType() string
func (*ResourceDeletePending) GetAuditContext ¶
func (x *ResourceDeletePending) GetAuditContext() *commands.AuditContext
func (*ResourceDeletePending) GetEventMetadata ¶
func (x *ResourceDeletePending) GetEventMetadata() *EventMetadata
func (*ResourceDeletePending) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *ResourceDeletePending) GetOpenTelemetryCarrier() map[string]string
func (*ResourceDeletePending) GetResourceId ¶
func (x *ResourceDeletePending) GetResourceId() *commands.ResourceId
func (*ResourceDeletePending) GetValidUntil ¶
func (x *ResourceDeletePending) GetValidUntil() int64
func (*ResourceDeletePending) GroupID ¶
func (e *ResourceDeletePending) GroupID() string
func (*ResourceDeletePending) IsExpired ¶
func (e *ResourceDeletePending) IsExpired(now time.Time) bool
func (*ResourceDeletePending) IsSnapshot ¶
func (e *ResourceDeletePending) IsSnapshot() bool
func (*ResourceDeletePending) Marshal ¶
func (e *ResourceDeletePending) Marshal() ([]byte, error)
func (*ResourceDeletePending) ProtoMessage ¶
func (*ResourceDeletePending) ProtoMessage()
func (*ResourceDeletePending) ProtoReflect ¶
func (x *ResourceDeletePending) ProtoReflect() protoreflect.Message
func (*ResourceDeletePending) Reset ¶
func (x *ResourceDeletePending) Reset()
func (*ResourceDeletePending) String ¶
func (x *ResourceDeletePending) String() string
func (*ResourceDeletePending) Timestamp ¶
func (e *ResourceDeletePending) Timestamp() time.Time
func (*ResourceDeletePending) Unmarshal ¶
func (e *ResourceDeletePending) Unmarshal(b []byte) error
func (*ResourceDeletePending) ValidUntilTime ¶
func (e *ResourceDeletePending) ValidUntilTime() time.Time
func (*ResourceDeletePending) Version ¶
func (e *ResourceDeletePending) Version() uint64
type ResourceDeleted ¶
type ResourceDeleted struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` Status commands.Status `protobuf:"varint,2,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"` Content *commands.Content `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"` AuditContext *commands.AuditContext `protobuf:"bytes,4,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` EventMetadata *EventMetadata `protobuf:"bytes,5,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ResourceDeleted) AggregateID ¶
func (e *ResourceDeleted) AggregateID() string
func (*ResourceDeleted) CheckInitialized ¶
func (e *ResourceDeleted) CheckInitialized() bool
func (*ResourceDeleted) CopyData ¶
func (e *ResourceDeleted) CopyData(event *ResourceDeleted)
func (*ResourceDeleted) Descriptor
deprecated
func (*ResourceDeleted) Descriptor() ([]byte, []int)
Deprecated: Use ResourceDeleted.ProtoReflect.Descriptor instead.
func (*ResourceDeleted) EventType ¶
func (e *ResourceDeleted) EventType() string
func (*ResourceDeleted) GetAuditContext ¶
func (x *ResourceDeleted) GetAuditContext() *commands.AuditContext
func (*ResourceDeleted) GetContent ¶
func (x *ResourceDeleted) GetContent() *commands.Content
func (*ResourceDeleted) GetEventMetadata ¶
func (x *ResourceDeleted) GetEventMetadata() *EventMetadata
func (*ResourceDeleted) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *ResourceDeleted) GetOpenTelemetryCarrier() map[string]string
func (*ResourceDeleted) GetResourceId ¶
func (x *ResourceDeleted) GetResourceId() *commands.ResourceId
func (*ResourceDeleted) GetStatus ¶
func (x *ResourceDeleted) GetStatus() commands.Status
func (*ResourceDeleted) GroupID ¶
func (e *ResourceDeleted) GroupID() string
func (*ResourceDeleted) IsSnapshot ¶
func (e *ResourceDeleted) IsSnapshot() bool
func (*ResourceDeleted) Marshal ¶
func (e *ResourceDeleted) Marshal() ([]byte, error)
func (*ResourceDeleted) ProtoMessage ¶
func (*ResourceDeleted) ProtoMessage()
func (*ResourceDeleted) ProtoReflect ¶
func (x *ResourceDeleted) ProtoReflect() protoreflect.Message
func (*ResourceDeleted) Reset ¶
func (x *ResourceDeleted) Reset()
func (*ResourceDeleted) String ¶
func (x *ResourceDeleted) String() string
func (*ResourceDeleted) Timestamp ¶
func (e *ResourceDeleted) Timestamp() time.Time
func (*ResourceDeleted) Unmarshal ¶
func (e *ResourceDeleted) Unmarshal(b []byte) error
func (*ResourceDeleted) Version ¶
func (e *ResourceDeleted) Version() uint64
type ResourceLinksPublished ¶
type ResourceLinksPublished struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` Resources []*commands.Resource `protobuf:"bytes,2,rep,name=resources,proto3" json:"resources,omitempty"` AuditContext *commands.AuditContext `protobuf:"bytes,3,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` EventMetadata *EventMetadata `protobuf:"bytes,4,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ResourceLinksPublished) AggregateID ¶
func (e *ResourceLinksPublished) AggregateID() string
func (*ResourceLinksPublished) CheckInitialized ¶
func (e *ResourceLinksPublished) CheckInitialized() bool
func (*ResourceLinksPublished) CopyData ¶
func (e *ResourceLinksPublished) CopyData(event *ResourceLinksPublished)
func (*ResourceLinksPublished) Descriptor
deprecated
func (*ResourceLinksPublished) Descriptor() ([]byte, []int)
Deprecated: Use ResourceLinksPublished.ProtoReflect.Descriptor instead.
func (*ResourceLinksPublished) EventType ¶
func (e *ResourceLinksPublished) EventType() string
func (*ResourceLinksPublished) GetAuditContext ¶
func (x *ResourceLinksPublished) GetAuditContext() *commands.AuditContext
func (*ResourceLinksPublished) GetDeviceId ¶
func (x *ResourceLinksPublished) GetDeviceId() string
func (*ResourceLinksPublished) GetEventMetadata ¶
func (x *ResourceLinksPublished) GetEventMetadata() *EventMetadata
func (*ResourceLinksPublished) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *ResourceLinksPublished) GetOpenTelemetryCarrier() map[string]string
func (*ResourceLinksPublished) GetResources ¶
func (x *ResourceLinksPublished) GetResources() []*commands.Resource
func (*ResourceLinksPublished) GroupID ¶
func (e *ResourceLinksPublished) GroupID() string
func (*ResourceLinksPublished) IsSnapshot ¶
func (e *ResourceLinksPublished) IsSnapshot() bool
func (*ResourceLinksPublished) Marshal ¶
func (e *ResourceLinksPublished) Marshal() ([]byte, error)
func (*ResourceLinksPublished) ProtoMessage ¶
func (*ResourceLinksPublished) ProtoMessage()
func (*ResourceLinksPublished) ProtoReflect ¶
func (x *ResourceLinksPublished) ProtoReflect() protoreflect.Message
func (*ResourceLinksPublished) Reset ¶
func (x *ResourceLinksPublished) Reset()
func (*ResourceLinksPublished) String ¶
func (x *ResourceLinksPublished) String() string
func (*ResourceLinksPublished) Timestamp ¶
func (e *ResourceLinksPublished) Timestamp() time.Time
func (*ResourceLinksPublished) Unmarshal ¶
func (e *ResourceLinksPublished) Unmarshal(b []byte) error
func (*ResourceLinksPublished) Version ¶
func (e *ResourceLinksPublished) Version() uint64
type ResourceLinksSnapshotTaken ¶
type ResourceLinksSnapshotTaken struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` Resources map[string]*commands.Resource `` /* 159-byte string literal not displayed */ EventMetadata *EventMetadata `protobuf:"bytes,3,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` AuditContext *commands.AuditContext `protobuf:"bytes,4,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // contains filtered or unexported fields }
func NewResourceLinksSnapshotTaken ¶
func NewResourceLinksSnapshotTaken() *ResourceLinksSnapshotTaken
func (*ResourceLinksSnapshotTaken) AggregateID ¶
func (e *ResourceLinksSnapshotTaken) AggregateID() string
func (*ResourceLinksSnapshotTaken) CheckInitialized ¶
func (e *ResourceLinksSnapshotTaken) CheckInitialized() bool
func (*ResourceLinksSnapshotTaken) CloneData ¶
func (e *ResourceLinksSnapshotTaken) CloneData(event *ResourceLinksSnapshotTaken)
func (*ResourceLinksSnapshotTaken) CopyData ¶
func (e *ResourceLinksSnapshotTaken) CopyData(event *ResourceLinksSnapshotTaken)
func (*ResourceLinksSnapshotTaken) Descriptor
deprecated
func (*ResourceLinksSnapshotTaken) Descriptor() ([]byte, []int)
Deprecated: Use ResourceLinksSnapshotTaken.ProtoReflect.Descriptor instead.
func (*ResourceLinksSnapshotTaken) EventType ¶
func (e *ResourceLinksSnapshotTaken) EventType() string
func (*ResourceLinksSnapshotTaken) GetAuditContext ¶
func (x *ResourceLinksSnapshotTaken) GetAuditContext() *commands.AuditContext
func (*ResourceLinksSnapshotTaken) GetDeviceId ¶
func (x *ResourceLinksSnapshotTaken) GetDeviceId() string
func (*ResourceLinksSnapshotTaken) GetEventMetadata ¶
func (x *ResourceLinksSnapshotTaken) GetEventMetadata() *EventMetadata
func (*ResourceLinksSnapshotTaken) GetNewPublishedLinks ¶
func (e *ResourceLinksSnapshotTaken) GetNewPublishedLinks(pub *ResourceLinksPublished) []*commands.Resource
Examine published resources by the ResourceLinksPublished, compare it with cached resources and return array of new or changed resources.
func (*ResourceLinksSnapshotTaken) GetResources ¶
func (x *ResourceLinksSnapshotTaken) GetResources() map[string]*commands.Resource
func (*ResourceLinksSnapshotTaken) GroupID ¶
func (e *ResourceLinksSnapshotTaken) GroupID() string
func (*ResourceLinksSnapshotTaken) Handle ¶
func (e *ResourceLinksSnapshotTaken) Handle(ctx context.Context, iter eventstore.Iter) error
func (*ResourceLinksSnapshotTaken) HandleCommand ¶
func (e *ResourceLinksSnapshotTaken) HandleCommand(ctx context.Context, cmd aggregate.Command, newVersion uint64) ([]eventstore.Event, error)
func (*ResourceLinksSnapshotTaken) HandleEventResourceLinksPublished ¶
func (e *ResourceLinksSnapshotTaken) HandleEventResourceLinksPublished(pub *ResourceLinksPublished) []*commands.Resource
func (*ResourceLinksSnapshotTaken) HandleEventResourceLinksSnapshotTaken ¶
func (e *ResourceLinksSnapshotTaken) HandleEventResourceLinksSnapshotTaken(s *ResourceLinksSnapshotTaken)
func (*ResourceLinksSnapshotTaken) HandleEventResourceLinksUnpublished ¶
func (e *ResourceLinksSnapshotTaken) HandleEventResourceLinksUnpublished(instanceIDs []int64, upub *ResourceLinksUnpublished) []string
func (*ResourceLinksSnapshotTaken) IsSnapshot ¶
func (e *ResourceLinksSnapshotTaken) IsSnapshot() bool
func (*ResourceLinksSnapshotTaken) Marshal ¶
func (e *ResourceLinksSnapshotTaken) Marshal() ([]byte, error)
func (*ResourceLinksSnapshotTaken) ProtoMessage ¶
func (*ResourceLinksSnapshotTaken) ProtoMessage()
func (*ResourceLinksSnapshotTaken) ProtoReflect ¶
func (x *ResourceLinksSnapshotTaken) ProtoReflect() protoreflect.Message
func (*ResourceLinksSnapshotTaken) Reset ¶
func (x *ResourceLinksSnapshotTaken) Reset()
func (*ResourceLinksSnapshotTaken) String ¶
func (x *ResourceLinksSnapshotTaken) String() string
func (*ResourceLinksSnapshotTaken) TakeSnapshot ¶
func (e *ResourceLinksSnapshotTaken) TakeSnapshot(version uint64) (eventstore.Event, bool)
func (*ResourceLinksSnapshotTaken) Timestamp ¶
func (e *ResourceLinksSnapshotTaken) Timestamp() time.Time
func (*ResourceLinksSnapshotTaken) ToResourceLinksPublished ¶
func (e *ResourceLinksSnapshotTaken) ToResourceLinksPublished() *ResourceLinksPublished
func (*ResourceLinksSnapshotTaken) Unmarshal ¶
func (e *ResourceLinksSnapshotTaken) Unmarshal(b []byte) error
func (*ResourceLinksSnapshotTaken) Version ¶
func (e *ResourceLinksSnapshotTaken) Version() uint64
type ResourceLinksUnpublished ¶
type ResourceLinksUnpublished struct { DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` Hrefs []string `protobuf:"bytes,2,rep,name=hrefs,proto3" json:"hrefs,omitempty"` AuditContext *commands.AuditContext `protobuf:"bytes,3,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` EventMetadata *EventMetadata `protobuf:"bytes,4,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
https://github.com/openconnectivityfoundation/cloud-services/blob/master/swagger2.0/oic.wk.rd.swagger.json #Specification CR needed
func (*ResourceLinksUnpublished) AggregateID ¶
func (e *ResourceLinksUnpublished) AggregateID() string
func (*ResourceLinksUnpublished) CheckInitialized ¶
func (e *ResourceLinksUnpublished) CheckInitialized() bool
func (*ResourceLinksUnpublished) CopyData ¶
func (e *ResourceLinksUnpublished) CopyData(event *ResourceLinksUnpublished)
func (*ResourceLinksUnpublished) Descriptor
deprecated
func (*ResourceLinksUnpublished) Descriptor() ([]byte, []int)
Deprecated: Use ResourceLinksUnpublished.ProtoReflect.Descriptor instead.
func (*ResourceLinksUnpublished) EventType ¶
func (e *ResourceLinksUnpublished) EventType() string
func (*ResourceLinksUnpublished) GetAuditContext ¶
func (x *ResourceLinksUnpublished) GetAuditContext() *commands.AuditContext
func (*ResourceLinksUnpublished) GetDeviceId ¶
func (x *ResourceLinksUnpublished) GetDeviceId() string
func (*ResourceLinksUnpublished) GetEventMetadata ¶
func (x *ResourceLinksUnpublished) GetEventMetadata() *EventMetadata
func (*ResourceLinksUnpublished) GetHrefs ¶
func (x *ResourceLinksUnpublished) GetHrefs() []string
func (*ResourceLinksUnpublished) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *ResourceLinksUnpublished) GetOpenTelemetryCarrier() map[string]string
func (*ResourceLinksUnpublished) GroupID ¶
func (e *ResourceLinksUnpublished) GroupID() string
func (*ResourceLinksUnpublished) IsSnapshot ¶
func (e *ResourceLinksUnpublished) IsSnapshot() bool
func (*ResourceLinksUnpublished) Marshal ¶
func (e *ResourceLinksUnpublished) Marshal() ([]byte, error)
func (*ResourceLinksUnpublished) ProtoMessage ¶
func (*ResourceLinksUnpublished) ProtoMessage()
func (*ResourceLinksUnpublished) ProtoReflect ¶
func (x *ResourceLinksUnpublished) ProtoReflect() protoreflect.Message
func (*ResourceLinksUnpublished) Reset ¶
func (x *ResourceLinksUnpublished) Reset()
func (*ResourceLinksUnpublished) String ¶
func (x *ResourceLinksUnpublished) String() string
func (*ResourceLinksUnpublished) Timestamp ¶
func (e *ResourceLinksUnpublished) Timestamp() time.Time
func (*ResourceLinksUnpublished) Unmarshal ¶
func (e *ResourceLinksUnpublished) Unmarshal(b []byte) error
func (*ResourceLinksUnpublished) Version ¶
func (e *ResourceLinksUnpublished) Version() uint64
type ResourceRetrievePending ¶
type ResourceRetrievePending struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` ResourceInterface string `protobuf:"bytes,2,opt,name=resource_interface,json=resourceInterface,proto3" json:"resource_interface,omitempty"` AuditContext *commands.AuditContext `protobuf:"bytes,3,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` EventMetadata *EventMetadata `protobuf:"bytes,4,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` ValidUntil int64 `protobuf:"varint,5,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when pending event is considered as expired. 0 means forever. // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ResourceRetrievePending) AggregateID ¶
func (e *ResourceRetrievePending) AggregateID() string
func (*ResourceRetrievePending) CheckInitialized ¶
func (e *ResourceRetrievePending) CheckInitialized() bool
func (*ResourceRetrievePending) CopyData ¶
func (e *ResourceRetrievePending) CopyData(event *ResourceRetrievePending)
func (*ResourceRetrievePending) Descriptor
deprecated
func (*ResourceRetrievePending) Descriptor() ([]byte, []int)
Deprecated: Use ResourceRetrievePending.ProtoReflect.Descriptor instead.
func (*ResourceRetrievePending) EventType ¶
func (e *ResourceRetrievePending) EventType() string
func (*ResourceRetrievePending) GetAuditContext ¶
func (x *ResourceRetrievePending) GetAuditContext() *commands.AuditContext
func (*ResourceRetrievePending) GetEventMetadata ¶
func (x *ResourceRetrievePending) GetEventMetadata() *EventMetadata
func (*ResourceRetrievePending) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *ResourceRetrievePending) GetOpenTelemetryCarrier() map[string]string
func (*ResourceRetrievePending) GetResourceId ¶
func (x *ResourceRetrievePending) GetResourceId() *commands.ResourceId
func (*ResourceRetrievePending) GetResourceInterface ¶
func (x *ResourceRetrievePending) GetResourceInterface() string
func (*ResourceRetrievePending) GetValidUntil ¶
func (x *ResourceRetrievePending) GetValidUntil() int64
func (*ResourceRetrievePending) GroupID ¶
func (e *ResourceRetrievePending) GroupID() string
func (*ResourceRetrievePending) IsExpired ¶
func (e *ResourceRetrievePending) IsExpired(now time.Time) bool
func (*ResourceRetrievePending) IsSnapshot ¶
func (e *ResourceRetrievePending) IsSnapshot() bool
func (*ResourceRetrievePending) Marshal ¶
func (e *ResourceRetrievePending) Marshal() ([]byte, error)
func (*ResourceRetrievePending) ProtoMessage ¶
func (*ResourceRetrievePending) ProtoMessage()
func (*ResourceRetrievePending) ProtoReflect ¶
func (x *ResourceRetrievePending) ProtoReflect() protoreflect.Message
func (*ResourceRetrievePending) Reset ¶
func (x *ResourceRetrievePending) Reset()
func (*ResourceRetrievePending) String ¶
func (x *ResourceRetrievePending) String() string
func (*ResourceRetrievePending) Timestamp ¶
func (e *ResourceRetrievePending) Timestamp() time.Time
func (*ResourceRetrievePending) Unmarshal ¶
func (e *ResourceRetrievePending) Unmarshal(b []byte) error
func (*ResourceRetrievePending) ValidUntilTime ¶
func (e *ResourceRetrievePending) ValidUntilTime() time.Time
func (*ResourceRetrievePending) Version ¶
func (e *ResourceRetrievePending) Version() uint64
type ResourceRetrieved ¶
type ResourceRetrieved struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` Status commands.Status `protobuf:"varint,2,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"` Content *commands.Content `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"` AuditContext *commands.AuditContext `protobuf:"bytes,4,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` EventMetadata *EventMetadata `protobuf:"bytes,5,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ResourceRetrieved) AggregateID ¶
func (e *ResourceRetrieved) AggregateID() string
func (*ResourceRetrieved) CheckInitialized ¶
func (e *ResourceRetrieved) CheckInitialized() bool
func (*ResourceRetrieved) CopyData ¶
func (e *ResourceRetrieved) CopyData(event *ResourceRetrieved)
func (*ResourceRetrieved) Descriptor
deprecated
func (*ResourceRetrieved) Descriptor() ([]byte, []int)
Deprecated: Use ResourceRetrieved.ProtoReflect.Descriptor instead.
func (*ResourceRetrieved) EventType ¶
func (e *ResourceRetrieved) EventType() string
func (*ResourceRetrieved) GetAuditContext ¶
func (x *ResourceRetrieved) GetAuditContext() *commands.AuditContext
func (*ResourceRetrieved) GetContent ¶
func (x *ResourceRetrieved) GetContent() *commands.Content
func (*ResourceRetrieved) GetEventMetadata ¶
func (x *ResourceRetrieved) GetEventMetadata() *EventMetadata
func (*ResourceRetrieved) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *ResourceRetrieved) GetOpenTelemetryCarrier() map[string]string
func (*ResourceRetrieved) GetResourceId ¶
func (x *ResourceRetrieved) GetResourceId() *commands.ResourceId
func (*ResourceRetrieved) GetStatus ¶
func (x *ResourceRetrieved) GetStatus() commands.Status
func (*ResourceRetrieved) GroupID ¶
func (e *ResourceRetrieved) GroupID() string
func (*ResourceRetrieved) IsSnapshot ¶
func (e *ResourceRetrieved) IsSnapshot() bool
func (*ResourceRetrieved) Marshal ¶
func (e *ResourceRetrieved) Marshal() ([]byte, error)
func (*ResourceRetrieved) ProtoMessage ¶
func (*ResourceRetrieved) ProtoMessage()
func (*ResourceRetrieved) ProtoReflect ¶
func (x *ResourceRetrieved) ProtoReflect() protoreflect.Message
func (*ResourceRetrieved) Reset ¶
func (x *ResourceRetrieved) Reset()
func (*ResourceRetrieved) String ¶
func (x *ResourceRetrieved) String() string
func (*ResourceRetrieved) Timestamp ¶
func (e *ResourceRetrieved) Timestamp() time.Time
func (*ResourceRetrieved) Unmarshal ¶
func (e *ResourceRetrieved) Unmarshal(b []byte) error
func (*ResourceRetrieved) Version ¶
func (e *ResourceRetrieved) Version() uint64
type ResourceStateSnapshotTaken ¶
type ResourceStateSnapshotTaken struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` LatestResourceChange *ResourceChanged `protobuf:"bytes,2,opt,name=latest_resource_change,json=latestResourceChange,proto3" json:"latest_resource_change,omitempty"` ResourceCreatePendings []*ResourceCreatePending `` // expired events will be removed by creating a new snapshot. /* 129-byte string literal not displayed */ ResourceRetrievePendings []*ResourceRetrievePending `` // expired events will be removed by creating a new snapshot. /* 135-byte string literal not displayed */ ResourceUpdatePendings []*ResourceUpdatePending `` // expired events will be removed by creating a new snapshot. /* 129-byte string literal not displayed */ ResourceDeletePendings []*ResourceDeletePending `` // expired events will be removed by creating a new snapshot. /* 129-byte string literal not displayed */ AuditContext *commands.AuditContext `protobuf:"bytes,7,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` EventMetadata *EventMetadata `protobuf:"bytes,8,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` // contains filtered or unexported fields }
func NewResourceStateSnapshotTaken ¶
func NewResourceStateSnapshotTaken() *ResourceStateSnapshotTaken
func (*ResourceStateSnapshotTaken) AggregateID ¶
func (e *ResourceStateSnapshotTaken) AggregateID() string
func (*ResourceStateSnapshotTaken) CancelPendingCommands ¶
func (e *ResourceStateSnapshotTaken) CancelPendingCommands(ctx context.Context, userID string, req *commands.CancelPendingCommandsRequest, newVersion uint64) ([]eventstore.Event, error)
func (*ResourceStateSnapshotTaken) CheckInitialized ¶
func (e *ResourceStateSnapshotTaken) CheckInitialized() bool
func (*ResourceStateSnapshotTaken) ConfirmResourceCreateCommand ¶
func (e *ResourceStateSnapshotTaken) ConfirmResourceCreateCommand(ctx context.Context, userID string, req *commands.ConfirmResourceCreateRequest, newVersion uint64) ([]eventstore.Event, error)
func (*ResourceStateSnapshotTaken) ConfirmResourceDeleteCommand ¶
func (e *ResourceStateSnapshotTaken) ConfirmResourceDeleteCommand(ctx context.Context, userID string, req *commands.ConfirmResourceDeleteRequest, newVersion uint64) ([]eventstore.Event, error)
func (*ResourceStateSnapshotTaken) ConfirmResourceRetrieveCommand ¶
func (e *ResourceStateSnapshotTaken) ConfirmResourceRetrieveCommand(ctx context.Context, userID string, req *commands.ConfirmResourceRetrieveRequest, newVersion uint64) ([]eventstore.Event, error)
func (*ResourceStateSnapshotTaken) ConfirmResourceUpdateCommand ¶
func (e *ResourceStateSnapshotTaken) ConfirmResourceUpdateCommand(ctx context.Context, userID string, req *commands.ConfirmResourceUpdateRequest, newVersion uint64) ([]eventstore.Event, error)
func (*ResourceStateSnapshotTaken) CopyData ¶
func (e *ResourceStateSnapshotTaken) CopyData(event *ResourceStateSnapshotTaken)
func (*ResourceStateSnapshotTaken) Descriptor
deprecated
func (*ResourceStateSnapshotTaken) Descriptor() ([]byte, []int)
Deprecated: Use ResourceStateSnapshotTaken.ProtoReflect.Descriptor instead.
func (*ResourceStateSnapshotTaken) EventType ¶
func (e *ResourceStateSnapshotTaken) EventType() string
func (*ResourceStateSnapshotTaken) GetAuditContext ¶
func (x *ResourceStateSnapshotTaken) GetAuditContext() *commands.AuditContext
func (*ResourceStateSnapshotTaken) GetEventMetadata ¶
func (x *ResourceStateSnapshotTaken) GetEventMetadata() *EventMetadata
func (*ResourceStateSnapshotTaken) GetLatestResourceChange ¶
func (x *ResourceStateSnapshotTaken) GetLatestResourceChange() *ResourceChanged
func (*ResourceStateSnapshotTaken) GetResourceCreatePendings ¶
func (x *ResourceStateSnapshotTaken) GetResourceCreatePendings() []*ResourceCreatePending
func (*ResourceStateSnapshotTaken) GetResourceDeletePendings ¶
func (x *ResourceStateSnapshotTaken) GetResourceDeletePendings() []*ResourceDeletePending
func (*ResourceStateSnapshotTaken) GetResourceId ¶
func (x *ResourceStateSnapshotTaken) GetResourceId() *commands.ResourceId
func (*ResourceStateSnapshotTaken) GetResourceRetrievePendings ¶
func (x *ResourceStateSnapshotTaken) GetResourceRetrievePendings() []*ResourceRetrievePending
func (*ResourceStateSnapshotTaken) GetResourceUpdatePendings ¶
func (x *ResourceStateSnapshotTaken) GetResourceUpdatePendings() []*ResourceUpdatePending
func (*ResourceStateSnapshotTaken) GroupID ¶
func (e *ResourceStateSnapshotTaken) GroupID() string
func (*ResourceStateSnapshotTaken) Handle ¶
func (e *ResourceStateSnapshotTaken) Handle(ctx context.Context, iter eventstore.Iter) error
func (*ResourceStateSnapshotTaken) HandleCommand ¶
func (e *ResourceStateSnapshotTaken) HandleCommand(ctx context.Context, cmd aggregate.Command, newVersion uint64) ([]eventstore.Event, error)
func (*ResourceStateSnapshotTaken) HandleEventResourceChanged ¶
func (e *ResourceStateSnapshotTaken) HandleEventResourceChanged(ctx context.Context, changed *ResourceChanged) (bool, error)
func (*ResourceStateSnapshotTaken) HandleEventResourceCreatePending ¶
func (e *ResourceStateSnapshotTaken) HandleEventResourceCreatePending(ctx context.Context, createPending *ResourceCreatePending) error
func (*ResourceStateSnapshotTaken) HandleEventResourceCreated ¶
func (e *ResourceStateSnapshotTaken) HandleEventResourceCreated(ctx context.Context, created *ResourceCreated) error
func (*ResourceStateSnapshotTaken) HandleEventResourceDeletePending ¶
func (e *ResourceStateSnapshotTaken) HandleEventResourceDeletePending(ctx context.Context, deletePending *ResourceDeletePending) error
func (*ResourceStateSnapshotTaken) HandleEventResourceDeleted ¶
func (e *ResourceStateSnapshotTaken) HandleEventResourceDeleted(ctx context.Context, deleted *ResourceDeleted) error
func (*ResourceStateSnapshotTaken) HandleEventResourceRetrievePending ¶
func (e *ResourceStateSnapshotTaken) HandleEventResourceRetrievePending(ctx context.Context, retrievePending *ResourceRetrievePending) error
func (*ResourceStateSnapshotTaken) HandleEventResourceRetrieved ¶
func (e *ResourceStateSnapshotTaken) HandleEventResourceRetrieved(ctx context.Context, retrieved *ResourceRetrieved) error
func (*ResourceStateSnapshotTaken) HandleEventResourceStateSnapshotTaken ¶
func (e *ResourceStateSnapshotTaken) HandleEventResourceStateSnapshotTaken(ctx context.Context, snapshot *ResourceStateSnapshotTaken)
func (*ResourceStateSnapshotTaken) HandleEventResourceUpdatePending ¶
func (e *ResourceStateSnapshotTaken) HandleEventResourceUpdatePending(ctx context.Context, updatePending *ResourceUpdatePending) error
func (*ResourceStateSnapshotTaken) HandleEventResourceUpdated ¶
func (e *ResourceStateSnapshotTaken) HandleEventResourceUpdated(ctx context.Context, updated *ResourceUpdated) error
func (*ResourceStateSnapshotTaken) IsSnapshot ¶
func (e *ResourceStateSnapshotTaken) IsSnapshot() bool
func (*ResourceStateSnapshotTaken) Marshal ¶
func (e *ResourceStateSnapshotTaken) Marshal() ([]byte, error)
func (*ResourceStateSnapshotTaken) ProtoMessage ¶
func (*ResourceStateSnapshotTaken) ProtoMessage()
func (*ResourceStateSnapshotTaken) ProtoReflect ¶
func (x *ResourceStateSnapshotTaken) ProtoReflect() protoreflect.Message
func (*ResourceStateSnapshotTaken) Reset ¶
func (x *ResourceStateSnapshotTaken) Reset()
func (*ResourceStateSnapshotTaken) String ¶
func (x *ResourceStateSnapshotTaken) String() string
func (*ResourceStateSnapshotTaken) TakeSnapshot ¶
func (e *ResourceStateSnapshotTaken) TakeSnapshot(version uint64) (eventstore.Event, bool)
func (*ResourceStateSnapshotTaken) Timestamp ¶
func (e *ResourceStateSnapshotTaken) Timestamp() time.Time
func (*ResourceStateSnapshotTaken) Unmarshal ¶
func (e *ResourceStateSnapshotTaken) Unmarshal(b []byte) error
func (*ResourceStateSnapshotTaken) ValidateSequence ¶
func (e *ResourceStateSnapshotTaken) ValidateSequence(eventMetadata *EventMetadata) bool
func (*ResourceStateSnapshotTaken) Version ¶
func (e *ResourceStateSnapshotTaken) Version() uint64
type ResourceUpdatePending ¶
type ResourceUpdatePending struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` ResourceInterface string `protobuf:"bytes,2,opt,name=resource_interface,json=resourceInterface,proto3" json:"resource_interface,omitempty"` Content *commands.Content `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"` AuditContext *commands.AuditContext `protobuf:"bytes,4,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` EventMetadata *EventMetadata `protobuf:"bytes,5,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` ValidUntil int64 `protobuf:"varint,6,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when pending event is considered as expired. 0 means forever. // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ResourceUpdatePending) AggregateID ¶
func (e *ResourceUpdatePending) AggregateID() string
func (*ResourceUpdatePending) CheckInitialized ¶
func (e *ResourceUpdatePending) CheckInitialized() bool
func (*ResourceUpdatePending) CopyData ¶
func (e *ResourceUpdatePending) CopyData(event *ResourceUpdatePending)
func (*ResourceUpdatePending) Descriptor
deprecated
func (*ResourceUpdatePending) Descriptor() ([]byte, []int)
Deprecated: Use ResourceUpdatePending.ProtoReflect.Descriptor instead.
func (*ResourceUpdatePending) EventType ¶
func (e *ResourceUpdatePending) EventType() string
func (*ResourceUpdatePending) GetAuditContext ¶
func (x *ResourceUpdatePending) GetAuditContext() *commands.AuditContext
func (*ResourceUpdatePending) GetContent ¶
func (x *ResourceUpdatePending) GetContent() *commands.Content
func (*ResourceUpdatePending) GetEventMetadata ¶
func (x *ResourceUpdatePending) GetEventMetadata() *EventMetadata
func (*ResourceUpdatePending) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *ResourceUpdatePending) GetOpenTelemetryCarrier() map[string]string
func (*ResourceUpdatePending) GetResourceId ¶
func (x *ResourceUpdatePending) GetResourceId() *commands.ResourceId
func (*ResourceUpdatePending) GetResourceInterface ¶
func (x *ResourceUpdatePending) GetResourceInterface() string
func (*ResourceUpdatePending) GetValidUntil ¶
func (x *ResourceUpdatePending) GetValidUntil() int64
func (*ResourceUpdatePending) GroupID ¶
func (e *ResourceUpdatePending) GroupID() string
func (*ResourceUpdatePending) IsExpired ¶
func (e *ResourceUpdatePending) IsExpired(now time.Time) bool
func (*ResourceUpdatePending) IsSnapshot ¶
func (e *ResourceUpdatePending) IsSnapshot() bool
func (*ResourceUpdatePending) Marshal ¶
func (e *ResourceUpdatePending) Marshal() ([]byte, error)
func (*ResourceUpdatePending) ProtoMessage ¶
func (*ResourceUpdatePending) ProtoMessage()
func (*ResourceUpdatePending) ProtoReflect ¶
func (x *ResourceUpdatePending) ProtoReflect() protoreflect.Message
func (*ResourceUpdatePending) Reset ¶
func (x *ResourceUpdatePending) Reset()
func (*ResourceUpdatePending) String ¶
func (x *ResourceUpdatePending) String() string
func (*ResourceUpdatePending) Timestamp ¶
func (e *ResourceUpdatePending) Timestamp() time.Time
func (*ResourceUpdatePending) Unmarshal ¶
func (e *ResourceUpdatePending) Unmarshal(b []byte) error
func (*ResourceUpdatePending) ValidUntilTime ¶
func (e *ResourceUpdatePending) ValidUntilTime() time.Time
func (*ResourceUpdatePending) Version ¶
func (e *ResourceUpdatePending) Version() uint64
type ResourceUpdated ¶
type ResourceUpdated struct { ResourceId *commands.ResourceId `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"` Status commands.Status `protobuf:"varint,2,opt,name=status,proto3,enum=resourceaggregate.pb.Status" json:"status,omitempty"` Content *commands.Content `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"` AuditContext *commands.AuditContext `protobuf:"bytes,4,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` EventMetadata *EventMetadata `protobuf:"bytes,5,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"` // Open telemetry data propagated to asynchronous events OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ResourceUpdated) AggregateID ¶
func (e *ResourceUpdated) AggregateID() string
func (*ResourceUpdated) CheckInitialized ¶
func (e *ResourceUpdated) CheckInitialized() bool
func (*ResourceUpdated) CopyData ¶
func (e *ResourceUpdated) CopyData(event *ResourceUpdated)
func (*ResourceUpdated) Descriptor
deprecated
func (*ResourceUpdated) Descriptor() ([]byte, []int)
Deprecated: Use ResourceUpdated.ProtoReflect.Descriptor instead.
func (*ResourceUpdated) EventType ¶
func (e *ResourceUpdated) EventType() string
func (*ResourceUpdated) GetAuditContext ¶
func (x *ResourceUpdated) GetAuditContext() *commands.AuditContext
func (*ResourceUpdated) GetContent ¶
func (x *ResourceUpdated) GetContent() *commands.Content
func (*ResourceUpdated) GetEventMetadata ¶
func (x *ResourceUpdated) GetEventMetadata() *EventMetadata
func (*ResourceUpdated) GetOpenTelemetryCarrier ¶ added in v2.4.0
func (x *ResourceUpdated) GetOpenTelemetryCarrier() map[string]string
func (*ResourceUpdated) GetResourceId ¶
func (x *ResourceUpdated) GetResourceId() *commands.ResourceId
func (*ResourceUpdated) GetStatus ¶
func (x *ResourceUpdated) GetStatus() commands.Status
func (*ResourceUpdated) GroupID ¶
func (e *ResourceUpdated) GroupID() string
func (*ResourceUpdated) IsSnapshot ¶
func (e *ResourceUpdated) IsSnapshot() bool
func (*ResourceUpdated) Marshal ¶
func (e *ResourceUpdated) Marshal() ([]byte, error)
func (*ResourceUpdated) ProtoMessage ¶
func (*ResourceUpdated) ProtoMessage()
func (*ResourceUpdated) ProtoReflect ¶
func (x *ResourceUpdated) ProtoReflect() protoreflect.Message
func (*ResourceUpdated) Reset ¶
func (x *ResourceUpdated) Reset()
func (*ResourceUpdated) String ¶
func (x *ResourceUpdated) String() string
func (*ResourceUpdated) Timestamp ¶
func (e *ResourceUpdated) Timestamp() time.Time
func (*ResourceUpdated) Unmarshal ¶
func (e *ResourceUpdated) Unmarshal(b []byte) error
func (*ResourceUpdated) Version ¶
func (e *ResourceUpdated) Version() uint64
Source Files ¶
- deviceMetadataSnapshotTaken.go
- deviceMetadataUpdatePending.go
- deviceMetadataUpdated.go
- events.go
- events.pb.go
- resourceChanged.go
- resourceCreatePending.go
- resourceCreated.go
- resourceDeletePending.go
- resourceDeleted.go
- resourceLinksPublished.go
- resourceLinksSnapshotTaken.go
- resourceLinksUnpublished.go
- resourceRetrievePending.go
- resourceRetrieved.go
- resourceStateSnapshotTaken.go
- resourceUpdatePending.go
- resourceUpdated.go
- utils.go