Versions in this module Expand all Collapse all v0 v0.1.0 Feb 25, 2023 Changes in this version + 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 struct + func CreateBakaRpc(chanIn <-chan []byte, chanOut chan<- []byte) *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 func(params map[string]parameters.Param) (returnMessage json.RawMessage, err error)