events

package
v2.18.0 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2024 License: Apache-2.0 Imports: 25 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_resource_aggregate_pb_events_proto protoreflect.FileDescriptor

Functions

func EqualResource 

func EqualResource(x, y *commands.Resource) bool

func EqualStringSlice 

func EqualStringSlice(x, y []string) bool

func IsExpired 

func IsExpired(now time.Time, validUntil time.Time) bool

func RemoveIndex 

func RemoveIndex(s []int, index int) []int

Types

type ConfirmExpiredServicesRequest added in v2.12.0 

type ConfirmExpiredServicesRequest struct {
	Heartbeat []*ServicesHeartbeat_Heartbeat
}

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

func (d *DeviceMetadataSnapshotTaken) CheckInitialized() bool

func (*DeviceMetadataSnapshotTaken) Clone 

func (d *DeviceMetadataSnapshotTaken) Clone() *DeviceMetadataSnapshotTaken

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) ETag added in v2.10.0 

func (d *DeviceMetadataSnapshotTaken) ETag() *eventstore.ETagData

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

func (d *DeviceMetadataSnapshotTaken) HandleDeviceMetadataSnapshotTaken(_ context.Context, s *DeviceMetadataSnapshotTaken)

func (*DeviceMetadataSnapshotTaken) HandleDeviceMetadataUpdatePending 

func (d *DeviceMetadataSnapshotTaken) HandleDeviceMetadataUpdatePending(_ context.Context, updatePending *DeviceMetadataUpdatePending) error

func (*DeviceMetadataSnapshotTaken) HandleDeviceMetadataUpdated 

func (d *DeviceMetadataSnapshotTaken) HandleDeviceMetadataUpdated(_ 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) ServiceID added in v2.12.0 

func (d *DeviceMetadataSnapshotTaken) ServiceID() (string, bool)

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) Types added in v2.18.0 

func (d *DeviceMetadataSnapshotTaken) Types() []string

func (*DeviceMetadataSnapshotTaken) Unmarshal 

func (d *DeviceMetadataSnapshotTaken) Unmarshal(b []byte) error

func (*DeviceMetadataSnapshotTaken) Version 

func (d *DeviceMetadataSnapshotTaken) Version() uint64

type DeviceMetadataSnapshotTakenForCommand added in v2.12.0 

type DeviceMetadataSnapshotTakenForCommand struct {
	*DeviceMetadataSnapshotTaken
	// contains filtered or unexported fields
}

func NewDeviceMetadataSnapshotTakenForCommand added in v2.12.0 

func NewDeviceMetadataSnapshotTakenForCommand(userID string, owner string, hubID string) *DeviceMetadataSnapshotTakenForCommand

func (*DeviceMetadataSnapshotTakenForCommand) CancelPendingMetadataUpdatesRequest added in v2.12.0 

func (d *DeviceMetadataSnapshotTakenForCommand) CancelPendingMetadataUpdatesRequest(ctx context.Context, req *commands.CancelPendingMetadataUpdatesRequest, newVersion uint64) ([]eventstore.Event, error)

func (*DeviceMetadataSnapshotTakenForCommand) ConfirmDeviceMetadataUpdateRequest added in v2.12.0 

func (d *DeviceMetadataSnapshotTakenForCommand) ConfirmDeviceMetadataUpdateRequest(ctx context.Context, req *commands.ConfirmDeviceMetadataUpdateRequest, newVersion uint64, cancel bool) ([]eventstore.Event, error)

func (*DeviceMetadataSnapshotTakenForCommand) HandleCommand added in v2.12.0 

func (d *DeviceMetadataSnapshotTakenForCommand) HandleCommand(ctx context.Context, cmd aggregate.Command, newVersion uint64) ([]eventstore.Event, error)

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_TwinEnabled
	//	*DeviceMetadataUpdatePending_TwinForceSynchronization
	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) ETag added in v2.10.0 

func (d *DeviceMetadataUpdatePending) ETag() *eventstore.ETagData

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) GetTwinEnabled added in v2.6.0 

func (x *DeviceMetadataUpdatePending) GetTwinEnabled() bool

