rpcd

type Call struct {
	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  // Receives *Call when Go is complete.
}

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

type ClientCodec interface {
	WriteRequest(*Request, interface{}) error
	ReadResponseHeader(*Response) error
	ReadResponseBody(interface{}) error

	Close() error
}

type DialOption interface {
	// contains filtered or unexported methods
}

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

type Request struct {
	ServiceMethod string // format: "Service.Method"
	Seq           uint64 // sequence number chosen by client
	// contains filtered or unexported fields
}

type RequestHeader struct {
	Id         uint64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Method     string `protobuf:"bytes,2,opt,name=method" json:"method,omitempty"`
	RpcdSource string `protobuf:"bytes,3,opt,name=rpcdSource" json:"rpcdSource,omitempty"`
	Checksum   uint32 `protobuf:"varint,5,opt,name=checksum" json:"checksum,omitempty"`
}

type Response struct {
	ServiceMethod string // echoes that of the Request
	Seq           uint64 // echoes that of the request
	Error         string // error, if any.
	// contains filtered or unexported fields
}

type ResponseHeader struct {
	Id       uint64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Error    string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	Method   string `protobuf:"bytes,2,opt,name=method" json:"method,omitempty"`
	Checksum uint32 `protobuf:"varint,5,opt,name=checksum" json:"checksum,omitempty"`
}

type ServerCodec interface {
	ReadRequestHeader(*Request) error
	ReadRequestBody(interface{}) error
	WriteResponse(*Response, interface{}) error

	// Close can be called multiple times and must be idempotent.
	Close() error
}

type ServerError string

type SugarCoatingRequest struct {
	RpcdSource string `protobuf:"bytes,1,opt,name=RpcdSource" json:"RpcdSource,omitempty"`
	Data       []byte `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
}

type SugarCoatingResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data" json:"data,omitempty"`
}

type SugarCoatingResponseInterface interface {
	GetSugarData() ([]byte, error)
}