tunnel

Documentation

Index

• Constants
• func NewDefaultRemoteDialer(mux bool, ts oauth2.TokenSource, url *url.URL) remotedialer.Dialer
• func NewIAPRemoteDialer(mux bool, ts oauth2.TokenSource, instance string, port int, ...) remotedialer.Dialer
• func StartProxy(ctx context.Context, addr string, c ProxyConfig) error
• func StartServer(addr string, timeout time.Duration, allowedUpstreams []string) error
• func StartTcpForward(ctx context.Context, addr string, c TcpForwardConfig) error
• type ProxyConfig
• type Rule
• type TcpForwardConfig
• type Tunnel

Constants

const (
	DefaultTimeout    = 5 * time.Second
	DefaultServerPort = 7654
)

Functions

func NewDefaultRemoteDialer

func NewDefaultRemoteDialer(mux bool, ts oauth2.TokenSource, url *url.URL) remotedialer.Dialer

func NewIAPRemoteDialer

func NewIAPRemoteDialer(mux bool, ts oauth2.TokenSource, instance string, port int, project, zone string) remotedialer.Dialer

func StartProxy

func StartProxy(ctx context.Context, addr string, c ProxyConfig) error

func StartServer

func StartServer(addr string, timeout time.Duration, allowedUpstreams []string) error

func StartTcpForward

func StartTcpForward(ctx context.Context, addr string, c TcpForwardConfig) error

Types

type ProxyConfig

type ProxyConfig struct {
	Rules   []Rule        `yaml:"rules"`
	Timeout time.Duration `yaml:"dial_timeout"`
}

type Rule

type Rule struct {
	Tunnel    Tunnel   `yaml:"tunnel"`
	Upstreams []string `yaml:"upstreams"`
}

type TcpForwardConfig

type TcpForwardConfig struct {
	ServiceUrl string
	Instance   string
	Port       int
	Project    string
	Zone       string
	Upstream   string
	MuxEnabled bool
}

type Tunnel

type Tunnel struct {
	Instance   string `yaml:"instance"`
	Port       int    `yaml:"port"`
	Project    string `yaml:"project"`
	Zone       string `yaml:"zone"`
	ServiceUrl string `yaml:"service_url"`
	MuxEnabled bool   `yaml:"mux"`
}