func (*DeviceMetadataUpdatePending) GetTwinForceSynchronization added in v2.10.0 

func (x *DeviceMetadataUpdatePending) GetTwinForceSynchronization() bool

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) ServiceID added in v2.12.0 

func (d *DeviceMetadataUpdatePending) ServiceID() (string, bool)

func (*DeviceMetadataUpdatePending) String 

func (x *DeviceMetadataUpdatePending) String() string

func (*DeviceMetadataUpdatePending) Timestamp 

func (d *DeviceMetadataUpdatePending) Timestamp() time.Time

func (*DeviceMetadataUpdatePending) Types added in v2.18.0 

func (d *DeviceMetadataUpdatePending) Types() []string

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_TwinEnabled added in v2.6.0 

type DeviceMetadataUpdatePending_TwinEnabled struct {
	TwinEnabled bool `protobuf:"varint,6,opt,name=twin_enabled,json=twinEnabled,proto3,oneof"`
}

type DeviceMetadataUpdatePending_TwinForceSynchronization added in v2.10.0 

type DeviceMetadataUpdatePending_TwinForceSynchronization struct {
	TwinForceSynchronization bool `protobuf:"varint,7,opt,name=twin_force_synchronization,json=twinForceSynchronization,proto3,oneof"`
}

type DeviceMetadataUpdated 

type DeviceMetadataUpdated struct {
	DeviceId            string                        `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Connection          *commands.Connection          `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	TwinSynchronization *commands.TwinSynchronization `protobuf:"bytes,7,opt,name=twin_synchronization,json=twinSynchronization,proto3" json:"twin_synchronization,omitempty"`
	TwinEnabled         bool                          `protobuf:"varint,8,opt,name=twin_enabled,json=twinEnabled,proto3" json:"twin_enabled,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"`
	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) ETag added in v2.10.0 

func (d *DeviceMetadataUpdated) ETag() *eventstore.ETagData

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) GetConnection added in v2.6.0 

func (x *DeviceMetadataUpdated) GetConnection() *commands.Connection

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) GetTwinEnabled added in v2.6.0 

func (x *DeviceMetadataUpdated) GetTwinEnabled() bool

func (*DeviceMetadataUpdated) GetTwinSynchronization added in v2.6.0 

func (x *DeviceMetadataUpdated) GetTwinSynchronization() *commands.TwinSynchronization

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) ServiceID added in v2.12.0 

func (d *DeviceMetadataUpdated) ServiceID() (string, bool)

func (*DeviceMetadataUpdated) String 

func (x *DeviceMetadataUpdated) String() string

func (*DeviceMetadataUpdated) Timestamp 

func (d *DeviceMetadataUpdated) Timestamp() time.Time

func (*DeviceMetadataUpdated) Types added in v2.18.0 

func (d *DeviceMetadataUpdated) Types() []string

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
	HubId        string `protobuf:"bytes,5,opt,name=hub_id,json=hubId,proto3" json:"hub_id,omitempty"` // the hub which sent the event
	// contains filtered or unexported fields
}

func MakeEventMeta 

func MakeEventMeta(connectionID string, sequence, version uint64, hubID string) *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) GetHubId added in v2.9.0 

