message

Jun 24, 2025

Changes in this version

+ func Kinds() iter.Seq[Kind]

Oct 5, 2024

Changes in this version

+ func MapByKindOfWithErr[T any](m dogma.Message, command func(dogma.Command) (T, error), ...) (result T, err error)

+ func MapByKindOf[T any](m dogma.Message, command func(dogma.Command) T, event func(dogma.Event) T, ...) (result T)

+ func MapByKind[T any](k Kind, command, event, timeout T) (result T)

+ func SwitchByKind(k Kind, command func(), event func(), timeout func())

+ func SwitchByKindOf(m dogma.Message, command func(dogma.Command), event func(dogma.Event), ...)

+ type Kind int

+ const CommandKind

+ const EventKind

+ const TimeoutKind

+ func KindFor[T dogma.Message]() Kind

+ func KindOf(m dogma.Message) Kind

+ func (k Kind) String() string

+ func (k Kind) Symbol() string

+ type Name string

+ func NameFor[T dogma.Message]() Name

+ func NameOf(m dogma.Message) Name

type Type

+ func TypeFor[T dogma.Message]() Type

+ func TypeFromReflect(r reflect.Type) Type

+ func (t Type) Kind() Kind

+ func (t Type) Name() Name

Oct 21, 2019

Changes in this version

+ func Description(m dogma.Message) string

+ type Describer interface

+ MessageDescription func() string

type RoleMap

+ func (rm RoleMap) Each(fn func(Type) bool) bool

type Type

+ func FromReflectType(rt reflect.Type) (mt Type, ok bool)

type TypeContainer

+ Each func(fn func(Type) bool) bool

type TypeSet

+ func (s TypeSet) Each(fn func(Type) bool) bool

Jun 10, 2019

Changes in this version

type Correlation

+ func (c Correlation) Validate() error

type Direction

+ func (d Direction) Validate() error

type Role

+ func (r Role) Validate() error

Mar 7, 2019

Changes in this version

+ type Timeout struct

+ Message dogma.Message

+ MetaData TimeoutMetaData

+ type TimeoutMetaData struct

+ ProcessID string

+ ProcessName string

+ TimeoutTime time.Time

Feb 27, 2019

Changes in this version

+ type RoleMap map[Type]Role

+ func (rm RoleMap) Add(t Type, r Role) bool

+ func (rm RoleMap) AddM(m dogma.Message, r Role) bool

+ func (rm RoleMap) Has(t Type) bool

+ func (rm RoleMap) HasM(m dogma.Message) bool

+ func (rm RoleMap) Remove(t Type) bool

+ func (rm RoleMap) RemoveM(m dogma.Message) bool

+ type TypeContainer interface

+ Has func(t Type) bool

+ HasM func(m dogma.Message) bool

Feb 6, 2019

Changes in this version

+ var Directions = []Direction

+ var Roles = []Role

+ func ToString(m dogma.Message) string

+ type Correlation struct

+ CausationID string

+ CorrelationID string

+ MessageID string

+ func NewCorrelation(id string) Correlation

+ func (c Correlation) IsCausedBy(p Correlation) bool

+ func (c Correlation) IsCorrelatedWith(p Correlation) bool

+ func (c Correlation) IsRoot() bool

+ func (c Correlation) MustValidate()

+ func (c Correlation) New(id string) Correlation

+ type Direction string

+ const InboundDirection

+ const OutboundDirection

+ func (d Direction) MustBe(x Direction)

+ func (d Direction) MustNotBe(x Direction)

+ func (d Direction) MustValidate()

+ func (d Direction) String() string

+ type MetaData struct

+ Correlation Correlation

+ Direction Direction

+ Role Role

+ Type Type

+ type Role string

+ const CommandRole

+ const EventRole

+ const TimeoutRole

+ func (r Role) Is(roles ...Role) bool

+ func (r Role) Marker() string

+ func (r Role) MustBe(roles ...Role)

+ func (r Role) MustNotBe(roles ...Role)

+ func (r Role) MustValidate()

+ func (r Role) String() string

+ type Stringer interface

+ MessageString func() string

+ type Type interface

+ ReflectType func() reflect.Type

+ String func() string

+ func TypeOf(m dogma.Message) Type

+ type TypeSet map[Type]struct

+ func NewTypeSet(types ...Type) TypeSet

+ func TypesOf(messages ...dogma.Message) TypeSet

+ func (s TypeSet) Add(t Type) bool

+ func (s TypeSet) AddM(m dogma.Message) bool

+ func (s TypeSet) Has(t Type) bool

+ func (s TypeSet) HasM(m dogma.Message) bool

+ func (s TypeSet) Remove(t Type) bool

+ func (s TypeSet) RemoveM(m dogma.Message) bool