events

Documentation

Index

• type ResourceChanged
  • func (e ResourceChanged) AggregateId() string
  • func (e ResourceChanged) EventType() string
  • func (e ResourceChanged) Marshal() ([]byte, error)
  • func (e *ResourceChanged) Unmarshal(b []byte) error
  • func (e ResourceChanged) Version() uint64
• type ResourcePublished
  • func (e ResourcePublished) AggregateId() string
  • func (e ResourcePublished) EventType() string
  • func (e ResourcePublished) Marshal() ([]byte, error)
  • func (e *ResourcePublished) Unmarshal(b []byte) error
  • func (e ResourcePublished) Version() uint64
• type ResourceRetrievePending
  • func (e ResourceRetrievePending) AggregateId() string
  • func (e ResourceRetrievePending) EventType() string
  • func (e ResourceRetrievePending) Marshal() ([]byte, error)
  • func (e *ResourceRetrievePending) Unmarshal(b []byte) error
  • func (e ResourceRetrievePending) Version() uint64
• type ResourceRetrieved
  • func (e ResourceRetrieved) AggregateId() string
  • func (e ResourceRetrieved) EventType() string
  • func (e ResourceRetrieved) Marshal() ([]byte, error)
  • func (e *ResourceRetrieved) Unmarshal(b []byte) error
  • func (e ResourceRetrieved) Version() uint64
• type ResourceStateSnapshotTaken
  • func NewResourceStateSnapshotTaken(verifyAccess VerifyAccessFunc) *ResourceStateSnapshotTaken
  • func (rs *ResourceStateSnapshotTaken) AggregateId() string
  • func (rs *ResourceStateSnapshotTaken) EventType() string
  • func (rs *ResourceStateSnapshotTaken) GroupId() string
  • func (rs *ResourceStateSnapshotTaken) Handle(ctx context.Context, iter event.Iter) error
  • func (rs *ResourceStateSnapshotTaken) HandleCommand(ctx context.Context, cmd cqrs.Command, newVersion uint64) ([]event.Event, error)
  • func (rs *ResourceStateSnapshotTaken) HandleEventResourceChanged(ctx context.Context, contentChanged ResourceChanged) (bool, error)
  • func (rs *ResourceStateSnapshotTaken) HandleEventResourcePublished(ctx context.Context, pub ResourcePublished) error
  • func (rs *ResourceStateSnapshotTaken) HandleEventResourceRetrievePending(ctx context.Context, contentRetrievePending ResourceRetrievePending) error
  • func (rs *ResourceStateSnapshotTaken) HandleEventResourceRetrieved(ctx context.Context, contentUpdateProcessed ResourceRetrieved) error
  • func (rs *ResourceStateSnapshotTaken) HandleEventResourceStateSnapshotTaken(ctx context.Context, s ResourceStateSnapshotTaken) error
  • func (rs *ResourceStateSnapshotTaken) HandleEventResourceUnpublished(ctx context.Context, pub ResourceUnpublished) error
  • func (rs *ResourceStateSnapshotTaken) HandleEventResourceUpdatePending(ctx context.Context, contentUpdatePending ResourceUpdatePending) error
  • func (rs *ResourceStateSnapshotTaken) HandleEventResourceUpdated(ctx context.Context, contentUpdateProcessed ResourceUpdated) error
  • func (rs *ResourceStateSnapshotTaken) Marshal() ([]byte, error)
  • func (rs *ResourceStateSnapshotTaken) SnapshotEventType() string
  • func (rs *ResourceStateSnapshotTaken) TakeSnapshot(version uint64) (event.Event, bool)
  • func (rs *ResourceStateSnapshotTaken) Unmarshal(b []byte) error
  • func (rs *ResourceStateSnapshotTaken) ValidateSequence(eventMetadata *pb.EventMetadata) bool
  • func (rs *ResourceStateSnapshotTaken) Version() uint64
• type ResourceUnpublished
  • func (e ResourceUnpublished) AggregateId() string
  • func (e ResourceUnpublished) EventType() string
  • func (e ResourceUnpublished) Marshal() ([]byte, error)
  • func (e *ResourceUnpublished) Unmarshal(b []byte) error
  • func (e ResourceUnpublished) Version() uint64
