ammeter/Bus/api.go

package bus

import (
	"time"
)

//Channel Dispatch not in event because event and dispatch handler not same one.

type ChnDispResult int

const (
	DispatchSingle ChnDispResult = -1 + iota
	DispatchNone
	DispatchMulti
)

//Dispatch maybe a protocol object
type IBusEvent interface {
	OnAttach(chn IChannel)
	OnDetach(chn IChannel)
	ChannelDispatch(stream []byte, argEvt interface{}) ChnDispResult
}

type IChannel interface {
	ID() string
	GetChan(id int) chan interface{}
	SetTimeout(time.Duration)
	SetEvent(evt IBusEvent, evtArgs interface{})
	GetEvent() IBusEvent
	GetBus() IBus
}

type IBus interface {
	Init() error
	Uninit()
	MountChannel(chnID interface{}, router []chan interface{}) IChannel
	FreeChannel(chn IChannel) error
	ResetChannel(chn IChannel)
	ScanChannel(stream []byte, conn int) IChannel
	Send(chn IChannel, buff interface{}) (int, error)
	Recive(chn IChannel, buff interface{}) (int, error)
	ApplyPatch(ptchName string, param ...interface{})
	TimeStamp() int64
}