config

Dec 7, 2025

Changes in this version

+ type ConcurrencyPreference struct

+ Value optional.Optional[dogma.ConcurrencyPreference]

+ func (v *ConcurrencyPreference) String() string

type Integration

+ ConcurrencyPreferences []*ConcurrencyPreference

+ func (h *Integration) ConcurrencyPreference() dogma.ConcurrencyPreference

type Projection

+ ConcurrencyPreferences []*ConcurrencyPreference

+ func (h *Projection) ConcurrencyPreference() dogma.ConcurrencyPreference

+ type UnrecognizedConcurrencyPreference struct

+ InvalidValue dogma.ConcurrencyPreference

+ func (e UnrecognizedConcurrencyPreference) Error() string

Oct 10, 2025

Changes in this version

type RouteSet

+ func (s RouteSet) MessageTypeSet() *sets.Set[message.Type]

Sep 14, 2025

Changes in this version

type Route

+ MessageTypeID optional.Optional[string]

Jun 24, 2025

Changes in this version

+ func Describe(w io.Writer, c Component, options ...DescribeOption) (int, error)

+ func Description(c Component, options ...DescribeOption) string

+ func ErrorsByComponent(c Component, err error) []error

+ func HandlerTypes() iter.Seq[HandlerType]

+ func MapByHandlerTypeOfWithErr[T any](h Handler, aggregate func(*Aggregate) (T, error), ...) (result T, err error)

+ func MapByHandlerTypeOf[T any](h Handler, aggregate func(*Aggregate) T, process func(*Process) T, ...) (result T)

+ func MapByHandlerType[T any](t HandlerType, aggregate T, process T, integration T, projection T) T

+ func MapByProjectionDeliveryPolicyType[T any](t ProjectionDeliveryPolicyType, unicast T, broadcast T) T

+ func MapByRouteType[T any](t RouteType, handlesCommand T, handlesEvent T, executesCommand T, ...) T

+ func ProjectionDeliveryPolicyTypes() iter.Seq[ProjectionDeliveryPolicyType]

+ func RouteTypes() iter.Seq[RouteType]

+ func SwitchByHandlerType(t HandlerType, aggregate func(), process func(), integration func(), ...)

+ func SwitchByHandlerTypeOf(h Handler, aggregate func(*Aggregate), process func(*Process), ...)

+ func SwitchByProjectionDeliveryPolicyType(t ProjectionDeliveryPolicyType, unicast func(), broadcast func())

+ func SwitchByRouteType(t RouteType, handlesCommand func(), handlesEvent func(), ...)

+ func Validate(c Component, options ...ValidateOption) error

+ type Aggregate struct

+ Source optional.Optional[dogma.AggregateMessageHandler]

+ func (h *Aggregate) HandlerType() HandlerType

+ func (h *Aggregate) Identity() *identitypb.Identity

+ func (h *Aggregate) Interface() dogma.AggregateMessageHandler

+ func (h *Aggregate) IsDisabled() bool

+ func (h *Aggregate) RouteSet() RouteSet

+ func (h *Aggregate) String() string

+ type AmbiguouslyIdentifiedEntityError struct

+ Identities []*Identity

+ func (e AmbiguouslyIdentifiedEntityError) Error() string

+ type Application struct

+ HandlerComponents []Handler

+ Source optional.Optional[dogma.Application]

+ func (a *Application) HandlerByName(name string) (Handler, bool)

+ func (a *Application) Handlers() []Handler

+ func (a *Application) Identity() *identitypb.Identity

+ func (a *Application) Interface() dogma.Application

+ func (a *Application) RouteSet() RouteSet

+ func (a *Application) String() string

+ type Component interface

+ ComponentProperties func() *ComponentCommon

+ type ComponentCommon struct

+ IsPartial bool

+ IsSpeculative bool

+ func (p *ComponentCommon) ComponentProperties() *ComponentCommon

+ type ConfigurationUnavailableError struct

+ Description string

+ func (e ConfigurationUnavailableError) Error() string

+ type DescribeOption func(*describeOptions)

+ func WithValidationResult(err error) DescribeOption

+ type Disabled struct

+ type DuplicateRouteError struct

+ DuplicateRoutes []*Route

+ MessageTypeName string

+ RouteType RouteType

+ func (e DuplicateRouteError) Error() string

+ type Entity interface

+ EntityProperties func() *EntityCommon

+ Identity func() *identitypb.Identity

+ RouteSet func() RouteSet

+ type EntityCommon struct

+ IdentityComponents []*Identity

+ TypeName optional.Optional[string]

+ func (p *EntityCommon) EntityProperties() *EntityCommon

+ type Flag struct

+ Value optional.Optional[bool]

