grpc

package

v0.2.1 Latest Latest Go to latest Published: Nov 21, 2017 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Client is a gRPC client for the function runner interface implementing Runnable

func NewClient(target string, opts ...grpc.DialOption) (*Client, error)

NewClient returns a new client instance

func (c *Client) Run(ctx context.Context, options []string, input io.Reader, output io.Writer) error

Run implements the Runnable interface

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

Server is a gRPC server which serves function calls to a specific runnable

func NewServer(cmd runnable.Runnable, cfg *config.Config, opts ...grpc.ServerOption) *Server

NewServer returns a new server instance

func (s *Server) ListenAndServe() error

ListenAndServe start listening for requests

func (s *Server) Run(stream btrfaasgrpc.FunctionRunner_RunServer) (err error)

Run implements the server interface implied by the btrfaas protobuf service definition

Path	Synopsis
test
client command