grpc

package

v0.3.3 Latest Latest Go to latest Published: Dec 8, 2017 License: MIT, MIT Imports: 19 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 to the fgateway

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

NewClient creates a new client instance

func (c *Client) Close() error

Close closes the client connection

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

Run nearly implements the runnable interface, except that it supports specifying chains of functions instead of a single function

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

Server represents a gRPC based function dispatcher

func NewServer(addr string, defaultPort uint16, opts ...grpc.ServerOption) *Server

NewServer creates a gRPC based function dispatcher

func (s *Server) ListenAndServe() error

ListenAndServe starts listening for connections

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

Run implements the gRPC interface