+ func (f *Flag[S]) String() string

+ type Handler interface

+ HandlerProperties func() *HandlerCommon

+ HandlerType func() HandlerType

+ IsDisabled func() bool

+ type HandlerCommon struct

+ DisabledFlags []*Flag[Disabled]

+ RouteComponents []*Route

+ func (p *HandlerCommon) HandlerProperties() *HandlerCommon

+ type HandlerType int

+ const AggregateHandlerType

+ const IntegrationHandlerType

+ const ProcessHandlerType

+ const ProjectionHandlerType

+ func (t HandlerType) RouteCapabilities() RouteCapabilities

+ func (t HandlerType) String() string

+ type Identity struct

+ Key optional.Optional[string]

+ Name optional.Optional[string]

+ func (i *Identity) String() string

+ type IdentityKeyConflictError struct

+ ConflictingKey string

+ Entities []Entity

+ func (e IdentityKeyConflictError) Error() string

+ type IdentityNameConflictError struct

+ ConflictingName string

+ Entities []Entity

+ func (e IdentityNameConflictError) Error() string

+ type Integration struct

+ Source optional.Optional[dogma.IntegrationMessageHandler]

+ func (h *Integration) HandlerType() HandlerType

+ func (h *Integration) Identity() *identitypb.Identity

+ func (h *Integration) Interface() dogma.IntegrationMessageHandler

+ func (h *Integration) IsDisabled() bool

+ func (h *Integration) RouteSet() RouteSet

+ func (h *Integration) String() string

+ type InvalidComponentError struct

+ Causes []error

+ Component Component

+ func (e InvalidComponentError) Error() string

+ func (e InvalidComponentError) Unwrap() []error

+ type InvalidIdentityKeyError struct

+ InvalidKey string

+ func (e InvalidIdentityKeyError) Error() string

+ type InvalidIdentityNameError struct

+ InvalidName string

+ func (e InvalidIdentityNameError) Error() string

+ type MessageKindMismatchError struct

+ MessageType message.Type

+ RouteType RouteType

+ func (e MessageKindMismatchError) Error() string

+ type MissingRouteTypeError struct

+ RouteType RouteType

+ func (e MissingRouteTypeError) Error() string

+ type PartialConfigurationError struct

+ func (e PartialConfigurationError) Error() string

+ type Process struct

+ Source optional.Optional[dogma.ProcessMessageHandler]

+ func (h *Process) HandlerType() HandlerType

+ func (h *Process) Identity() *identitypb.Identity

+ func (h *Process) Interface() dogma.ProcessMessageHandler

+ func (h *Process) IsDisabled() bool

+ func (h *Process) RouteSet() RouteSet

+ func (h *Process) String() string

+ type Projection struct

+ DeliveryPolicyComponents []*ProjectionDeliveryPolicy

+ Source optional.Optional[dogma.ProjectionMessageHandler]

+ func (h *Projection) DeliveryPolicy() dogma.ProjectionDeliveryPolicy

+ func (h *Projection) HandlerType() HandlerType

+ func (h *Projection) Identity() *identitypb.Identity

+ func (h *Projection) Interface() dogma.ProjectionMessageHandler

+ func (h *Projection) IsDisabled() bool

+ func (h *Projection) RouteSet() RouteSet

+ func (h *Projection) String() string

+ type ProjectionDeliveryPolicy struct

+ Broadcast struct{ ... }

+ DeliveryPolicyType optional.Optional[ProjectionDeliveryPolicyType]

+ func (p *ProjectionDeliveryPolicy) Interface() dogma.ProjectionDeliveryPolicy

+ func (p *ProjectionDeliveryPolicy) String() string

+ type ProjectionDeliveryPolicyType int

+ const BroadcastProjectionDeliveryPolicyType

+ const UnicastProjectionDeliveryPolicyType

+ func (t ProjectionDeliveryPolicyType) String() string

+ type Route struct

+ MessageType optional.Optional[message.Type]

+ MessageTypeName optional.Optional[string]

+ RouteType optional.Optional[RouteType]

+ func (r *Route) String() string

+ type RouteCapabilities struct

+ RouteTypes map[RouteType]RouteCapability

+ func (c RouteCapabilities) DirectionOf(k message.Kind) RouteDirection

+ type RouteCapability int

+ const RouteTypeAllowed

+ const RouteTypeDisallowed

+ const RouteTypeRequired

+ type RouteConflictError struct

+ ConflictingMessageTypeName string

+ ConflictingRouteType RouteType

+ Handlers []Handler

+ func (e RouteConflictError) Error() string

+ type RouteDirection int

+ const InboundDirection

+ const OutboundDirection

+ func (d RouteDirection) Has(x RouteDirection) bool

