cqrs

package
v1.1.2 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetTopics

func GetTopics(deviceId string) []string

func MakeAuditContext

func MakeAuditContext(deviceID, userID, correlationId string) pb.AuditContext

func MakeEventMeta

func MakeEventMeta(connectionId string, sequence, version uint64) pb.EventMetadata

CreateEventMeta for creating EventMetadata for event.

func MakeResourceId

func MakeResourceId(deviceID, href string) string

func Marshal

func Marshal(v interface{}) ([]byte, error)

func TimeNowMs

func TimeNowMs() uint64

func Unmarshal

func Unmarshal(b []byte, v interface{}) error

Types

type ProtobufMarshaler

type ProtobufMarshaler interface {
	Marshal() ([]byte, error)
}

type ProtobufUnmarshaler

type ProtobufUnmarshaler interface {
	Unmarshal([]byte) error
}

Directories

Path Synopsis
eventbus
eventstore

Jump to

Keyboard shortcuts

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