event

Documentation

Index

• type Emitter
  • func NewEmitter[T any]() *Emitter[T]
  • func (emitter *Emitter[T]) Emit(data T)
  • func (emitter *Emitter[T]) EmitAsync(data T)
  • func (emitter *Emitter[T]) EmitAsyncTTL(data T, hash string, ttl time.Duration)
  • func (emitter *Emitter[T]) EmitTTL(data T, hash string, ttl time.Duration)
  • func (emitter *Emitter[T]) Register(handler func(event Event, data T)) Event
• type Event

Types

type Emitter

type Emitter[T any] struct {
	// contains filtered or unexported fields
}

func NewEmitter

func NewEmitter[T any]() *Emitter[T]

func (*Emitter[T]) Emit

func (emitter *Emitter[T]) Emit(data T)

func (*Emitter[T]) EmitAsync

func (emitter *Emitter[T]) EmitAsync(data T)

func (*Emitter[T]) EmitAsyncTTL

func (emitter *Emitter[T]) EmitAsyncTTL(data T, hash string, ttl time.Duration)

func (*Emitter[T]) EmitTTL

func (emitter *Emitter[T]) EmitTTL(data T, hash string, ttl time.Duration)

func (*Emitter[T]) Register

func (emitter *Emitter[T]) Register(handler func(event Event, data T)) Event

type Event

type Event interface {
	Close()
}