• type ResourceUpdatePending
  • func (e ResourceUpdatePending) AggregateId() string
  • func (e ResourceUpdatePending) EventType() string
  • func (e ResourceUpdatePending) Marshal() ([]byte, error)
  • func (e *ResourceUpdatePending) Unmarshal(b []byte) error
  • func (e ResourceUpdatePending) Version() uint64
• type ResourceUpdated
  • func (e ResourceUpdated) AggregateId() string
  • func (e ResourceUpdated) EventType() string
  • func (e ResourceUpdated) Marshal() ([]byte, error)
  • func (e *ResourceUpdated) Unmarshal(b []byte) error
  • func (e ResourceUpdated) Version() uint64
• type VerifyAccessFunc

Types

type ResourceChanged

type ResourceChanged struct {
	pb.ResourceChanged
}

func (ResourceChanged) AggregateId

func (e ResourceChanged) AggregateId() string

func (ResourceChanged) EventType

func (e ResourceChanged) EventType() string

func (ResourceChanged) Marshal

func (e ResourceChanged) Marshal() ([]byte, error)

func (*ResourceChanged) Unmarshal

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

func (ResourceChanged) Version

func (e ResourceChanged) Version() uint64

type ResourcePublished

type ResourcePublished struct {
	pb.ResourcePublished
}

func (ResourcePublished) AggregateId

func (e ResourcePublished) AggregateId() string

func (ResourcePublished) EventType

func (e ResourcePublished) EventType() string

func (ResourcePublished) Marshal

func (e ResourcePublished) Marshal() ([]byte, error)

func (*ResourcePublished) Unmarshal

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

func (ResourcePublished) Version

func (e ResourcePublished) Version() uint64

type ResourceRetrievePending

type ResourceRetrievePending struct {
	pb.ResourceRetrievePending
}

func (ResourceRetrievePending) AggregateId

func (e ResourceRetrievePending) AggregateId() string

func (ResourceRetrievePending) EventType

func (e ResourceRetrievePending) EventType() string

func (ResourceRetrievePending) Marshal

func (e ResourceRetrievePending) Marshal() ([]byte, error)

func (*ResourceRetrievePending) Unmarshal

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

func (ResourceRetrievePending) Version

func (e ResourceRetrievePending) Version() uint64

type ResourceRetrieved

type ResourceRetrieved struct {
	pb.ResourceRetrieved
}

func (ResourceRetrieved) AggregateId

func (e ResourceRetrieved) AggregateId() string

func (ResourceRetrieved) EventType

func (e ResourceRetrieved) EventType() string

func (ResourceRetrieved) Marshal

func (e ResourceRetrieved) Marshal() ([]byte, error)

func (*ResourceRetrieved) Unmarshal

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

func (ResourceRetrieved) Version

func (e ResourceRetrieved) Version() uint64

type ResourceStateSnapshotTaken

type ResourceStateSnapshotTaken struct {
	pb.ResourceStateSnapshotTaken
	// contains filtered or unexported fields
}

func NewResourceStateSnapshotTaken

func NewResourceStateSnapshotTaken(verifyAccess VerifyAccessFunc) *ResourceStateSnapshotTaken

func (*ResourceStateSnapshotTaken) AggregateId

func (rs *ResourceStateSnapshotTaken) AggregateId() string

func (*ResourceStateSnapshotTaken) EventType

func (rs *ResourceStateSnapshotTaken) EventType() string

func (*ResourceStateSnapshotTaken) GroupId

func (rs *ResourceStateSnapshotTaken) GroupId() string

func (*ResourceStateSnapshotTaken) Handle

func (rs *ResourceStateSnapshotTaken) Handle(ctx context.Context, iter event.Iter) error

func (*ResourceStateSnapshotTaken) HandleCommand

func (rs *ResourceStateSnapshotTaken) HandleCommand(ctx context.Context, cmd cqrs.Command, newVersion uint64) ([]event.Event, error)

func (*ResourceStateSnapshotTaken) HandleEventResourceChanged

func (rs *ResourceStateSnapshotTaken) HandleEventResourceChanged(ctx context.Context, contentChanged ResourceChanged) (bool, error)

func (*ResourceStateSnapshotTaken) HandleEventResourcePublished

