Documentation
¶
Index ¶
- Variables
- func CreateOrUpdate(ctx context.Context, c client.Client, obj client.Object) error
- func DecodeStruct[T any](input interface{}) (*T, error)
- func DeepCopy[T any](in *T) *T
- func DeepCopyInto[T any](out, in *T)
- func GenerateRandomString(length int) []byte
- func LoadClientMTLSConfig(certs *v1beta1.MTLSSpec) (*tls.Config, error)
- func LoadServingCertBundle(certsSpec v1beta1.CertsSpec) (*tls.Certificate, *x509.CertPool, error)
- func Must[T any](t T, err ...error) T
- func NewK8sClient(options ClientOptions) (client.Client, error)
- func NewProtocolListener(addr string) (net.Listener, error)
- func NewTestLogger() logr.Logger
- func ParsePEMEncodedCert(data []byte) (*x509.Certificate, error)
- func ParsePEMEncodedCertChain(chain []byte) ([]*x509.Certificate, error)
- func Pointer[T any](t T) *T
- type ClientOptions
- type DelimiterCodec
- type Future
- type RequeueOp
Constants ¶
This section is empty.
Variables ¶
View Source
var EncoderConfig = zapcore.EncoderConfig{ MessageKey: "M", LevelKey: "L", TimeKey: "T", NameKey: "N", CallerKey: "C", FunctionKey: "", StacktraceKey: "S", ConsoleSeparator: " ", EncodeLevel: zapcore.CapitalColorLevelEncoder, EncodeCaller: func(ec zapcore.EntryCaller, enc zapcore.PrimitiveArrayEncoder) { enc.AppendString(chalk.Dim.TextStyle(ec.TrimmedPath())) }, EncodeName: func(name string, enc zapcore.PrimitiveArrayEncoder) { enc.AppendString(chalk.Dim.TextStyle( strings.Replace(name, "controller-runtime.manager.", "", 1))) }, EncodeTime: func(t time.Time, enc zapcore.PrimitiveArrayEncoder) { enc.AppendString(t.Format("[15:04:05]")) }, EncodeDuration: zapcore.SecondsDurationEncoder, }
View Source
var ErrUnsupportedProtocolScheme = errors.New("unsupported protocol scheme")
View Source
var Version string
Functions ¶
func CreateOrUpdate ¶
func DecodeStruct ¶ added in v0.4.1
func DeepCopyInto ¶ added in v0.4.1
func DeepCopyInto[T any](out, in *T)
func GenerateRandomString ¶ added in v0.3.1
func LoadClientMTLSConfig ¶ added in v0.4.1
func LoadServingCertBundle ¶ added in v0.4.1
func NewK8sClient ¶ added in v0.4.1
func NewK8sClient(options ClientOptions) (client.Client, error)
func NewProtocolListener ¶ added in v0.4.1
func NewTestLogger ¶
func ParsePEMEncodedCert ¶ added in v0.4.1
func ParsePEMEncodedCert(data []byte) (*x509.Certificate, error)
func ParsePEMEncodedCertChain ¶ added in v0.4.1
func ParsePEMEncodedCertChain(chain []byte) ([]*x509.Certificate, error)
Types ¶
type ClientOptions ¶ added in v0.4.1
type DelimiterCodec ¶ added in v0.4.1
type DelimiterCodec struct {
// contains filtered or unexported fields
}
Implements rbac.Codec
func NewDelimiterCodec ¶ added in v0.4.1
func NewDelimiterCodec(key string, delimiter string) DelimiterCodec
func (DelimiterCodec) Decode ¶ added in v0.4.1
func (d DelimiterCodec) Decode(s string) []string
func (DelimiterCodec) Encode ¶ added in v0.4.1
func (d DelimiterCodec) Encode(ids []string) string
func (DelimiterCodec) Key ¶ added in v0.4.1
func (d DelimiterCodec) Key() string
type Future ¶ added in v0.4.1
type Future[T any] struct { // contains filtered or unexported fields }
func (*Future[T]) GetContext ¶ added in v0.4.1
type RequeueOp ¶
type RequeueOp struct {
// contains filtered or unexported fields
}
func DoNotRequeue ¶
func DoNotRequeue() RequeueOp
func RequeueAfter ¶
func RequeueErr ¶
func (RequeueOp) ShouldRequeue ¶
Source Files
¶
Click to show internal directories.
Click to hide internal directories.