processing

Documentation

Index

• type Dispatcher
  • func (d *Dispatcher) Handle(e resource.Event)
• type DispatcherBuilder
  • func NewDispatcherBuilder() *DispatcherBuilder
  • func (d *DispatcherBuilder) Add(t resource.Collection, h Handler)
  • func (d *DispatcherBuilder) Build() *Dispatcher
• type Handler
  • func HandlerFromFn(fn func(e resource.Event)) Handler
• type Listener
  • func ListenerFromFn(fn func(c resource.Collection)) Listener

Types

type Dispatcher

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

Dispatcher is a Handler that can dispatch events to other Handlers, based on Collection.

func (*Dispatcher) Handle

func (d *Dispatcher) Handle(e resource.Event)

Handle implements Handler

type DispatcherBuilder

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

DispatcherBuilder builds Dispatchers

func NewDispatcherBuilder

func NewDispatcherBuilder() *DispatcherBuilder

NewDispatcherBuilder returns a new dispatcher dispatcher

func (*DispatcherBuilder) Add

func (d *DispatcherBuilder) Add(t resource.Collection, h Handler)

Add a new handler for the given Collection

func (*DispatcherBuilder) Build

func (d *DispatcherBuilder) Build() *Dispatcher

Build a Dispatcher

type Handler

type Handler interface {
	Handle(e resource.Event)
}

Handler handles an incoming resource event.

func HandlerFromFn

func HandlerFromFn(fn func(e resource.Event)) Handler

HandlerFromFn returns a new Handler, based on the Handler function.

type Listener

type Listener interface {
	CollectionChanged(c resource.Collection)
}

Listener gets notified when resource of a given collection has changed.

func ListenerFromFn

func ListenerFromFn(fn func(c resource.Collection)) Listener

ListenerFromFn creates a listener based on the given function