Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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 OutLogger ¶
type OutLogger struct {
// contains filtered or unexported fields
}
func NewOutLogger ¶
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 }
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
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 WatchRequest ¶
type WatchRequest struct {
// contains filtered or unexported fields
}
func (*WatchRequest) Cancel ¶
func (p *WatchRequest) Cancel()
func (*WatchRequest) Stream ¶
func (p *WatchRequest) Stream()
Click to show internal directories.
Click to hide internal directories.