dispatcher

package

v1.2.0 Latest Latest Go to latest Published: Aug 18, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Dispatcher is Event Dispatcher

func NewDispatcher(opts Options) *Dispatcher

func (d *Dispatcher) Dispatch(ctx context.Context, events []*entities.Event) ([]*entities.Attempt, error)

func (d *Dispatcher) DispatchEndpoint(ctx context.Context, event *entities.Event, endpoints []*entities.Endpoint) ([]*entities.Attempt, error)

func (d *Dispatcher) WarmUp()

type Options struct {
	DB       *db.DB
	Metrics  *metrics.Metrics
	Registry *Registry
	EventBus eventbus.EventBus
}

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

func NewRegistration(endpoints []*entities.Endpoint) *Registration

func (r *Registration) LookUp(event *entities.Event) []*entities.Endpoint

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

func NewRegistry(db *db.DB) *Registry

func (r *Registry) LookUp(ctx context.Context, event *entities.Event) ([]*entities.Endpoint, error)

func (r *Registry) Unregister(wid string)

func (r *Registry) Warmup() error