mirror of
https://github.com/kubernetes/sample-controller.git
synced 2025-01-21 17:32:50 +08:00
ec723b2112
Automatic merge from submit-queue. If you want to cherry-pick this change to another branch, please follow the instructions <a href="https://github.com/kubernetes/community/blob/master/contributors/devel/cherry-picks.md">here</a>. sample-controller: add example CRD controller **What this PR does / why we need it**: Adds a sample-controller example repository fixes #52752 **Special notes for your reviewer**: This is currently based on the sttts:sttts-codegen-scripts branch and should not be merged until that is (ref https://github.com/kubernetes/kubernetes/pull/52186) **Release note**: ``` Add sample-controller repository ``` /cc @sttts @nikhita @colemickens Kubernetes-commit: 9a7800f7d2efb88b397674672ac56f898826cf7c
88 lines
2.4 KiB
Go
88 lines
2.4 KiB
Go
// Copyright 2016 The Go Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
// +build !go1.7
|
|
|
|
package http2
|
|
|
|
import (
|
|
"crypto/tls"
|
|
"net"
|
|
"net/http"
|
|
"time"
|
|
)
|
|
|
|
type contextContext interface {
|
|
Done() <-chan struct{}
|
|
Err() error
|
|
}
|
|
|
|
type fakeContext struct{}
|
|
|
|
func (fakeContext) Done() <-chan struct{} { return nil }
|
|
func (fakeContext) Err() error { panic("should not be called") }
|
|
|
|
func reqContext(r *http.Request) fakeContext {
|
|
return fakeContext{}
|
|
}
|
|
|
|
func setResponseUncompressed(res *http.Response) {
|
|
// Nothing.
|
|
}
|
|
|
|
type clientTrace struct{}
|
|
|
|
func requestTrace(*http.Request) *clientTrace { return nil }
|
|
func traceGotConn(*http.Request, *ClientConn) {}
|
|
func traceFirstResponseByte(*clientTrace) {}
|
|
func traceWroteHeaders(*clientTrace) {}
|
|
func traceWroteRequest(*clientTrace, error) {}
|
|
func traceGot100Continue(trace *clientTrace) {}
|
|
func traceWait100Continue(trace *clientTrace) {}
|
|
|
|
func nop() {}
|
|
|
|
func serverConnBaseContext(c net.Conn, opts *ServeConnOpts) (ctx contextContext, cancel func()) {
|
|
return nil, nop
|
|
}
|
|
|
|
func contextWithCancel(ctx contextContext) (_ contextContext, cancel func()) {
|
|
return ctx, nop
|
|
}
|
|
|
|
func requestWithContext(req *http.Request, ctx contextContext) *http.Request {
|
|
return req
|
|
}
|
|
|
|
// temporary copy of Go 1.6's private tls.Config.clone:
|
|
func cloneTLSConfig(c *tls.Config) *tls.Config {
|
|
return &tls.Config{
|
|
Rand: c.Rand,
|
|
Time: c.Time,
|
|
Certificates: c.Certificates,
|
|
NameToCertificate: c.NameToCertificate,
|
|
GetCertificate: c.GetCertificate,
|
|
RootCAs: c.RootCAs,
|
|
NextProtos: c.NextProtos,
|
|
ServerName: c.ServerName,
|
|
ClientAuth: c.ClientAuth,
|
|
ClientCAs: c.ClientCAs,
|
|
InsecureSkipVerify: c.InsecureSkipVerify,
|
|
CipherSuites: c.CipherSuites,
|
|
PreferServerCipherSuites: c.PreferServerCipherSuites,
|
|
SessionTicketsDisabled: c.SessionTicketsDisabled,
|
|
SessionTicketKey: c.SessionTicketKey,
|
|
ClientSessionCache: c.ClientSessionCache,
|
|
MinVersion: c.MinVersion,
|
|
MaxVersion: c.MaxVersion,
|
|
CurvePreferences: c.CurvePreferences,
|
|
}
|
|
}
|
|
|
|
func (cc *ClientConn) Ping(ctx contextContext) error {
|
|
return cc.ping(ctx)
|
|
}
|
|
|
|
func (t *Transport) idleConnTimeout() time.Duration { return 0 }
|