func (x *EventMetadata) GetHubId() 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"`
	Etag          []byte                 `protobuf:"bytes,6,opt,name=etag,proto3" json:"etag,omitempty"` // etag of the resource used by twin synchronization
	ResourceTypes []string               `protobuf:"bytes,7,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,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) ETag added in v2.10.0 

func (rc *ResourceChanged) ETag() *eventstore.ETagData

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) GetEtag added in v2.10.0 

func (x *ResourceChanged) GetEtag() []byte

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) GetResourceTypes added in v2.18.0 

func (x *ResourceChanged) GetResourceTypes() []string

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) ServiceID added in v2.12.0 

func (rc *ResourceChanged) ServiceID() (string, bool)

func (*ResourceChanged) String 

func (x *ResourceChanged) String() string

func (*ResourceChanged) Timestamp 

func (rc *ResourceChanged) Timestamp() time.Time

func (*ResourceChanged) Types added in v2.18.0 

func (rc *ResourceChanged) Types() []string

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.
	ResourceTypes []string               `protobuf:"bytes,6,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,omitempty"`
	// 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) ETag added in v2.10.0 

func (e *ResourceCreatePending) ETag() *eventstore.ETagData

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) GetResourceTypes added in v2.18.0 

func (x *ResourceCreatePending) GetResourceTypes() []string

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) ServiceID added in v2.12.0 

func (e *ResourceCreatePending) ServiceID() (string, bool)

func (*ResourceCreatePending) String 

func (x *ResourceCreatePending) String() string

func (*ResourceCreatePending) Timestamp 

func (e *ResourceCreatePending) Timestamp() time.Time

func (*ResourceCreatePending) Types added in v2.18.0 

func (e *ResourceCreatePending) Types() []string

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"`
	ResourceTypes []string               `protobuf:"bytes,6,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,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) ETag added in v2.10.0 

func (e *ResourceCreated) ETag() *eventstore.ETagData

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) GetResourceTypes added in v2.18.0 

func (x *ResourceCreated) GetResourceTypes() []string

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) ServiceID added in v2.12.0 

func (e *ResourceCreated) ServiceID() (string, bool)

func (*ResourceCreated) String 

func (x *ResourceCreated) String() string

func (*ResourceCreated) Timestamp 

func (e *ResourceCreated) Timestamp() time.Time

func (*ResourceCreated) Types added in v2.18.0 

func (e *ResourceCreated) Types() []string

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.
	ResourceInterface string                 `protobuf:"bytes,5,opt,name=resource_interface,json=resourceInterface,proto3" json:"resource_interface,omitempty"`
	ResourceTypes     []string               `protobuf:"bytes,6,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,omitempty"`
	// 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) ETag added in v2.10.0 

func (e *ResourceDeletePending) ETag() *eventstore.ETagData

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) GetResourceInterface added in v2.13.1 

func (x *ResourceDeletePending) GetResourceInterface() string

func (*ResourceDeletePending) GetResourceTypes added in v2.18.0 

func (x *ResourceDeletePending) GetResourceTypes() []string

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) ServiceID added in v2.12.0 

func (e *ResourceDeletePending) ServiceID() (string, bool)

func (*ResourceDeletePending) String 

func (x *ResourceDeletePending) String() string

func (*ResourceDeletePending) Timestamp 

func (e *ResourceDeletePending) Timestamp() time.Time

func (*ResourceDeletePending) Types added in v2.18.0 

func (e *ResourceDeletePending) Types() []string

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"`
	ResourceTypes []string               `protobuf:"bytes,6,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,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) ETag added in v2.10.0 

func (e *ResourceDeleted) ETag() *eventstore.ETagData

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) GetResourceTypes added in v2.18.0 

func (x *ResourceDeleted) GetResourceTypes() []string

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) ServiceID added in v2.12.0 

func (e *ResourceDeleted) ServiceID() (string, bool)

func (*ResourceDeleted) String 

func (x *ResourceDeleted) String() string

func (*ResourceDeleted) Timestamp 

func (e *ResourceDeleted) Timestamp() time.Time

func (*ResourceDeleted) Types added in v2.18.0 

func (e *ResourceDeleted) Types() []string

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
}

https://github.com/openconnectivityfoundation/cloud-services/blob/master/swagger2.0/oic.wk.rd.swagger.json#L173

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) ETag added in v2.10.0 

func (e *ResourceLinksPublished) ETag() *eventstore.ETagData

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) ServiceID added in v2.12.0 

func (e *ResourceLinksPublished) ServiceID() (string, bool)

func (*ResourceLinksPublished) String 

func (x *ResourceLinksPublished) String() string

func (*ResourceLinksPublished) Timestamp 

func (e *ResourceLinksPublished) Timestamp() time.Time

func (*ResourceLinksPublished) Types added in v2.18.0 

func (e *ResourceLinksPublished) Types() []string

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) ETag added in v2.10.0 

func (e *ResourceLinksSnapshotTaken) ETag() *eventstore.ETagData

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 (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) 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) ServiceID added in v2.12.0 

func (e *ResourceLinksSnapshotTaken) ServiceID() (string, bool)

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) Types added in v2.18.0 

func (e *ResourceLinksSnapshotTaken) Types() []string

func (*ResourceLinksSnapshotTaken) Unmarshal 

func (e *ResourceLinksSnapshotTaken) Unmarshal(b []byte) error

func (*ResourceLinksSnapshotTaken) Version 

func (e *ResourceLinksSnapshotTaken) Version() uint64

type ResourceLinksSnapshotTakenForCommand added in v2.12.0 

type ResourceLinksSnapshotTakenForCommand struct {
	*ResourceLinksSnapshotTaken
	// contains filtered or unexported fields
}

func NewResourceLinksSnapshotTakenForCommand added in v2.12.0 

func NewResourceLinksSnapshotTakenForCommand(userID string, owner string, hubID string) *ResourceLinksSnapshotTakenForCommand

func (*ResourceLinksSnapshotTakenForCommand) HandleCommand added in v2.12.0 

func (e *ResourceLinksSnapshotTakenForCommand) HandleCommand(ctx context.Context, cmd aggregate.Command, newVersion uint64) ([]eventstore.Event, error)

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) ETag added in v2.10.0 

func (e *ResourceLinksUnpublished) ETag() *eventstore.ETagData

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) ServiceID added in v2.12.0 

func (e *ResourceLinksUnpublished) ServiceID() (string, bool)

func (*ResourceLinksUnpublished) String 

func (x *ResourceLinksUnpublished) String() string

func (*ResourceLinksUnpublished) Timestamp 

func (e *ResourceLinksUnpublished) Timestamp() time.Time

func (*ResourceLinksUnpublished) Types added in v2.18.0 

func (e *ResourceLinksUnpublished) Types() []string

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.
	Etag              [][]byte               `protobuf:"bytes,6,rep,name=etag,proto3" json:"etag,omitempty"`
	ResourceTypes     []string               `protobuf:"bytes,7,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,omitempty"`
	// 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) ETag added in v2.10.0 

func (e *ResourceRetrievePending) ETag() *eventstore.ETagData

func (*ResourceRetrievePending) EventType 

func (e *ResourceRetrievePending) EventType() string

func (*ResourceRetrievePending) GetAuditContext 

func (x *ResourceRetrievePending) GetAuditContext() *commands.AuditContext

func (*ResourceRetrievePending) GetEtag added in v2.10.0 

func (x *ResourceRetrievePending) GetEtag() [][]byte

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) GetResourceTypes added in v2.18.0 

func (x *ResourceRetrievePending) GetResourceTypes() []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) ServiceID added in v2.12.0 

func (e *ResourceRetrievePending) ServiceID() (string, bool)

func (*ResourceRetrievePending) String 

func (x *ResourceRetrievePending) String() string

func (*ResourceRetrievePending) Timestamp 

func (e *ResourceRetrievePending) Timestamp() time.Time

func (*ResourceRetrievePending) Types added in v2.18.0 

func (e *ResourceRetrievePending) Types() []string

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"`
	Etag          []byte                 `protobuf:"bytes,6,opt,name=etag,proto3" json:"etag,omitempty"`
	ResourceTypes []string               `protobuf:"bytes,7,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,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) ETag added in v2.10.0 

func (e *ResourceRetrieved) ETag() *eventstore.ETagData

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) GetEtag added in v2.10.0 

func (x *ResourceRetrieved) GetEtag() []byte

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) GetResourceTypes added in v2.18.0 

func (x *ResourceRetrieved) GetResourceTypes() []string

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) ServiceID added in v2.12.0 

func (e *ResourceRetrieved) ServiceID() (string, bool)

func (*ResourceRetrieved) String 

func (x *ResourceRetrieved) String() string

func (*ResourceRetrieved) Timestamp 

func (e *ResourceRetrieved) Timestamp() time.Time

func (*ResourceRetrieved) Types added in v2.18.0 

func (e *ResourceRetrieved) Types() []string

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"`
	ResourceTypes []string               `protobuf:"bytes,9,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,omitempty"`
	// contains filtered or unexported fields
}

