util

package
v0.5.4-rc3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 22, 2022 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

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 CreateOrUpdate(ctx context.Context, c client.Client, obj client.Object) error

func DecodeStruct added in v0.4.1

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

func DeepCopy added in v0.4.1

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

func DeepCopyInto added in v0.4.1

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

func GenerateRandomString added in v0.3.1

func GenerateRandomString(length int) []byte

func LoadClientMTLSConfig added in v0.4.1

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

func LoadServingCertBundle added in v0.4.1

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

func Must added in v0.4.1

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

func NewK8sClient added in v0.4.1

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

func NewProtocolListener added in v0.4.1

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

func NewTestLogger

func NewTestLogger() logr.Logger

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)

func Pointer added in v0.4.1

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

func ProtoClone added in v0.5.4

func ProtoClone[T proto.Message](msg T) T

func StatusCode added in v0.5.4

func StatusCode(err error) codes.Code

Like status.Code(), but supports wrapped errors.

func StatusError added in v0.5.4

func StatusError(code codes.Code) error

Types

type ClientOptions added in v0.4.1

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

type ClientStreamWithContext added in v0.5.4

type ClientStreamWithContext struct {
	Stream grpc.ClientStream
	Ctx    context.Context
}

func (*ClientStreamWithContext) CloseSend added in v0.5.4

func (s *ClientStreamWithContext) CloseSend() error

func (*ClientStreamWithContext) Context added in v0.5.4

func (*ClientStreamWithContext) Header added in v0.5.4

func (s *ClientStreamWithContext) Header() (metadata.MD, error)

func (*ClientStreamWithContext) RecvMsg added in v0.5.4

func (s *ClientStreamWithContext) RecvMsg(m interface{}) error

func (*ClientStreamWithContext) SendMsg added in v0.5.4

func (s *ClientStreamWithContext) SendMsg(m interface{}) error

func (*ClientStreamWithContext) Trailer added in v0.5.4

func (s *ClientStreamWithContext) Trailer() metadata.MD

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 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 added in v0.4.1

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

func (RequeueOp) ShouldRequeue

func (r RequeueOp) ShouldRequeue() bool

type ServerStreamWithContext added in v0.5.4

type ServerStreamWithContext struct {
	Stream grpc.ServerStream
	Ctx    context.Context
}

func (*ServerStreamWithContext) Context added in v0.5.4

func (*ServerStreamWithContext) RecvMsg added in v0.5.4

func (s *ServerStreamWithContext) RecvMsg(m interface{}) error

func (*ServerStreamWithContext) SendHeader added in v0.5.4

func (s *ServerStreamWithContext) SendHeader(md metadata.MD) error

func (*ServerStreamWithContext) SendMsg added in v0.5.4

func (s *ServerStreamWithContext) SendMsg(m interface{}) error

func (*ServerStreamWithContext) SetHeader added in v0.5.4

func (s *ServerStreamWithContext) SetHeader(md metadata.MD) error

func (*ServerStreamWithContext) SetTrailer added in v0.5.4

func (s *ServerStreamWithContext) SetTrailer(md metadata.MD)

type ServicePack added in v0.5.4

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

func PackService added in v0.5.4

func PackService[T any](desc *grpc.ServiceDesc, impl T) ServicePack[T]

func (*ServicePack[T]) Unpack added in v0.5.4

func (s *ServicePack[T]) Unpack() (*grpc.ServiceDesc, any)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL