grpc

Documentation

Index

• type Client
  • func NewClient(target string, opts ...grpc.DialOption) (*Client, error)
  • func NewClientWithContext(ctx context.Context, target string, opts ...grpc.DialOption) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) Run(ctx context.Context, options []string, input io.Reader, output io.Writer) error
• type Server
  • func NewServer(cmd runnable.Runnable, cfg *config.Config, opts ...grpc.ServerOption) *Server
  • func (s *Server) ListenAndServe() error
  • func (s *Server) Run(stream btrfaasgrpc.FunctionRunner_RunServer) error

Types

type Client

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

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

func NewClient

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

NewClient returns a new client instance

func NewClientWithContext

func NewClientWithContext(ctx context.Context, target string, opts ...grpc.DialOption) (*Client, error)

NewClientWithContext returns a new client instance

func (*Client) Close

func (c *Client) Close() error

Close closes the client connection

func (*Client) Run

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

Run implements the Runnable interface

type Server

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

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

func NewServer

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

NewServer returns a new server instance

func (*Server) ListenAndServe

func (s *Server) ListenAndServe() error

ListenAndServe start listening for requests

func (*Server) Run

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

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