events

package
v2.4.6 Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2022 License: Apache-2.0 Imports: 22 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 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
}

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

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.