ordering

Documentation

Index

• func EventBuffer(process func(*inter.Event), drop func(*inter.Event, error), ...) (push func(*inter.Event))

Functions

func EventBuffer

func EventBuffer(
	process func(*inter.Event),
	drop func(*inter.Event, error),
	exists func(hash.Event) *inter.Event) (
	push func(*inter.Event))

EventBuffer validates, bufferizes and drops() or processes() pushed() event if all their parents exists(). TODO: drop incomplete events by timeout.