util

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
  • func NewDelimiterCodec(key string, delimiter string) DelimiterCodec
  • func (d DelimiterCodec) Decode(s string) []string
  • func (d DelimiterCodec) Encode(ids []string) string
  • func (d DelimiterCodec) Key() string
• type Future
  • func NewFuture[T any]() *Future[T]
  • func (f *Future[T]) Get() T
  • func (f *Future[T]) GetContext(ctx context.Context) (_ T, err error)
  • func (f *Future[T]) Set(object T)
• type RequeueOp
  • func DoNotRequeue() RequeueOp
  • func LoadResult(result *reconcile.Result, err error) RequeueOp
  • func Requeue() RequeueOp
  • func RequeueAfter(d time.Duration) RequeueOp
  • func RequeueErr(err error) RequeueOp
  • func (r RequeueOp) Result() (ctrl.Result, error)
  • func (r RequeueOp) ResultPtr() (result *ctrl.Result, err error)
  • func (r RequeueOp) ShouldRequeue() bool

Variables

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,
}

var ErrUnsupportedProtocolScheme = errors.New("unsupported protocol scheme")

var Version string

Functions

func CreateOrUpdate

func CreateOrUpdate(ctx context.Context, c client.Client, obj client.Object) error

func DecodeStruct

func DecodeStruct[T any](input interface{}) (*T, error)

func DeepCopy

func DeepCopy[T any](in *T) *T

func DeepCopyInto

func DeepCopyInto[T any](out, in *T)

func GenerateRandomString

func GenerateRandomString(length int) []byte

func LoadClientMTLSConfig

func LoadClientMTLSConfig(certs *v1beta1.MTLSSpec) (*tls.Config, error)

func LoadServingCertBundle

func LoadServingCertBundle(certsSpec v1beta1.CertsSpec) (*tls.Certificate, *x509.CertPool, error)

func Must

func Must[T any](t T, err ...error) T

func NewK8sClient

func NewK8sClient(options ClientOptions) (client.Client, error)

func NewProtocolListener

func NewProtocolListener(addr string) (net.Listener, error)

func NewTestLogger

func NewTestLogger() logr.Logger

func ParsePEMEncodedCert

func ParsePEMEncodedCert(data []byte) (*x509.Certificate, error)

func ParsePEMEncodedCertChain

func ParsePEMEncodedCertChain(chain []byte) ([]*x509.Certificate, error)

func Pointer

func Pointer[T any](t T) *T

Types

type ClientOptions

type ClientOptions struct {
	Kubeconfig *string
	RestConfig *rest.Config
	Scheme     *runtime.Scheme
}

type DelimiterCodec

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

Implements rbac.Codec

func NewDelimiterCodec

func NewDelimiterCodec(key string, delimiter string) DelimiterCodec

func (DelimiterCodec) Decode

func (d DelimiterCodec) Decode(s string) []string

func (DelimiterCodec) Encode

func (d DelimiterCodec) Encode(ids []string) string

func (DelimiterCodec) Key

func (d DelimiterCodec) Key() string

type Future

type Future[T any] struct {
	// contains filtered or unexported fields
}

func NewFuture

func NewFuture[T any]() *Future[T]

func (*Future[T]) Get

func (f *Future[T]) Get() T

func (*Future[T]) GetContext

func (f *Future[T]) GetContext(ctx context.Context) (_ T, err error)

func (*Future[T]) Set

func (f *Future[T]) Set(object T)

type RequeueOp

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

func DoNotRequeue

func DoNotRequeue() RequeueOp

func LoadResult

func LoadResult(result *reconcile.Result, err error) RequeueOp

func Requeue

func Requeue() RequeueOp

func RequeueAfter

func RequeueAfter(d time.Duration) RequeueOp

func RequeueErr

func RequeueErr(err error) RequeueOp

func (RequeueOp) Result

func (r RequeueOp) Result() (ctrl.Result, error)

func (RequeueOp) ResultPtr

func (r RequeueOp) ResultPtr() (result *ctrl.Result, err error)

func (RequeueOp) ShouldRequeue

func (r RequeueOp) ShouldRequeue() bool