proxy

Documentation

Index

• type ListChunk
• type ListEnvelope
• type ListReq
  • func (p ListReq) Respond()
• type Logger
• type OutLogger
  • func NewOutLogger(debug bool) OutLogger
  • func (l OutLogger) Debug(str string, data ...interface{})
  • func (l OutLogger) Error(str string, data ...interface{})
  • func (l OutLogger) Info(str string, data ...interface{})
• type PrefixLogger
  • func NewPrefixLogger(prefix string, logger Logger) PrefixLogger
  • func (l PrefixLogger) Debug(str string, data ...interface{})
  • func (l PrefixLogger) Error(str string, data ...interface{})
  • func (l PrefixLogger) Info(str string, data ...interface{})
• type Proxy
  • func (p Proxy) Run() error
• type ServiceAccount
  • func (s ServiceAccount) Namespaces() ([]string, error)
• type ServiceAccountFactory
  • func NewServiceAccountFactory(coreClient kubernetes.Interface) ServiceAccountFactory
  • func (f ServiceAccountFactory) New(authHeaders []string) (ServiceAccount, error)
• type TypeMetaResolver
  • func NewTypeMetaResolver(coreClient kubernetes.Interface) TypeMetaResolver
  • func (r TypeMetaResolver) Resolve(pathMeta map[string]string) (metav1.TypeMeta, error)
• type UpstreamTransportFactory
  • func NewUpstreamTransportFactory(logger Logger) (UpstreamTransportFactory, error)
  • func (f UpstreamTransportFactory) New() *http.Transport
• type WatchChanges
  • func NewWatchChanges(nss []string, serviceAccount ServiceAccount, watchReq *WatchRequest, ...) WatchChanges
  • func (c WatchChanges) Observe()
  • func (c WatchChanges) StopObserving()
• type WatchEventChunk
• type WatchRequest
  • func (p *WatchRequest) Cancel()
  • func (p *WatchRequest) Stream()

Types

type ListChunk

type ListChunk struct {
	Error      error
	Header     http.Header
	StatusCode int
	Data       []byte
}

type ListEnvelope

type ListEnvelope struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`

	// plain response application/json
	Items []json.RawMessage `json:"items,omitempty"`

	// table response application/json;as=Table;v=v1beta1;g=meta.k8s.io
	ColDefs []json.RawMessage `json:"columnDefinitions,omitempty"`
	Rows    []json.RawMessage `json:"rows,omitempty"`
}

type ListReq

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

func (ListReq) Respond

func (p ListReq) Respond()

type Logger

type Logger interface {
	Error(string, ...interface{})
	Info(string, ...interface{})
	Debug(string, ...interface{})
}

type OutLogger

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

func NewOutLogger

func NewOutLogger(debug bool) OutLogger

func (OutLogger) Debug

func (l OutLogger) Debug(str string, data ...interface{})

func (OutLogger) Error

func (l OutLogger) Error(str string, data ...interface{})

func (OutLogger) Info

func (l OutLogger) Info(str string, data ...interface{})

type PrefixLogger

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

func NewPrefixLogger

func NewPrefixLogger(prefix string, logger Logger) PrefixLogger

func (PrefixLogger) Debug

func (l PrefixLogger) Debug(str string, data ...interface{})

func (PrefixLogger) Error

func (l PrefixLogger) Error(str string, data ...interface{})

func (PrefixLogger) Info

func (l PrefixLogger) Info(str string, data ...interface{})

type Proxy

type Proxy struct {
	ListenAddr                string
	CertFilePath, KeyFilePath string

	Pprof bool

	UpstreamAPIServerHost    string // os.Getenv("KUBERNETES_SERVICE_HOST")
	ServiceAccountFactory    ServiceAccountFactory
	UpstreamTransportFactory UpstreamTransportFactory
	TypeMetaResolver         TypeMetaResolver

	Logger Logger
}

func (Proxy) Run

func (p Proxy) Run() error

type ServiceAccount

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

func (ServiceAccount) Namespaces

func (s ServiceAccount) Namespaces() ([]string, error)

type ServiceAccountFactory

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

func NewServiceAccountFactory

func NewServiceAccountFactory(coreClient kubernetes.Interface) ServiceAccountFactory

func (ServiceAccountFactory) New

func (f ServiceAccountFactory) New(authHeaders []string) (ServiceAccount, error)

TODO cache service account namespaces

type TypeMetaResolver

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

func NewTypeMetaResolver

func NewTypeMetaResolver(coreClient kubernetes.Interface) TypeMetaResolver

func (TypeMetaResolver) Resolve

func (r TypeMetaResolver) Resolve(pathMeta map[string]string) (metav1.TypeMeta, error)

type UpstreamTransportFactory

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

func NewUpstreamTransportFactory

func NewUpstreamTransportFactory(logger Logger) (UpstreamTransportFactory, error)

func (UpstreamTransportFactory) New

func (f UpstreamTransportFactory) New() *http.Transport

type WatchChanges

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

func NewWatchChanges

func NewWatchChanges(nss []string, serviceAccount ServiceAccount, watchReq *WatchRequest, logger Logger) WatchChanges

func (WatchChanges) Observe

func (c WatchChanges) Observe()

func (WatchChanges) StopObserving

func (c WatchChanges) StopObserving()

type WatchEventChunk

type WatchEventChunk struct {
	Error      error
	Header     http.Header
	StatusCode int
	Data       []byte
}

type WatchRequest

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

func (*WatchRequest) Cancel

func (p *WatchRequest) Cancel()

func (*WatchRequest) Stream

func (p *WatchRequest) Stream()