inbound

Documentation

Index

• func Register[Options any](registry *Registry, outboundType string, constructor ConstructorFunc[Options])
• type Adapter
  • func NewAdapter(inboundType string, inboundTag string) Adapter
  • func (a *Adapter) Tag() string
  • func (a *Adapter) Type() string
• type ConstructorFunc
• type Manager
  • func NewManager(logger log.ContextLogger, registry adapter.InboundRegistry) *Manager
  • func (m *Manager) Close() error
  • func (m *Manager) Create(ctx context.Context, router adapter.Router, logger log.ContextLogger, ...) error
  • func (m *Manager) Get(tag string) (adapter.Inbound, bool)
  • func (m *Manager) Inbounds() []adapter.Inbound
  • func (m *Manager) Remove(tag string) error
  • func (m *Manager) Start(stage adapter.StartStage) error
• type Registry
  • func NewRegistry() *Registry
  • func (m *Registry) Create(ctx context.Context, router adapter.Router, logger log.ContextLogger, ...) (adapter.Inbound, error)
  • func (m *Registry) CreateOptions(outboundType string) (any, bool)

Functions

func Register

func Register[Options any](registry *Registry, outboundType string, constructor ConstructorFunc[Options])

Types

type Adapter

type Adapter struct {
	// contains filtered or unexported fields
}

func NewAdapter

func NewAdapter(inboundType string, inboundTag string) Adapter

func (*Adapter) Tag

func (a *Adapter) Tag() string

func (*Adapter) Type

func (a *Adapter) Type() string

type ConstructorFunc

type ConstructorFunc[T any] func(ctx context.Context, router adapter.Router, logger log.ContextLogger, tag string, options T) (adapter.Inbound, error)

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager

func NewManager(logger log.ContextLogger, registry adapter.InboundRegistry) *Manager

func (*Manager) Close

func (m *Manager) Close() error

func (*Manager) Create

func (m *Manager) Create(ctx context.Context, router adapter.Router, logger log.ContextLogger, tag string, outboundType string, options any) error

func (*Manager) Get

func (m *Manager) Get(tag string) (adapter.Inbound, bool)

func (*Manager) Inbounds

func (m *Manager) Inbounds() []adapter.Inbound

func (*Manager) Remove

func (m *Manager) Remove(tag string) error

func (*Manager) Start

func (m *Manager) Start(stage adapter.StartStage) error

type Registry

type Registry struct {
	// contains filtered or unexported fields
}

func NewRegistry

func NewRegistry() *Registry

func (*Registry) Create

func (m *Registry) Create(ctx context.Context, router adapter.Router, logger log.ContextLogger, tag string, outboundType string, options any) (adapter.Inbound, error)

func (*Registry) CreateOptions

func (m *Registry) CreateOptions(outboundType string) (any, bool)