Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Catalog ¶
type Catalog struct {
// contains filtered or unexported fields
}
func NewCatalog ¶
func (*Catalog) GetDeliveryClass ¶
func (c *Catalog) GetDeliveryClass(eventType string) (DeliveryClass, bool)
func (*Catalog) GetTopicForEvent ¶
func (*Catalog) IsDurableOutbox ¶
func (*Catalog) IsEventRegistered ¶
type Config ¶
type Config struct {
Version string `yaml:"version"`
Topics map[string]TopicConfig `yaml:"topics"`
Events map[string]EventConfig `yaml:"events"`
}
func LoadWithOptions ¶
func LoadWithOptions(path string, opts ValidateOptions) (*Config, error)
func ParseWithOptions ¶
func ParseWithOptions(data []byte, opts ValidateOptions) (*Config, error)
func (*Config) GetDeliveryClass ¶
func (c *Config) GetDeliveryClass(eventType string) (DeliveryClass, bool)
func (*Config) ValidateWithOptions ¶
func (c *Config) ValidateWithOptions(opts ValidateOptions) error
type DeliveryClass ¶
type DeliveryClass string
const ( DeliveryClassBestEffort DeliveryClass = "best_effort" DeliveryClassDurableOutbox DeliveryClass = "durable_outbox" )
func (DeliveryClass) Valid ¶
func (c DeliveryClass) Valid() bool
type DeliveryClassResolver ¶
type DeliveryClassResolver interface {
GetDeliveryClass(eventType string) (DeliveryClass, bool)
}
type EventConfig ¶
type TopicConfig ¶
type TopicResolver ¶
type ValidateOptions ¶
type ValidateOptions struct {
RequireHandler bool
}
ValidateOptions controls which catalog rules are enforced by shared callers.
Click to show internal directories.
Click to hide internal directories.