internal

Documentation

Index

• func DbCommandToBaseCommand(dbCmd *Command) (comby.Command, error)
• func DbCommandsToBaseCommands(dbCommands []*Command) ([]comby.Command, error)
• func DbEventToBaseEvent(dbEvent *Event) (comby.Event, error)
• func DbEventsToBaseEvents(dbEvents []*Event) ([]comby.Event, error)
• func Deserialize(dataBytes []byte, dst interface{}) error
• func Serialize(src interface{}) ([]byte, error)
• type Command
  • func BaseCommandToDbCommand(cmd comby.Command) (*Command, error)
• type Event
  • func BaseEventToDbEvent(evt comby.Event) (*Event, error)

Functions

func DbCommandToBaseCommand

func DbCommandToBaseCommand(dbCmd *Command) (comby.Command, error)

func DbCommandsToBaseCommands

func DbCommandsToBaseCommands(dbCommands []*Command) ([]comby.Command, error)

func DbEventToBaseEvent

func DbEventToBaseEvent(dbEvent *Event) (comby.Event, error)

func DbEventsToBaseEvents

func DbEventsToBaseEvents(dbEvents []*Event) ([]comby.Event, error)

func Deserialize

func Deserialize(dataBytes []byte, dst interface{}) error

func Serialize

func Serialize(src interface{}) ([]byte, error)

Types

type Command

type Command struct {
	// system fields
	ID sql.NullInt64

	// fields
	InstanceId int64  `json:"instance_id"`
	Uuid       string `json:"uuid"`
	TenantUuid string `json:"tenant_uuid"`
	Domain     string `json:"domain"`
	CreatedAt  int64  `json:"created_at"`
	DataType   string `json:"data_type"`
	DataBytes  string `json:"data_bytes"`
	ReqCtx     string `json:"req_ctx"`
}

func BaseCommandToDbCommand

func BaseCommandToDbCommand(cmd comby.Command) (*Command, error)

type Event

type Event struct {
	// system fields
	ID sql.NullInt64

	// fields
	InstanceId    int64  `json:"instance_id"`
	Uuid          string `json:"uuid"`
	TenantUuid    string `json:"tenant_uuid"`
	CommandUuid   string `json:"command_uuid"`
	Domain        string `json:"domain"`
	AggregateUuid string `json:"aggregate_uuid"`
	Version       int64  `json:"version"`
	CreatedAt     int64  `json:"created_at"`
	DataType      string `json:"data_type"`
	DataBytes     string `json:"data_bytes"`
}

func BaseEventToDbEvent

func BaseEventToDbEvent(evt comby.Event) (*Event, error)

helpers