test

package
v2.4.7 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

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

func (x *Published) String() string

func (*Published) Timestamp 

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

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

func (x *Unpublished) String() string

func (*Unpublished) Timestamp 

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

func (*Unpublished) Unmarshal 

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

func (*Unpublished) Version 

func (e *Unpublished) 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.