rpc

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 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

Functions

func MakeReaderChan

func MakeReaderChan(r io.Reader) <-chan []byte

func MakeSocketReaderChan

func MakeSocketReaderChan(conn *websocket.Conn) (readerChan chan []byte)

func MakeSocketWriterChan

func MakeSocketWriterChan(conn *websocket.Conn) (writerChan chan []byte)

func MakeWriterChan

func MakeWriterChan(r io.Writer) chan<- []byte

Types

type BakaRpc

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

func CreateBakaRpc

func CreateBakaRpc(chanIn <-chan []byte, chanOut chan<- []byte) *BakaRpc

func (*BakaRpc) AddChannels

func (rpc *BakaRpc) AddChannels(chanIn <-chan []byte, chanOut chan<- []byte) (uuid *UUID.UUID)

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 (rpc *BakaRpc) CallMethodWithNone(channelUuid *UUID.UUID, methodName string) (res *json.RawMessage, resErr *errors.RPCError)

func (*BakaRpc) DeregisterMethod

func (rpc *BakaRpc) DeregisterMethod(methodName string)

func (*BakaRpc) HandleDisconnect

func (rpc *BakaRpc) HandleDisconnect(handle func(uuid *UUID.UUID))

func (*BakaRpc) NotifyMethod

func (rpc *BakaRpc) NotifyMethod(channelUuid *UUID.UUID, methodName string, params *parameters.Parameters)

func (*BakaRpc) NotifyMethodByName

func (rpc *BakaRpc) NotifyMethodByName(channelUuid *UUID.UUID, methodName string, params ...parameters.Param)

func (*BakaRpc) NotifyMethodByPosition

func (rpc *BakaRpc) NotifyMethodByPosition(channelUuid *UUID.UUID, methodName string, params ...parameters.Param)

func (*BakaRpc) NotifyMethodWithNone

func (rpc *BakaRpc) NotifyMethodWithNone(channelUuid *UUID.UUID, methodName string)

func (*BakaRpc) RegisterMethod

func (rpc *BakaRpc) RegisterMethod(methodName string, methodParams []parameters.Param, methodFunc MethodFunc)

func (*BakaRpc) RemoveChannels

func (rpc *BakaRpc) RemoveChannels(uuid *UUID.UUID)

func (*BakaRpc) UseChannels

func (rpc *BakaRpc) UseChannels(chanIn <-chan []byte, chanOut chan<- []byte)

type MethodFunc

type MethodFunc func(params map[string]parameters.Param) (returnMessage json.RawMessage, err error)