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 Registry
  • func NewRegistry() *Registry
  • func (r *Registry) CreateInbound(ctx context.Context, router adapter.Router, logger log.ContextLogger, ...) (adapter.Inbound, error)
  • func (r *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 Registry

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

func NewRegistry

func NewRegistry() *Registry

func (*Registry) CreateInbound

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

func (*Registry) CreateOptions

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