components

Documentation

Index

• Variables
• type ComponentFactory
• type DefaultComponent
  • func NewDefaultComponent(ctx api.Context, scheme string) DefaultComponent
  • func (c *DefaultComponent) Context() api.Context
  • func (c *DefaultComponent) ID() string
  • func (c *DefaultComponent) Logger() *slog.Logger
  • func (c *DefaultComponent) Scheme() string
• type DefaultConsumer
  • func NewDefaultConsumer(endpoint api.Endpoint, target *actor.PID) DefaultConsumer
  • func (c *DefaultConsumer) Endpoint() api.Endpoint
  • func (c *DefaultConsumer) Logger() *slog.Logger
  • func (c *DefaultConsumer) Target() *actor.PID
• type DefaultEndpoint
  • func NewDefaultEndpoint(component api.Component) DefaultEndpoint
  • func (e *DefaultEndpoint) Component() api.Component
  • func (e *DefaultEndpoint) Context() api.Context
  • func (e *DefaultEndpoint) ID() string
  • func (e *DefaultEndpoint) Logger() *slog.Logger
• type DefaultProducer
  • func NewDefaultProducer(endpoint api.Endpoint) DefaultProducer
  • func (p *DefaultProducer) Endpoint() api.Endpoint
  • func (p *DefaultProducer) Logger() *slog.Logger

Variables

var Factories = make(map[string]ComponentFactory)

Types

type ComponentFactory

type ComponentFactory func(api.Context, map[string]interface{}) (api.Component, error)

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