eventchannel

Documentation

Overview

Package eventchannel contains functionality for sending any protobuf message on a socketpair.

The wire format is a uvarint length followed by a binary protobuf.Any message.

Index

• func AddEmitter(e Emitter)
• func Emit(msg proto.Message) error
• type Emitter
  • func DebugEmitterFrom(inner Emitter) Emitter
  • func SocketEmitter(fd int) (Emitter, error)

Functions

func AddEmitter

func AddEmitter(e Emitter)

AddEmitter adds a new emitter.

func Emit

func Emit(msg proto.Message) error

Emit emits a message using all added emitters.

Types

type Emitter

type Emitter interface {
	// Emit writes a single eventchannel message to an emitter. Emit should
	// return hangup = true to indicate an emitter has "hung up" and no further
	// messages should be directed to it.
	Emit(msg proto.Message) (hangup bool, err error)

	// Close closes this emitter. Emit cannot be used after Close is called.
	Close() error
}

Emitter emits a proto message.

func DebugEmitterFrom

func DebugEmitterFrom(inner Emitter) Emitter

DebugEmitterFrom creates a new event channel emitter by wraping an existing raw emitter.

func SocketEmitter

func SocketEmitter(fd int) (Emitter, error)

SocketEmitter creates a new event channel based on the given fd.

SocketEmitter takes ownership of fd.