Documentation ¶
Index ¶
- func MakeReaderChan(r io.Reader) <-chan []byte
- func MakeSocketReaderChan(conn *websocket.Conn) (readerChan chan []byte)
- func MakeSocketWriterChan(conn *websocket.Conn) (writerChan chan []byte)
- func MakeWriterChan(r io.Writer) chan<- []byte
- type BakaRpc
- func (rpc *BakaRpc) AddChannels(chanIn <-chan []byte, chanOut chan<- []byte) (uuid *UUID.UUID)
- func (rpc *BakaRpc) CallMethod(channelUuid *UUID.UUID, methodName string, params *parameters.Parameters) (res *json.RawMessage, resErr *errors.RPCError)
- func (rpc *BakaRpc) CallMethodByName(channelUuid *UUID.UUID, methodName string, params ...parameters.Param) (res *json.RawMessage, resErr *errors.RPCError)
- func (rpc *BakaRpc) CallMethodByPosition(channelUuid *UUID.UUID, methodName string, params ...parameters.Param) (res *json.RawMessage, resErr *errors.RPCError)
- func (rpc *BakaRpc) CallMethodWithNone(channelUuid *UUID.UUID, methodName string) (res *json.RawMessage, resErr *errors.RPCError)
- func (rpc *BakaRpc) DeregisterMethod(methodName string)
- func (rpc *BakaRpc) HandleDisconnect(handle func(uuid *UUID.UUID))
- func (rpc *BakaRpc) NotifyMethod(channelUuid *UUID.UUID, methodName string, params *parameters.Parameters)
- func (rpc *BakaRpc) NotifyMethodByName(channelUuid *UUID.UUID, methodName string, params ...parameters.Param)
- func (rpc *BakaRpc) NotifyMethodByPosition(channelUuid *UUID.UUID, methodName string, params ...parameters.Param)
- func (rpc *BakaRpc) NotifyMethodWithNone(channelUuid *UUID.UUID, methodName string)
- func (rpc *BakaRpc) RegisterMethod(methodName string, methodParams []parameters.Param, methodFunc MethodFunc)
- func (rpc *BakaRpc) RemoveChannels(uuid *UUID.UUID)
- func (rpc *BakaRpc) UseChannels(chanIn <-chan []byte, chanOut chan<- []byte)
- type MethodFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeReaderChan ¶
func MakeSocketReaderChan ¶
func MakeSocketWriterChan ¶
func MakeWriterChan ¶
Types ¶
type BakaRpc ¶
type BakaRpc struct {
// contains filtered or unexported fields
}
func CreateBakaRpc ¶
func (*BakaRpc) AddChannels ¶
func (*BakaRpc) CallMethod ¶
func (rpc *BakaRpc) CallMethod(channelUuid *UUID.UUID, methodName string, params *parameters.Parameters) (res *json.RawMessage, resErr *errors.RPCError)
func (*BakaRpc) CallMethodByName ¶
func (rpc *BakaRpc) CallMethodByName(channelUuid *UUID.UUID, methodName string, params ...parameters.Param) (res *json.RawMessage, resErr *errors.RPCError)
func (*BakaRpc) CallMethodByPosition ¶
func (rpc *BakaRpc) CallMethodByPosition(channelUuid *UUID.UUID, methodName string, params ...parameters.Param) (res *json.RawMessage, resErr *errors.RPCError)
func (*BakaRpc) CallMethodWithNone ¶
func (*BakaRpc) DeregisterMethod ¶
func (*BakaRpc) HandleDisconnect ¶
func (*BakaRpc) NotifyMethod ¶
func (rpc *BakaRpc) NotifyMethod(channelUuid *UUID.UUID, methodName string, params *parameters.Parameters)
func (*BakaRpc) NotifyMethodByName ¶
func (*BakaRpc) NotifyMethodByPosition ¶
func (*BakaRpc) NotifyMethodWithNone ¶
func (*BakaRpc) RegisterMethod ¶
func (rpc *BakaRpc) RegisterMethod(methodName string, methodParams []parameters.Param, methodFunc MethodFunc)
func (*BakaRpc) RemoveChannels ¶
func (*BakaRpc) UseChannels ¶
type MethodFunc ¶
type MethodFunc func(params map[string]parameters.Param) (returnMessage json.RawMessage, err error)
Click to show internal directories.
Click to hide internal directories.