proxies

Documentation

Index

• Variables
• func NewProxyHandler(manager clusters.ClusterEndpointsManager, dialer transports.Dialer) transports.MuxHandler
• type Config
• type Option
  • func Handler(handler transports.MuxHandler) Option
  • func Middleware(middleware transports.Middleware) Option
  • func Transport(transport transports.Transport) Option
• type Options
• type Proxy
  • func New(options ...Option) (p Proxy, err error)
• type ProxyOptions
• type Response

Variables

var (
	ErrDeviceId               = errors.NotAcceptable("fns: X-Fns-Device-Id is required")
	ErrInvalidPath            = errors.Warning("fns: invalid path")
	ErrInvalidRequestVersions = errors.Warning("fns: invalid request versions")
)

Functions

func NewProxyHandler

func NewProxyHandler(manager clusters.ClusterEndpointsManager, dialer transports.Dialer) transports.MuxHandler

Types

type Config

type Config struct {
	transports.Config
}

type Option

type Option func(*Options) error

func Handler

func Handler(handler transports.MuxHandler) Option

func Middleware

func Middleware(middleware transports.Middleware) Option

func Transport

func Transport(transport transports.Transport) Option

type Options

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

type Proxy

type Proxy interface {
	Construct(options ProxyOptions) (err error)
	Port() int
	Run(ctx context.Context) (err error)
	Shutdown(ctx context.Context)
}

func New

func New(options ...Option) (p Proxy, err error)

type ProxyOptions

type ProxyOptions struct {
	Log     logs.Logger
	Config  Config
	Runtime *runtime.Runtime
	Manager clusters.ClusterEndpointsManager
	Dialer  transports.Dialer
}

type Response

type Response struct {
	Status int
	Header transports.Header
	Value  []byte
}