func (rs *ResourceStateSnapshotTaken) HandleEventResourcePublished(ctx context.Context, pub ResourcePublished) error

func (*ResourceStateSnapshotTaken) HandleEventResourceRetrievePending

func (rs *ResourceStateSnapshotTaken) HandleEventResourceRetrievePending(ctx context.Context, contentRetrievePending ResourceRetrievePending) error

func (*ResourceStateSnapshotTaken) HandleEventResourceRetrieved

func (rs *ResourceStateSnapshotTaken) HandleEventResourceRetrieved(ctx context.Context, contentUpdateProcessed ResourceRetrieved) error

func (*ResourceStateSnapshotTaken) HandleEventResourceStateSnapshotTaken

func (rs *ResourceStateSnapshotTaken) HandleEventResourceStateSnapshotTaken(ctx context.Context, s ResourceStateSnapshotTaken) error

func (*ResourceStateSnapshotTaken) HandleEventResourceUnpublished

func (rs *ResourceStateSnapshotTaken) HandleEventResourceUnpublished(ctx context.Context, pub ResourceUnpublished) error

func (*ResourceStateSnapshotTaken) HandleEventResourceUpdatePending

func (rs *ResourceStateSnapshotTaken) HandleEventResourceUpdatePending(ctx context.Context, contentUpdatePending ResourceUpdatePending) error

func (*ResourceStateSnapshotTaken) HandleEventResourceUpdated

func (rs *ResourceStateSnapshotTaken) HandleEventResourceUpdated(ctx context.Context, contentUpdateProcessed ResourceUpdated) error

func (*ResourceStateSnapshotTaken) Marshal

func (rs *ResourceStateSnapshotTaken) Marshal() ([]byte, error)

func (*ResourceStateSnapshotTaken) SnapshotEventType

func (rs *ResourceStateSnapshotTaken) SnapshotEventType() string

func (*ResourceStateSnapshotTaken) TakeSnapshot

func (rs *ResourceStateSnapshotTaken) TakeSnapshot(version uint64) (event.Event, bool)

func (*ResourceStateSnapshotTaken) Unmarshal

func (rs *ResourceStateSnapshotTaken) Unmarshal(b []byte) error

func (*ResourceStateSnapshotTaken) ValidateSequence

func (rs *ResourceStateSnapshotTaken) ValidateSequence(eventMetadata *pb.EventMetadata) bool

func (*ResourceStateSnapshotTaken) Version

func (rs *ResourceStateSnapshotTaken) Version() uint64

type ResourceUnpublished

type ResourceUnpublished struct {
	pb.ResourceUnpublished
}

func (ResourceUnpublished) AggregateId

func (e ResourceUnpublished) AggregateId() string

func (ResourceUnpublished) EventType

func (e ResourceUnpublished) EventType() string

func (ResourceUnpublished) Marshal

func (e ResourceUnpublished) Marshal() ([]byte, error)

func (*ResourceUnpublished) Unmarshal

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

func (ResourceUnpublished) Version

func (e ResourceUnpublished) Version() uint64

type ResourceUpdatePending

type ResourceUpdatePending struct {
	pb.ResourceUpdatePending
}

func (ResourceUpdatePending) AggregateId

func (e ResourceUpdatePending) AggregateId() string

func (ResourceUpdatePending) EventType

func (e ResourceUpdatePending) EventType() string

func (ResourceUpdatePending) Marshal

func (e ResourceUpdatePending) Marshal() ([]byte, error)

func (*ResourceUpdatePending) Unmarshal

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

func (ResourceUpdatePending) Version

func (e ResourceUpdatePending) Version() uint64

type ResourceUpdated

type ResourceUpdated struct {
	pb.ResourceUpdated
}

func (ResourceUpdated) AggregateId

func (e ResourceUpdated) AggregateId() string

func (ResourceUpdated) EventType

func (e ResourceUpdated) EventType() string

func (ResourceUpdated) Marshal

func (e ResourceUpdated) Marshal() ([]byte, error)

func (*ResourceUpdated) Unmarshal

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

func (ResourceUpdated) Version

func (e ResourceUpdated) Version() uint64

type VerifyAccessFunc

type VerifyAccessFunc func(deviceId, resourceId string) error