func NewResourceStateSnapshotTaken 

func NewResourceStateSnapshotTaken() *ResourceStateSnapshotTaken

func (*ResourceStateSnapshotTaken) AggregateID 

func (e *ResourceStateSnapshotTaken) AggregateID() string

func (*ResourceStateSnapshotTaken) CheckInitialized 

func (e *ResourceStateSnapshotTaken) CheckInitialized() bool

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) ETag added in v2.10.0 

func (e *ResourceStateSnapshotTaken) ETag() *eventstore.ETagData

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) GetResourceTypes added in v2.18.0 

func (x *ResourceStateSnapshotTaken) GetResourceTypes() []string

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) 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) ServiceID added in v2.12.0 

func (e *ResourceStateSnapshotTaken) ServiceID() (string, bool)

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) Types added in v2.18.0 

func (e *ResourceStateSnapshotTaken) Types() []string

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 ResourceStateSnapshotTakenForCommand added in v2.12.0 

type ResourceStateSnapshotTakenForCommand struct {
	*ResourceStateSnapshotTaken
	// contains filtered or unexported fields
}

func NewResourceStateSnapshotTakenForCommand added in v2.12.0 

func NewResourceStateSnapshotTakenForCommand(userID string, owner string, hubID string, resourceLinks *ResourceLinksSnapshotTakenForCommand) *ResourceStateSnapshotTakenForCommand

