events

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 ResourceDeletePending added in v1.1.0 

type ResourceDeletePending struct {
	pb.ResourceDeletePending
}

func (ResourceDeletePending) AggregateId added in v1.1.0 

func (e ResourceDeletePending) AggregateId() string

func (ResourceDeletePending) EventType added in v1.1.0 

func (e ResourceDeletePending) EventType() string

func (ResourceDeletePending) Marshal added in v1.1.0 

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

func (*ResourceDeletePending) Unmarshal added in v1.1.0 

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

func (ResourceDeletePending) Version added in v1.1.0 

func (e ResourceDeletePending) Version() uint64

type ResourceDeleted added in v1.1.0 

type ResourceDeleted struct {
	pb.ResourceDeleted
}

func (ResourceDeleted) AggregateId added in v1.1.0 

func (e ResourceDeleted) AggregateId() string

func (ResourceDeleted) EventType added in v1.1.0 

func (e ResourceDeleted) EventType() string

func (ResourceDeleted) Marshal added in v1.1.0 

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

func (*ResourceDeleted) Unmarshal added in v1.1.0 

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

func (ResourceDeleted) Version added in v1.1.0 

func (e ResourceDeleted) 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) HandleEventResourceDeletePending added in v1.1.0 

func (rs *ResourceStateSnapshotTaken) HandleEventResourceDeletePending(ctx context.Context, req ResourceDeletePending) error

func (*ResourceStateSnapshotTaken) HandleEventResourceDeleted added in v1.1.0 

func (rs *ResourceStateSnapshotTaken) HandleEventResourceDeleted(ctx context.Context, deleted ResourceDeleted) 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

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.