+ type RouteSet struct

+ func (s RouteSet) DirectionOf(t message.Type) RouteDirection

+ func (s RouteSet) Filter(filters ...RouteSetFilter) RouteSet

+ func (s RouteSet) HasMessageType(t message.Type) bool

+ func (s RouteSet) MessageTypes() map[message.Type]RouteDirection

+ func (s RouteSet) Routes() iter.Seq2[*Route, Handler]

+ type RouteSetFilter func(*routeSetFilters)

+ func FilterByMessageDirection(directions ...RouteDirection) RouteSetFilter

+ func FilterByMessageKind(kinds ...message.Kind) RouteSetFilter

+ func FilterByMessageType(kinds ...message.Kind) RouteSetFilter

+ func FilterByRouteDirection(directions ...RouteDirection) RouteSetFilter

+ func FilterByRouteType(types ...RouteType) RouteSetFilter

+ type RouteType int

+ const ExecutesCommandRouteType

+ const HandlesCommandRouteType

+ const HandlesEventRouteType

+ const RecordsEventRouteType

+ const SchedulesTimeoutRouteType

+ func (r RouteType) Direction() RouteDirection

+ func (r RouteType) MessageKind() message.Kind

+ func (r RouteType) String() string

+ type SpeculativeConfigurationError struct

+ func (e SpeculativeConfigurationError) Error() string

+ type Symbol interface

+ type UnidentifiedEntityError struct

+ func (e UnidentifiedEntityError) Error() string

+ type UnsupportedRouteTypeError struct

+ UnexpectedRoute *Route

+ func (e UnsupportedRouteTypeError) Error() string

+ type ValidateOption func(*validationOptions)

+ func ForExecution() ValidateOption

Oct 22, 2019

Changes in this version

type AggregateConfig

+ HandlerIdentity identity.Identity

+ func (c *AggregateConfig) Identity() identity.Identity

type ApplicationConfig

+ ApplicationIdentity identity.Identity

+ func (c *ApplicationConfig) Identity() identity.Identity

type Config

+ Identity func() identity.Identity

type IntegrationConfig

+ HandlerIdentity identity.Identity

+ func (c *IntegrationConfig) Identity() identity.Identity

type ProcessConfig

+ HandlerIdentity identity.Identity

+ func (c *ProcessConfig) Identity() identity.Identity

type ProjectionConfig

+ HandlerIdentity identity.Identity

+ func (c *ProjectionConfig) Identity() identity.Identity

Jul 31, 2019

Changes in this version

+ func IsValidKey(k string) bool

type AggregateConfig

+ HandlerKey string

+ func (c *AggregateConfig) Key() string

type ApplicationConfig

+ ApplicationKey string

+ HandlersByKey map[string]HandlerConfig

+ HandlersByName map[string]HandlerConfig

+ func (c *ApplicationConfig) Key() string

type Config

+ Key func() string

type IntegrationConfig

+ HandlerKey string

+ func (c *IntegrationConfig) Key() string

type ProcessConfig

+ HandlerKey string

+ func (c *ProcessConfig) Key() string

type ProjectionConfig

+ HandlerKey string

+ func (c *ProjectionConfig) Key() string

Feb 26, 2019

Changes in this version

+ func IsValidName(n string) bool

type AggregateConfig

+ func (c *AggregateConfig) ConsumedMessageTypes() map[message.Type]message.Role

+ func (c *AggregateConfig) ProducedMessageTypes() map[message.Type]message.Role

type ApplicationConfig

+ Consumers map[message.Type][]string

+ Producers map[message.Type][]string

+ Roles map[message.Type]message.Role

type HandlerConfig

+ ConsumedMessageTypes func() map[message.Type]message.Role

+ ProducedMessageTypes func() map[message.Type]message.Role

type IntegrationConfig

+ func (c *IntegrationConfig) ConsumedMessageTypes() map[message.Type]message.Role

+ func (c *IntegrationConfig) ProducedMessageTypes() map[message.Type]message.Role

type ProcessConfig

+ func (c *ProcessConfig) ConsumedMessageTypes() map[message.Type]message.Role

+ func (c *ProcessConfig) ProducedMessageTypes() map[message.Type]message.Role

type ProjectionConfig

+ func (c *ProjectionConfig) ConsumedMessageTypes() map[message.Type]message.Role

+ func (c *ProjectionConfig) ProducedMessageTypes() map[message.Type]message.Role

Feb 6, 2019

Changes in this version

+ type AggregateConfig struct

+ Handler dogma.AggregateMessageHandler

+ HandlerName string

+ MessageTypes message.TypeSet

+ func NewAggregateConfig(h dogma.AggregateMessageHandler) (*AggregateConfig, error)