func (*ResourceStateSnapshotTakenForCommand) CancelPendingCommandsRequest added in v2.12.0 

func (e *ResourceStateSnapshotTakenForCommand) CancelPendingCommandsRequest(ctx context.Context, req *commands.CancelPendingCommandsRequest, newVersion uint64) ([]eventstore.Event, error)

func (*ResourceStateSnapshotTakenForCommand) HandleCommand added in v2.12.0 

func (e *ResourceStateSnapshotTakenForCommand) HandleCommand(ctx context.Context, cmd aggregate.Command, newVersion uint64) ([]eventstore.Event, error)

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.
	ResourceTypes     []string               `protobuf:"bytes,7,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,omitempty"`
	// 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) ETag added in v2.10.0 

func (e *ResourceUpdatePending) ETag() *eventstore.ETagData

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) GetResourceTypes added in v2.18.0 

func (x *ResourceUpdatePending) GetResourceTypes() []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) ServiceID added in v2.12.0 

func (e *ResourceUpdatePending) ServiceID() (string, bool)

func (*ResourceUpdatePending) String 

func (x *ResourceUpdatePending) String() string

func (*ResourceUpdatePending) Timestamp 

func (e *ResourceUpdatePending) Timestamp() time.Time

func (*ResourceUpdatePending) Types added in v2.18.0 

