Versions in this module Expand all Collapse all v0 v0.4.0 Mar 31, 2022 Changes in this version + var ErrUnsupportedProtocolScheme = errors.New("unsupported protocol scheme") + func DecodeStruct(input interface{}) (*T, error) + func DeepCopy(in *T) *T + func DeepCopyInto(out, in *T) + func LoadClientMTLSConfig(certs *v1beta1.MTLSSpec) (*tls.Config, error) + func LoadServingCertBundle(certsSpec v1beta1.CertsSpec) (*tls.Certificate, *x509.CertPool, error) + func Must(t T, err ...error) T + func NewK8sClient(options ClientOptions) (client.Client, error) + func NewProtocolListener(addr string) (net.Listener, error) + func ParsePEMEncodedCert(data []byte) (*x509.Certificate, error) + func ParsePEMEncodedCertChain(chain []byte) ([]*x509.Certificate, error) + func Pointer(t T) *T + type ClientOptions struct + Kubeconfig *string + RestConfig *rest.Config + Scheme *runtime.Scheme + type DelimiterCodec struct + 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 struct + func NewFuture() *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)