observer

Documentation

Index

• type Event
• type Observer
  • func NewObserver[T comparable]() *Observer[T]
  • func (o *Observer[T]) Emit(e *Event[T]) error
  • func (o *Observer[T]) Subscribe(t T, p Processor[T]) SourceID
  • func (o *Observer[T]) Unsubscribe(s SourceID)
• type Processor
• type SourceID

Types

type Event

type Event[T comparable] struct {
	Topic   T
	Payload protoreflect.ProtoMessage
}

type Observer

type Observer[T comparable] struct {
	// contains filtered or unexported fields
}

func NewObserver

func NewObserver[T comparable]() *Observer[T]

NewObserver ...

func (*Observer[T]) Emit

func (o *Observer[T]) Emit(e *Event[T]) error

Emit ...

func (*Observer[T]) Subscribe

func (o *Observer[T]) Subscribe(t T, p Processor[T]) SourceID

Subscribe ...

func (*Observer[T]) Unsubscribe

func (o *Observer[T]) Unsubscribe(s SourceID)

Unsubscribe ...

type Processor

type Processor[T comparable] func(e *Event[T]) error

type SourceID

type SourceID int64