func (e *ResourceUpdatePending) Types() []string

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"`
	ResourceTypes []string               `protobuf:"bytes,6,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,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) ETag added in v2.10.0 

func (e *ResourceUpdated) ETag() *eventstore.ETagData

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) GetResourceTypes added in v2.18.0 

func (x *ResourceUpdated) GetResourceTypes() []string

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) ServiceID added in v2.12.0 

func (e *ResourceUpdated) ServiceID() (string, bool)

func (*ResourceUpdated) String 

func (x *ResourceUpdated) String() string

func (*ResourceUpdated) Timestamp 

func (e *ResourceUpdated) Timestamp() time.Time

func (*ResourceUpdated) Types added in v2.18.0 

func (e *ResourceUpdated) Types() []string

func (*ResourceUpdated) Unmarshal 

func (e *ResourceUpdated) Unmarshal(b []byte) error

func (*ResourceUpdated) Version 

func (e *ResourceUpdated) Version() uint64

type ServiceMetadataSnapshotTaken added in v2.12.0 

type ServiceMetadataSnapshotTaken struct {
	ServiceMetadataUpdated *ServiceMetadataUpdated `` /* 129-byte string literal not displayed */
	EventMetadata          *EventMetadata          `protobuf:"bytes,2,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"`
	// contains filtered or unexported fields
}

func NewServiceMetadataSnapshotTaken added in v2.12.0 

func NewServiceMetadataSnapshotTaken() *ServiceMetadataSnapshotTaken

func (*ServiceMetadataSnapshotTaken) AggregateID added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) AggregateID() string

func (*ServiceMetadataSnapshotTaken) CheckInitialized added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) CheckInitialized() bool

func (*ServiceMetadataSnapshotTaken) CopyData added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) CopyData(event *ServiceMetadataSnapshotTaken)

func (*ServiceMetadataSnapshotTaken) Descriptor deprecated added in v2.12.0 

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

Deprecated: Use ServiceMetadataSnapshotTaken.ProtoReflect.Descriptor instead.

func (*ServiceMetadataSnapshotTaken) ETag added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) ETag() *eventstore.ETagData

func (*ServiceMetadataSnapshotTaken) EventType added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) EventType() string

func (*ServiceMetadataSnapshotTaken) GetEventMetadata added in v2.12.0 

func (x *ServiceMetadataSnapshotTaken) GetEventMetadata() *EventMetadata

func (*ServiceMetadataSnapshotTaken) GetServiceMetadataUpdated added in v2.12.0 

func (x *ServiceMetadataSnapshotTaken) GetServiceMetadataUpdated() *ServiceMetadataUpdated

func (*ServiceMetadataSnapshotTaken) GroupID added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) GroupID() string

func (*ServiceMetadataSnapshotTaken) Handle added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) Handle(ctx context.Context, iter eventstore.Iter) error

func (*ServiceMetadataSnapshotTaken) HandleServiceMetadataSnapshotTaken added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) HandleServiceMetadataSnapshotTaken(_ context.Context, s *ServiceMetadataSnapshotTaken)

func (*ServiceMetadataSnapshotTaken) HandleServiceMetadataUpdated added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) HandleServiceMetadataUpdated(_ context.Context, upd *ServiceMetadataUpdated) (bool, error)

func (*ServiceMetadataSnapshotTaken) IsSnapshot added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) IsSnapshot() bool

func (*ServiceMetadataSnapshotTaken) Marshal added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) Marshal() ([]byte, error)

func (*ServiceMetadataSnapshotTaken) ProtoMessage added in v2.12.0 

func (*ServiceMetadataSnapshotTaken) ProtoMessage()

func (*ServiceMetadataSnapshotTaken) ProtoReflect added in v2.12.0 

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

func (*ServiceMetadataSnapshotTaken) Reset added in v2.12.0 

func (x *ServiceMetadataSnapshotTaken) Reset()

func (*ServiceMetadataSnapshotTaken) ServiceID added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) ServiceID() (string, bool)

func (*ServiceMetadataSnapshotTaken) String added in v2.12.0 

func (x *ServiceMetadataSnapshotTaken) String() string

func (*ServiceMetadataSnapshotTaken) TakeSnapshot added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) TakeSnapshot(version uint64) (eventstore.Event, bool)

func (*ServiceMetadataSnapshotTaken) Timestamp added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) Timestamp() time.Time

func (*ServiceMetadataSnapshotTaken) Types added in v2.18.0 

func (d *ServiceMetadataSnapshotTaken) Types() []string

func (*ServiceMetadataSnapshotTaken) Unmarshal added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) Unmarshal(b []byte) error

func (*ServiceMetadataSnapshotTaken) Version added in v2.12.0 

func (d *ServiceMetadataSnapshotTaken) Version() uint64

type ServiceMetadataSnapshotTakenForCommand added in v2.12.0 

type ServiceMetadataSnapshotTakenForCommand struct {
	*ServiceMetadataSnapshotTaken
	// contains filtered or unexported fields
}

func NewServiceMetadataSnapshotTakenForCommand added in v2.12.0 

func NewServiceMetadataSnapshotTakenForCommand(userID string, owner string, hubID string) *ServiceMetadataSnapshotTakenForCommand

func (*ServiceMetadataSnapshotTakenForCommand) HandleCommand added in v2.12.0 

func (d *ServiceMetadataSnapshotTakenForCommand) HandleCommand(ctx context.Context, cmd aggregate.Command, newVersion uint64) ([]eventstore.Event, error)

type ServiceMetadataUpdated added in v2.12.0 

type ServiceMetadataUpdated struct {
	ServicesHeartbeat *ServicesHeartbeat     `protobuf:"bytes,1,opt,name=services_heartbeat,json=servicesHeartbeat,proto3" json:"services_heartbeat,omitempty"`
	EventMetadata     *EventMetadata         `protobuf:"bytes,2,opt,name=event_metadata,json=eventMetadata,proto3" json:"event_metadata,omitempty"`
	AuditContext      *commands.AuditContext `protobuf:"bytes,3,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"`
	// Open telemetry data propagated to asynchronous events
	OpenTelemetryCarrier map[string]string `` /* 213-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ServiceMetadataUpdated) AggregateID added in v2.12.0 

func (d *ServiceMetadataUpdated) AggregateID() string

func (*ServiceMetadataUpdated) CheckInitialized added in v2.12.0 

func (d *ServiceMetadataUpdated) CheckInitialized() bool

func (*ServiceMetadataUpdated) CopyData added in v2.12.0 

func (d *ServiceMetadataUpdated) CopyData(event *ServiceMetadataUpdated)

func (*ServiceMetadataUpdated) Descriptor deprecated added in v2.12.0 

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

Deprecated: Use ServiceMetadataUpdated.ProtoReflect.Descriptor instead.

func (*ServiceMetadataUpdated) ETag added in v2.12.0 

func (d *ServiceMetadataUpdated) ETag() *eventstore.ETagData

func (*ServiceMetadataUpdated) Equal added in v2.12.0 

func (d *ServiceMetadataUpdated) Equal(upd *ServiceMetadataUpdated) bool

Equal checks if two ServiceMetadataUpdated events are equal.

func (*ServiceMetadataUpdated) EventType added in v2.12.0 

func (d *ServiceMetadataUpdated) EventType() string

func (*ServiceMetadataUpdated) GetAuditContext added in v2.12.0 

func (x *ServiceMetadataUpdated) GetAuditContext() *commands.AuditContext

func (*ServiceMetadataUpdated) GetEventMetadata added in v2.12.0 

func (x *ServiceMetadataUpdated) GetEventMetadata() *EventMetadata

func (*ServiceMetadataUpdated) GetOpenTelemetryCarrier added in v2.12.0 

func (x *ServiceMetadataUpdated) GetOpenTelemetryCarrier() map[string]string

func (*ServiceMetadataUpdated) GetServicesHeartbeat added in v2.12.0 

func (x *ServiceMetadataUpdated) GetServicesHeartbeat() *ServicesHeartbeat

func (*ServiceMetadataUpdated) GroupID added in v2.12.0 

func (d *ServiceMetadataUpdated) GroupID() string

func (*ServiceMetadataUpdated) IsSnapshot added in v2.12.0 

func (d *ServiceMetadataUpdated) IsSnapshot() bool

func (*ServiceMetadataUpdated) Marshal added in v2.12.0 

func (d *ServiceMetadataUpdated) Marshal() ([]byte, error)

func (*ServiceMetadataUpdated) ProtoMessage added in v2.12.0 

func (*ServiceMetadataUpdated) ProtoMessage()

func (*ServiceMetadataUpdated) ProtoReflect added in v2.12.0 

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

func (*ServiceMetadataUpdated) Reset added in v2.12.0 

func (x *ServiceMetadataUpdated) Reset()

func (*ServiceMetadataUpdated) ServiceID added in v2.12.0 

func (d *ServiceMetadataUpdated) ServiceID() (string, bool)

func (*ServiceMetadataUpdated) String added in v2.12.0 

func (x *ServiceMetadataUpdated) String() string

func (*ServiceMetadataUpdated) Timestamp added in v2.12.0 

func (d *ServiceMetadataUpdated) Timestamp() time.Time

func (*ServiceMetadataUpdated) Types added in v2.18.0 

func (d *ServiceMetadataUpdated) Types() []string

func (*ServiceMetadataUpdated) Unmarshal added in v2.12.0 

func (d *ServiceMetadataUpdated) Unmarshal(b []byte) error

func (*ServiceMetadataUpdated) Version added in v2.12.0 

func (d *ServiceMetadataUpdated) Version() uint64

type ServicesHeartbeat added in v2.12.0 

type ServicesHeartbeat struct {
	Valid   []*ServicesHeartbeat_Heartbeat `protobuf:"bytes,1,rep,name=valid,proto3" json:"valid,omitempty"`     // services which heartbeat is still valid
	Expired []*ServicesHeartbeat_Heartbeat `protobuf:"bytes,2,rep,name=expired,proto3" json:"expired,omitempty"` // services which heartbeat is already expired
	// contains filtered or unexported fields
}

func (*ServicesHeartbeat) CopyData added in v2.12.0 

func (s *ServicesHeartbeat) CopyData(s1 *ServicesHeartbeat)

func (*ServicesHeartbeat) Descriptor deprecated added in v2.12.0 

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

Deprecated: Use ServicesHeartbeat.ProtoReflect.Descriptor instead.

func (*ServicesHeartbeat) Equal added in v2.12.0 

func (s *ServicesHeartbeat) Equal(upd *ServicesHeartbeat) bool

func (*ServicesHeartbeat) GetExpired added in v2.12.0 

func (x *ServicesHeartbeat) GetExpired() []*ServicesHeartbeat_Heartbeat

func (*ServicesHeartbeat) GetValid added in v2.12.0 

func (x *ServicesHeartbeat) GetValid() []*ServicesHeartbeat_Heartbeat

func (*ServicesHeartbeat) ProtoMessage added in v2.12.0 

func (*ServicesHeartbeat) ProtoMessage()

func (*ServicesHeartbeat) ProtoReflect added in v2.12.0 

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

func (*ServicesHeartbeat) Reset added in v2.12.0 

func (x *ServicesHeartbeat) Reset()

func (*ServicesHeartbeat) String added in v2.12.0 

func (x *ServicesHeartbeat) String() string

type ServicesHeartbeat_Heartbeat added in v2.12.0 

type ServicesHeartbeat_Heartbeat struct {
	ServiceId  string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`     // generated unique id during start the service
	ValidUntil int64  `protobuf:"varint,2,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"` // unix timestamp in nanoseconds (https://golang.org/pkg/time/#Time.UnixNano) when service heartbeat is considered as expired.
	// contains filtered or unexported fields
}

func (*ServicesHeartbeat_Heartbeat) CopyData added in v2.12.1 

func (h *ServicesHeartbeat_Heartbeat) CopyData(h1 *ServicesHeartbeat_Heartbeat)

func (*ServicesHeartbeat_Heartbeat) Descriptor deprecated added in v2.12.0 

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

Deprecated: Use ServicesHeartbeat_Heartbeat.ProtoReflect.Descriptor instead.

func (*ServicesHeartbeat_Heartbeat) GetServiceId added in v2.12.0 

func (x *ServicesHeartbeat_Heartbeat) GetServiceId() string

func (*ServicesHeartbeat_Heartbeat) GetValidUntil added in v2.12.0 

func (x *ServicesHeartbeat_Heartbeat) GetValidUntil() int64

func (*ServicesHeartbeat_Heartbeat) ProtoMessage added in v2.12.0 

func (*ServicesHeartbeat_Heartbeat) ProtoMessage()

func (*ServicesHeartbeat_Heartbeat) ProtoReflect added in v2.12.0 

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

func (*ServicesHeartbeat_Heartbeat) Reset added in v2.12.0 

func (x *ServicesHeartbeat_Heartbeat) Reset()

func (*ServicesHeartbeat_Heartbeat) String added in v2.12.0 

func (x *ServicesHeartbeat_Heartbeat) String() string

type UpdateDeviceToOfflineRequest added in v2.12.0 

type UpdateDeviceToOfflineRequest struct {
	DeviceID  string
	ServiceID string
}

func (*UpdateDeviceToOfflineRequest) GetDeviceId added in v2.12.0 

func (r *UpdateDeviceToOfflineRequest) GetDeviceId() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.