Versions in this module Expand all Collapse all v0 v0.1.1 May 20, 2016 v0.1.0 May 12, 2016 Changes in this version + const PackageName + var OwnEnvironment = os.Getenv("LEVEROS_ENVIRONMENT") + var OwnInstanceID = os.Getenv("LEVEROS_INSTANCE_ID") + var OwnService = os.Getenv("LEVEROS_SERVICE") + func IsChanMethod(name string) bool + type BytesError interface + GetBytes func() []byte + type Client struct + ForceHost string + func NewClient() (*Client, error) + func (client *Client) InvokeChanURL(leverURLStr string, args ...interface{}) (stream Stream, err error) + func (client *Client) InvokeURL(replyObj interface{}, leverURLStr string, args ...interface{}) (err error) + func (client *Client) Resource(env string, service string, resource string) *Endpoint + func (client *Client) Service(env string, service string) *Endpoint + type ClientStream struct + func (stream *ClientStream) Close() error + func (stream *ClientStream) Context() context.Context + func (stream *ClientStream) Receive(msgObj interface{}) error + func (stream *ClientStream) Send(msg interface{}) error + type Endpoint struct + func (endpoint *Endpoint) Invoke(replyObj interface{}, method string, args ...interface{}) (err error) + func (endpoint *Endpoint) InvokeChan(method string, args ...interface{}) (stream Stream, err error) + type RemoteByteError struct + Err []byte + func (err *RemoteByteError) Error() string + func (err *RemoteByteError) GetBytes() []byte + type RemoteError struct + Err interface{} + func (err *RemoteError) Error() string + type Server struct + func NewServer() (server *Server, err error) + func (server *Server) HandleRPC(ctx context.Context, rpc *core.RPC) (reply *core.RPCReply, err error) + func (server *Server) HandleStreamingRPC(grpcStream core.LeverRPC_HandleStreamingRPCServer) error + func (server *Server) RegisterHandler(name string, handler interface{}) error + func (server *Server) RegisterHandlerObject(obj interface{}) error + func (server *Server) Serve() error + func (server *Server) Stop() + type ServerStream struct + func (stream *ServerStream) Close() error + func (stream *ServerStream) Context() context.Context + func (stream *ServerStream) Receive(msgObj interface{}) error + func (stream *ServerStream) Send(msg interface{}) error + type Stream interface + Close func() error + Context func() context.Context + Receive func(msgObj interface{}) error + Send func(msg interface{}) error