Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Factories = make(map[string]ComponentFactory)
Functions ¶
This section is empty.
Types ¶
type ComponentFactory ¶
type DefaultComponent ¶
type DefaultComponent struct {
// contains filtered or unexported fields
}
func NewDefaultComponent ¶
func NewDefaultComponent(ctx api.Context, scheme string) DefaultComponent
func (*DefaultComponent) Context ¶
func (c *DefaultComponent) Context() api.Context
func (*DefaultComponent) ID ¶
func (c *DefaultComponent) ID() string
func (*DefaultComponent) Logger ¶
func (c *DefaultComponent) Logger() *slog.Logger
func (*DefaultComponent) Scheme ¶
func (c *DefaultComponent) Scheme() string
type DefaultConsumer ¶
type DefaultConsumer struct {
processors.DefaultVerticle
// contains filtered or unexported fields
}
func NewDefaultConsumer ¶
func NewDefaultConsumer(endpoint api.Endpoint, target *actor.PID) DefaultConsumer
func (*DefaultConsumer) Endpoint ¶
func (c *DefaultConsumer) Endpoint() api.Endpoint
func (*DefaultConsumer) Logger ¶
func (c *DefaultConsumer) Logger() *slog.Logger
func (*DefaultConsumer) Target ¶
func (c *DefaultConsumer) Target() *actor.PID
type DefaultEndpoint ¶
type DefaultEndpoint struct {
// contains filtered or unexported fields
}
func NewDefaultEndpoint ¶
func NewDefaultEndpoint(component api.Component) DefaultEndpoint
func (*DefaultEndpoint) Component ¶
func (e *DefaultEndpoint) Component() api.Component
func (*DefaultEndpoint) Context ¶
func (e *DefaultEndpoint) Context() api.Context
func (*DefaultEndpoint) ID ¶
func (e *DefaultEndpoint) ID() string
func (*DefaultEndpoint) Logger ¶
func (e *DefaultEndpoint) Logger() *slog.Logger
type DefaultProducer ¶
type DefaultProducer struct {
processors.DefaultVerticle
// contains filtered or unexported fields
}
func NewDefaultProducer ¶
func NewDefaultProducer(endpoint api.Endpoint) DefaultProducer
func (*DefaultProducer) Endpoint ¶
func (p *DefaultProducer) Endpoint() api.Endpoint
func (*DefaultProducer) Logger ¶
func (p *DefaultProducer) Logger() *slog.Logger
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.