cqrs

Documentation

Index

• func GetTopics(deviceId string) []string
• func MakeAuditContext(a *pb.AuthorizationContext, correlationId string) pb.AuditContext
• func MakeEventMeta(connectionId string, sequence, version uint64) pb.EventMetadata
• func MakeResourceId(deviceID, href string) string
• func Marshal(v interface{}) ([]byte, error)
• func TimeNowMs() uint64
• func Unmarshal(b []byte, v interface{}) error
• type ProtobufMarshaler
• type ProtobufUnmarshaler

Functions

func GetTopics

func GetTopics(deviceId string) []string

func MakeAuditContext

func MakeAuditContext(a *pb.AuthorizationContext, 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
}