rpc

type Call struct {
	Topic         string      // The MQTT topic this call will be sent to
	ServiceMethod string      // The name of the service and method to call.
	Args          interface{} // The argument to the function (*struct).
	Reply         interface{} // The reply from the function (*struct).
	Error         error       // After completion, the error status.
	Done          chan *Call  // Strobes when call is complete.
	ID            uint32      // Used to map responses
}

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

type ClientCodec interface {
	EncodeClientRequest(call *Call) ([]byte, error)
	DecodeIdAndError(msg []byte) (*uint32, error)
	DecodeClientResponse(msg []byte, reply interface{}) error
}

type Codec interface {
	NewRequest(topic string, payload []byte) (CodecRequest, error)
	SendNotification(c bus.Bus, topic string, payload ...interface{}) error
}

type CodecRequest interface {
	// Reads the request and returns the RPC method name.
	Method() (string, error)
	// Reads the request filling the RPC method args.
	ReadRequest(interface{}) error
	// Writes the response using the RPC method reply.
	WriteResponse(c bus.Bus, response interface{})
	// Writes an error produced by the server.
	WriteError(c bus.Bus, err error)
}

type ExportedService struct {
	Methods []string
	// contains filtered or unexported fields
}

type Message struct {
	Payload []byte
	Topic   string
}

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