mux

type Buffer interface {
	Write(b []byte) (int, error)
	Bytes() []byte
	Len() int
	Reset()
}

type BufferDecoder interface {
	Buffer
	Decoder
}

type BufferEncoder interface {
	Buffer
	Encoder
}

type Client interface {
	Conn
	Wait() error
}

type Config struct {
	// Timeout for receiving frames
	Timeout time.Duration

	// Lager is used to control the log destination
	Lager lager.Lager
}

type Conn interface {
	// Receive registers a receiver to receive t
	Receive(t uint8, r Receiver)
	// Send encodes a frame on conn using t and e
	Send(t uint8, e interface{}) error
	// Recv listens for frames and sends them to a receiver
	Recv()
	// Pool returns the pool used by the Conn
	Pool() Pool
	// Shutdown closes the gob connection
	Shutdown()
	// IsShutdown provides a way to listen for this connection to shutdown
	IsShutdown() chan struct{}
}

type Decoder interface {
	Decode(v interface{}) error
}

type Encoder interface {
	Encode(v interface{}) error
}

type Frame struct {
	Type uint8
	Data []byte
}

type Pool interface {
	NewBufferEncoder() BufferEncoder
	NewBufferDecoder() BufferDecoder
	NewEncoder(w io.Writer) Encoder
	NewDecoder(r io.Reader) Decoder
	NewReceiver(ch interface{}) Receiver
	NewClient(conn net.Conn, config *Config) (Client, error)
	NewServer(conn net.Conn, config *Config) (Server, error)
}

type Receiver interface {
	Receive(b []byte) error
	Close() error
}

type Server interface {
	Conn
	Done(err error)
}

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

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

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