io

Documentation

Index

• Variables
• type Bus
• type StreamReader
• type StreamWriter

Variables

var (
	ErrClosed = errors.New("connection closed")
)

Types

type Bus

type Bus interface {
	Push(m *types.Message) // should be goroutine safe
	Pull() <-chan *types.Message
	Lock()   // turn off the message supply
	Unlock() // turn on the message supply
}

type StreamReader

type StreamReader interface {
	Read() (*types.Message, error)
}

type StreamWriter

type StreamWriter interface {
	Write(*types.Message) error
}