forwarder

package

v0.3.3 Latest Latest Go to latest Published: Dec 8, 2017 License: MIT, MIT Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func Forward(ctx context.Context, options *Options) (err error)

Forward forwards a function call

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

HTTPRunnable is a Runnable which does an HTTP request for its work (to be used with openfaas)

func NewHTTPRunnable(url string) *HTTPRunnable

NewHTTPRunnable returns a new http runnable for a given host port combination

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

Run implements the runnable interface

type HostConfig struct {
	Transport   TransportProtocol
	Host        string
	Port        uint16
	CallOptions []string
}

HostConfig specifies one function service

type Options struct {
	Hosts  []*HostConfig
	Input  io.Reader
	Output io.Writer
}

Options are the options for the forwarding

type TransportProtocol int

TransportProtocol is the type of the transport, currently only GRPC is supported

const (
	// GRPC represents a gRPC transport layer
	GRPC TransportProtocol = iota
	// HTTP represents a http transport layer
	HTTP
)