+ func (c *AggregateConfig) Accept(ctx context.Context, v Visitor) error

+ func (c *AggregateConfig) CommandTypes() message.TypeSet

+ func (c *AggregateConfig) EventTypes() message.TypeSet

+ func (c *AggregateConfig) HandlerReflectType() reflect.Type

+ func (c *AggregateConfig) HandlerType() handler.Type

+ func (c *AggregateConfig) Name() string

+ type ApplicationConfig struct

+ Application dogma.Application

+ ApplicationName string

+ CommandRoutes map[message.Type]string

+ EventRoutes map[message.Type][]string

+ Handlers map[string]HandlerConfig

+ Routes map[message.Type][]string

+ func NewApplicationConfig(app dogma.Application) (*ApplicationConfig, error)

+ func (c *ApplicationConfig) Accept(ctx context.Context, v Visitor) error

+ func (c *ApplicationConfig) Name() string

+ type Config interface

+ Accept func(ctx context.Context, v Visitor) error

+ Name func() string

+ type Error string

+ func (e Error) Error() string

+ type FuncVisitor struct

+ AggregateConfig func(context.Context, *AggregateConfig) error

+ ApplicationConfig func(context.Context, *ApplicationConfig) error

+ IntegrationConfig func(context.Context, *IntegrationConfig) error

+ ProcessConfig func(context.Context, *ProcessConfig) error

+ ProjectionConfig func(context.Context, *ProjectionConfig) error

+ func (v *FuncVisitor) VisitAggregateConfig(ctx context.Context, cfg *AggregateConfig) error

+ func (v *FuncVisitor) VisitApplicationConfig(ctx context.Context, cfg *ApplicationConfig) error

+ func (v *FuncVisitor) VisitIntegrationConfig(ctx context.Context, cfg *IntegrationConfig) error

+ func (v *FuncVisitor) VisitProcessConfig(ctx context.Context, cfg *ProcessConfig) error

+ func (v *FuncVisitor) VisitProjectionConfig(ctx context.Context, cfg *ProjectionConfig) error

+ type HandlerConfig interface

+ CommandTypes func() message.TypeSet

+ EventTypes func() message.TypeSet

+ HandlerReflectType func() reflect.Type

+ HandlerType func() handler.Type

+ type IntegrationConfig struct

+ Handler dogma.IntegrationMessageHandler

+ HandlerName string

+ MessageTypes message.TypeSet

+ func NewIntegrationConfig(h dogma.IntegrationMessageHandler) (*IntegrationConfig, error)

+ func (c *IntegrationConfig) Accept(ctx context.Context, v Visitor) error

+ func (c *IntegrationConfig) CommandTypes() message.TypeSet

+ func (c *IntegrationConfig) EventTypes() message.TypeSet

+ func (c *IntegrationConfig) HandlerReflectType() reflect.Type

+ func (c *IntegrationConfig) HandlerType() handler.Type

+ func (c *IntegrationConfig) Name() string

+ type ProcessConfig struct

+ Handler dogma.ProcessMessageHandler

+ HandlerName string

+ MessageTypes message.TypeSet

+ func NewProcessConfig(h dogma.ProcessMessageHandler) (*ProcessConfig, error)

+ func (c *ProcessConfig) Accept(ctx context.Context, v Visitor) error

+ func (c *ProcessConfig) CommandTypes() message.TypeSet

+ func (c *ProcessConfig) EventTypes() message.TypeSet

+ func (c *ProcessConfig) HandlerReflectType() reflect.Type

+ func (c *ProcessConfig) HandlerType() handler.Type

+ func (c *ProcessConfig) Name() string

+ type ProjectionConfig struct

+ Handler dogma.ProjectionMessageHandler

+ HandlerName string

+ MessageTypes message.TypeSet

+ func NewProjectionConfig(h dogma.ProjectionMessageHandler) (*ProjectionConfig, error)

+ func (c *ProjectionConfig) Accept(ctx context.Context, v Visitor) error

+ func (c *ProjectionConfig) CommandTypes() message.TypeSet

+ func (c *ProjectionConfig) EventTypes() message.TypeSet

+ func (c *ProjectionConfig) HandlerReflectType() reflect.Type

+ func (c *ProjectionConfig) HandlerType() handler.Type

+ func (c *ProjectionConfig) Name() string

+ type Visitor interface

+ VisitAggregateConfig func(context.Context, *AggregateConfig) error

+ VisitApplicationConfig func(context.Context, *ApplicationConfig) error

+ VisitIntegrationConfig func(context.Context, *IntegrationConfig) error

+ VisitProcessConfig func(context.Context, *ProcessConfig) error

+ VisitProjectionConfig func(context.Context, *ProjectionConfig) error