test

package

v2.18.0 Latest Latest Go to latest Published: Apr 17, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/plgd-dev/hub

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

View Source

var File_resource_aggregate_cqrs_aggregate_test_aggregate_test_proto protoreflect.FileDescriptor

Functions ¶

This section is empty.

Types ¶

type Command ¶

type Command = interface{}

type Publish ¶

type Publish struct {
	DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Href     string `protobuf:"bytes,2,opt,name=href,proto3" json:"href,omitempty"`
	// contains filtered or unexported fields
}

func (*Publish) Descriptor deprecated

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

Deprecated: Use Publish.ProtoReflect.Descriptor instead.

func (*Publish) GetDeviceId ¶

func (x *Publish) GetDeviceId() string

func (*Publish) GetHref ¶

func (x *Publish) GetHref() string

func (*Publish) ProtoMessage ¶

func (*Publish) ProtoMessage()

func (*Publish) ProtoReflect ¶

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

func (*Publish) Reset ¶

func (x *Publish) Reset()

func (*Publish) String ¶

func (x *Publish) String() string

type Published ¶

type Published struct {
	DeviceId       string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Href           string `protobuf:"bytes,2,opt,name=href,proto3" json:"href,omitempty"`
	EventVersion   uint64 `protobuf:"varint,3,opt,name=event_version,json=eventVersion,proto3" json:"event_version,omitempty"`
	EventTimestamp int64  `protobuf:"varint,4,opt,name=event_timestamp,json=eventTimestamp,proto3" json:"event_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Published) AggregateID ¶

func (e *Published) AggregateID() string

func (*Published) Descriptor deprecated

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

Deprecated: Use Published.ProtoReflect.Descriptor instead.

func (*Published) ETag ¶ added in v2.10.0

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

func (*Published) EventType ¶

func (e *Published) EventType() string

func (*Published) GetDeviceId ¶

func (x *Published) GetDeviceId() string

func (*Published) GetEventTimestamp ¶

func (x *Published) GetEventTimestamp() int64

func (*Published) GetEventVersion ¶

func (x *Published) GetEventVersion() uint64

func (*Published) GetHref ¶

func (x *Published) GetHref() string

func (*Published) GroupID ¶

func (e *Published) GroupID() string

func (*Published) IsSnapshot ¶

func (e *Published) IsSnapshot() bool

func (*Published) Marshal ¶

func (e *Published) Marshal() ([]byte, error)

func (*Published) ProtoMessage ¶

func (*Published) ProtoMessage()

func (*Published) ProtoReflect ¶

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

func (*Published) Reset ¶

func (x *Published) Reset()

func (*Published) ServiceID ¶ added in v2.12.0

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

func (*Published) String ¶

func (x *Published) String() string

func (*Published) Timestamp ¶

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

func (*Published) Types ¶ added in v2.18.0

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

func (*Published) Unmarshal ¶

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

func (*Published) Version ¶

func (e *Published) Version() uint64

type Snapshot ¶

type Snapshot struct {
	DeviceId       string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Href           string `protobuf:"bytes,2,opt,name=href,proto3" json:"href,omitempty"`
	IsPublished    bool   `protobuf:"varint,3,opt,name=is_published,json=isPublished,proto3" json:"is_published,omitempty"`
	EventVersion   uint64 `protobuf:"varint,4,opt,name=event_version,json=eventVersion,proto3" json:"event_version,omitempty"`
	EventTimestamp int64  `protobuf:"varint,5,opt,name=event_timestamp,json=eventTimestamp,proto3" json:"event_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Snapshot) AggregateID ¶

func (e *Snapshot) AggregateID() string

func (*Snapshot) Descriptor deprecated

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

Deprecated: Use Snapshot.ProtoReflect.Descriptor instead.

func (*Snapshot) ETag ¶ added in v2.10.0

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

func (*Snapshot) EventType ¶

func (e *Snapshot) EventType() string

func (*Snapshot) GetDeviceId ¶

func (x *Snapshot) GetDeviceId() string

func (*Snapshot) GetEventTimestamp ¶

func (x *Snapshot) GetEventTimestamp() int64

func (*Snapshot) GetEventVersion ¶

func (x *Snapshot) GetEventVersion() uint64

func (*Snapshot) GetHref ¶

func (x *Snapshot) GetHref() string

func (*Snapshot) GetIsPublished ¶

func (x *Snapshot) GetIsPublished() bool

func (*Snapshot) GroupID ¶

func (e *Snapshot) GroupID() string

func (*Snapshot) GroupId ¶

func (e *Snapshot) GroupId() string

func (*Snapshot) Handle ¶

func (e *Snapshot) Handle(ctx context.Context, iter eventstore.Iter) error

func (*Snapshot) HandleCommand ¶

func (e *Snapshot) HandleCommand(_ context.Context, cmd Command, newVersion uint64) ([]eventstore.Event, error)

func (*Snapshot) IsSnapshot ¶

func (e *Snapshot) IsSnapshot() bool

func (*Snapshot) Marshal ¶

func (e *Snapshot) Marshal() ([]byte, error)

func (*Snapshot) ProtoMessage ¶

func (*Snapshot) ProtoMessage()

func (*Snapshot) ProtoReflect ¶

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

func (*Snapshot) Reset ¶

func (x *Snapshot) Reset()

func (*Snapshot) ServiceID ¶ added in v2.12.0

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

func (*Snapshot) String ¶

func (x *Snapshot) String() string

func (*Snapshot) TakeSnapshot ¶

func (e *Snapshot) TakeSnapshot(version uint64) (eventstore.Event, bool)

func (*Snapshot) Timestamp ¶

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

func (*Snapshot) Types ¶ added in v2.18.0

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

func (*Snapshot) Unmarshal ¶

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

func (*Snapshot) Version ¶

func (e *Snapshot) Version() uint64

type Unpublish ¶

type Unpublish struct {
	DeviceId string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Href     string `protobuf:"bytes,2,opt,name=href,proto3" json:"href,omitempty"`
	// contains filtered or unexported fields
}

func (*Unpublish) Descriptor deprecated

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

Deprecated: Use Unpublish.ProtoReflect.Descriptor instead.

func (*Unpublish) GetDeviceId ¶

func (x *Unpublish) GetDeviceId() string

func (*Unpublish) GetHref ¶

func (x *Unpublish) GetHref() string

func (*Unpublish) ProtoMessage ¶

func (*Unpublish) ProtoMessage()

func (*Unpublish) ProtoReflect ¶

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

func (*Unpublish) Reset ¶

func (x *Unpublish) Reset()

func (*Unpublish) String ¶

func (x *Unpublish) String() string

type Unpublished ¶

type Unpublished struct {
	DeviceId       string `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Href           string `protobuf:"bytes,2,opt,name=href,proto3" json:"href,omitempty"`
	EventVersion   uint64 `protobuf:"varint,3,opt,name=event_version,json=eventVersion,proto3" json:"event_version,omitempty"`
	EventTimestamp int64  `protobuf:"varint,4,opt,name=event_timestamp,json=eventTimestamp,proto3" json:"event_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Unpublished) AggregateID ¶

func (e *Unpublished) AggregateID() string

func (*Unpublished) Descriptor deprecated

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

Deprecated: Use Unpublished.ProtoReflect.Descriptor instead.

func (*Unpublished) ETag ¶ added in v2.10.0

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

func (*Unpublished) EventType ¶

func (e *Unpublished) EventType() string

func (*Unpublished) GetDeviceId ¶

func (x *Unpublished) GetDeviceId() string

func (*Unpublished) GetEventTimestamp ¶

func (x *Unpublished) GetEventTimestamp() int64

func (*Unpublished) GetEventVersion ¶

func (x *Unpublished) GetEventVersion() uint64

func (*Unpublished) GetHref ¶

func (x *Unpublished) GetHref() string

func (*Unpublished) GroupID ¶

func (e *Unpublished) GroupID() string

func (*Unpublished) IsSnapshot ¶

func (e *Unpublished) IsSnapshot() bool

func (*Unpublished) Marshal ¶

func (e *Unpublished) Marshal() ([]byte, error)

func (*Unpublished) ProtoMessage ¶

func (*Unpublished) ProtoMessage()

func (*Unpublished) ProtoReflect ¶

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

func (*Unpublished) Reset ¶

func (x *Unpublished) Reset()

func (*Unpublished) ServiceID ¶ added in v2.12.0

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

func (*Unpublished) String ¶

func (x *Unpublished) String() string

func (*Unpublished) Timestamp ¶

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

func (*Unpublished) Types ¶ added in v2.18.0

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

func (*Unpublished) Unmarshal ¶

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

func (*Unpublished) Version ¶

func (e *Unpublished) Version() uint64

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL