event

package

v1.4.0 Latest Latest Go to latest Published: Feb 5, 2026 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/precision-soft/melody

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func EventDispatcherMustFromContainer(serviceContainer containercontract.Container) eventcontract.EventDispatcher
func EventDispatcherMustFromResolver(resolver containercontract.Resolver) eventcontract.EventDispatcher
type Event
type EventDispatcher
- func NewEventDispatcher(clock clockcontract.Clock) *EventDispatcher
type EventDispatcherAdapter
- func NewEventDispatcherAdapter(eventDispatcher eventcontract.EventDispatcher, clock clockcontract.Clock) *EventDispatcherAdapter
type SubscribedEvent
- func NewSubscribedEvent(listener eventcontract.EventListener, priority int) *SubscribedEvent
- func (instance *SubscribedEvent) Listener() eventcontract.EventListener
- func (instance *SubscribedEvent) Priority() int

Constants ¶

View Source

const (
	ServiceEventDispatcher = "service.event.dispatcher"
)

Variables ¶

This section is empty.

Functions ¶

func EventDispatcherMustFromContainer ¶

func EventDispatcherMustFromContainer(serviceContainer containercontract.Container) eventcontract.EventDispatcher

func EventDispatcherMustFromResolver ¶

func EventDispatcherMustFromResolver(resolver containercontract.Resolver) eventcontract.EventDispatcher

Types ¶

type Event ¶

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

func NewEvent ¶

func NewEvent(
	name string,
	payload any,
	clockInstance clockcontract.Clock,
) *Event

func NewEventFromEvent ¶

func NewEventFromEvent(event eventcontract.Event) *Event

func NewEventWithTimestamp ¶

func NewEventWithTimestamp(name string, payload any, timestamp time.Time) *Event

func (*Event) IsPropagationStopped ¶

func (instance *Event) IsPropagationStopped() bool

func (*Event) Name ¶

func (instance *Event) Name() string

func (*Event) Payload ¶

func (instance *Event) Payload() any

func (*Event) StopPropagation ¶

func (instance *Event) StopPropagation()

func (*Event) Timestamp ¶

func (instance *Event) Timestamp() time.Time

type EventDispatcher ¶

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

func NewEventDispatcher ¶

func NewEventDispatcher(clock clockcontract.Clock) *EventDispatcher

func (*EventDispatcher) AddListener ¶

func (instance *EventDispatcher) AddListener(
	eventName string,
	listener eventcontract.EventListener,
	priority int,
) eventcontract.ListenerRegistration

func (*EventDispatcher) AddSubscriber ¶

func (instance *EventDispatcher) AddSubscriber(subscriber eventcontract.EventSubscriber)

func (*EventDispatcher) Dispatch ¶

func (instance *EventDispatcher) Dispatch(runtimeInstance runtimecontract.Runtime, event eventcontract.Event) (eventcontract.Event, error)

func (*EventDispatcher) DispatchName ¶

func (instance *EventDispatcher) DispatchName(runtimeInstance runtimecontract.Runtime, eventName string, payload any) (eventcontract.Event, error)

func (*EventDispatcher) RegisteredEvents ¶

func (instance *EventDispatcher) RegisteredEvents() []eventcontract.RegisteredEvent

func (*EventDispatcher) RemoveListener ¶

func (instance *EventDispatcher) RemoveListener(registration eventcontract.ListenerRegistration) bool

func (*EventDispatcher) RemoveSubscriber ¶

func (instance *EventDispatcher) RemoveSubscriber(subscriber eventcontract.EventSubscriber) int

type EventDispatcherAdapter ¶

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

func NewEventDispatcherAdapter ¶

func NewEventDispatcherAdapter(
	eventDispatcher eventcontract.EventDispatcher,
	clock clockcontract.Clock,
) *EventDispatcherAdapter

func (*EventDispatcherAdapter) AddListener ¶

func (instance *EventDispatcherAdapter) AddListener(eventName string, listener eventcontract.EventListener, priority int) eventcontract.ListenerRegistration

func (*EventDispatcherAdapter) AddSubscriber ¶

func (instance *EventDispatcherAdapter) AddSubscriber(subscriber eventcontract.EventSubscriber)

func (*EventDispatcherAdapter) Dispatch ¶

func (instance *EventDispatcherAdapter) Dispatch(runtimeInstance runtimecontract.Runtime, eventValue eventcontract.Event) (eventcontract.Event, error)

func (*EventDispatcherAdapter) DispatchName ¶

func (instance *EventDispatcherAdapter) DispatchName(runtimeInstance runtimecontract.Runtime, eventName string, payload any) (eventcontract.Event, error)

func (*EventDispatcherAdapter) RegisteredEvents ¶

func (instance *EventDispatcherAdapter) RegisteredEvents() []eventcontract.RegisteredEvent

func (*EventDispatcherAdapter) RemoveListener ¶

func (instance *EventDispatcherAdapter) RemoveListener(registration eventcontract.ListenerRegistration) bool

func (*EventDispatcherAdapter) RemoveSubscriber ¶

func (instance *EventDispatcherAdapter) RemoveSubscriber(subscriber eventcontract.EventSubscriber) int

type SubscribedEvent ¶

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

func NewSubscribedEvent ¶

func NewSubscribedEvent(
	listener eventcontract.EventListener,
	priority int,
) *SubscribedEvent

func (*SubscribedEvent) Listener ¶

func (instance *SubscribedEvent) Listener() eventcontract.EventListener

func (*SubscribedEvent) Priority ¶

func (instance *SubscribedEvent) Priority() int

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
contract

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL