proxy

Documentation

Index

• func GenSignedCert() (keyPem []byte, certPem []byte, err error)
• func InitProxy(httpAuth ProxyHTTPAuth)
• func LoadOrGenCA() error
• func LoadOrGenSignedMasterCert() error
• func MasterCACert() ([]byte, error)
• func MasterKeyAndCert() (keyPem []byte, certPem []byte, err error)
• func VerifyMasterSigned(state tls.ConnectionState) error
• type Proxy
  • func (p *Proxy) ClearProxy()
  • func (p *Proxy) GetService(serviceID string) *Service
  • func (p *Proxy) NewProxyHandler(serviceID string) echo.HandlerFunc
  • func (p *Proxy) Register(serviceID string, url *url.URL, proxyTCP bool, unauth bool)
  • func (p *Proxy) Summaries() map[string]Service
  • func (p *Proxy) Summary(id string) (Service, bool)
  • func (p *Proxy) Unregister(serviceID string)
• type ProxyHTTPAuth
• type Service
  • func (s Service) Clone() Service

Functions

func GenSignedCert

func GenSignedCert() (keyPem []byte, certPem []byte, err error)

GenSignedCert generates a key and cert pair, signed by the master CA cert.

func InitProxy

func InitProxy(httpAuth ProxyHTTPAuth)

InitProxy initializes the global proxy.

func LoadOrGenCA

func LoadOrGenCA() error

LoadOrGenCA generates a new CA cert and key if they do not exist in DB or are expired.

func LoadOrGenSignedMasterCert

func LoadOrGenSignedMasterCert() error

LoadOrGenSignedMasterCert generates a new master cert and key if they do not exist in DB or are expired.

func MasterCACert

func MasterCACert() ([]byte, error)

MasterCACert returns the CA cert.

func MasterKeyAndCert

func MasterKeyAndCert() (keyPem []byte, certPem []byte, err error)

MasterKeyAndCert returns the key and cert, signed by CA, that Master uses.

func VerifyMasterSigned

func VerifyMasterSigned(state tls.ConnectionState) error

VerifyMasterSigned checks the offered certificate to ensure that it was signed by the master CA.

Types

type Proxy

type Proxy struct {
	HTTPAuth ProxyHTTPAuth
	// contains filtered or unexported fields
}

Proxy is an actor that proxies requests to registered services.

var DefaultProxy *Proxy

DefaultProxy is the global proxy singleton.

func (*Proxy) ClearProxy

func (p *Proxy) ClearProxy()

ClearProxy erases all services from the proxy in case any handlers are still active.

func (*Proxy) GetService

func (p *Proxy) GetService(serviceID string) *Service

GetService returns the Service, if any, given the serviceID key.

func (*Proxy) NewProxyHandler

func (p *Proxy) NewProxyHandler(serviceID string) echo.HandlerFunc

NewProxyHandler returns a middleware function for proxying HTTP-like traffic to services running in the cluster. Services an HTTP request through the /proxy/:service/* route.

func (*Proxy) Register

func (p *Proxy) Register(serviceID string, url *url.URL, proxyTCP bool, unauth bool)

Register registers the service name with the associated target URL. All requests with the format ".../:service-name/*" are forwarded to the service via the target URL.

func (*Proxy) Summaries

func (p *Proxy) Summaries() map[string]Service

Summaries returns a snapshot of the registered services.

func (*Proxy) Summary

func (p *Proxy) Summary(id string) (Service, bool)

Summary returns a snapshot of a specific registered service.

func (*Proxy) Unregister

func (p *Proxy) Unregister(serviceID string)

Unregister removes the service from the proxy. All future requests until the service name is registered again will be responded with a 404 response. If the service is not registered with the proxy, the message is ignored.

type ProxyHTTPAuth

type ProxyHTTPAuth func(echo.Context) (done bool, err error)

ProxyHTTPAuth processes a proxy request, returning true if the request should terminate immediately and an error if one was encountered during authentication.

type Service

type Service struct {
	URL                  *url.URL
	LastRequested        time.Time
	ProxyTCP             bool
	AllowUnauthenticated bool
}

Service represents a registered service. The LastRequested field is used by the Tensorboard manager to spin down idle instances of Tensorboard.

func (Service) Clone

func (s Service) Clone() Service

Clone returns a deep copy of the Service.