Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( WireTimeoutError = fmt.Errorf("Wire timeout") NextHopUnreachableError = fmt.Errorf("Next hop unreachable") )
Functions ¶
func RegisterNewEngineFunc ¶
func RegisterNewEngineFunc(name string, fn NewEngineFunc)
Types ¶
type Descriptor ¶
type Engine ¶
type Engine interface { Wire(dst, src *Descriptor) (*Descriptor, error) OnWire(handler WireHandler) Close() error }
type NewEngineFunc ¶
type NewEngineFunc func(...NewEngineOption) (Engine, error)
type NewEngineOption ¶
func WithID ¶
func WithID(id string) NewEngineOption
func WithLogger ¶
func WithLogger(logger logrus.FieldLogger) NewEngineOption
type WireHandler ¶
type WireHandler func(*Descriptor) (*Descriptor, error)
Click to show internal directories.
Click to hide internal directories.