Documentation
¶
Index ¶
- Constants
- func NewFakeDiscoveryClient(registeredResouces []schema.GroupVersionResource) *fakeDiscoveryClient
- type Client
- func (c *Client) CreateResource(kind string, namespace string, obj interface{}, dryRun bool) (*unstructured.Unstructured, error)
- func (c *Client) DeleteResource(kind string, namespace string, name string, dryRun bool) error
- func (c *Client) GetCSRInterface() (csrtype.CertificateSigningRequestInterface, error)
- func (c *Client) GetEventsInterface() (event.EventInterface, error)
- func (c *Client) GetKubePolicyDeployment() (*apps.Deployment, error)
- func (c *Client) GetResource(kind string, namespace string, name string, subresources ...string) (*unstructured.Unstructured, error)
- func (c *Client) GetTLSCertProps(configuration *rest.Config) (certProps tls.TlsCertificateProps, err error)
- func (c *Client) InitTLSPemPair(configuration *rest.Config, fqdncn bool) (*tls.TlsPemPair, error)
- func (c *Client) ListResource(kind string, namespace string, lselector *meta.LabelSelector) (*unstructured.UnstructuredList, error)
- func (c *Client) NewDynamicSharedInformerFactory(defaultResync time.Duration) dynamicinformer.DynamicSharedInformerFactory
- func (c *Client) PatchResource(kind string, namespace string, name string, patch []byte) (*unstructured.Unstructured, error)
- func (c *Client) ReadRootCASecret() (result []byte)
- func (c *Client) ReadTlsPair(props tls.TlsCertificateProps) *tls.TlsPemPair
- func (c *Client) SetDiscovery(discoveryClient IDiscovery)
- func (c *Client) UpdateResource(kind string, namespace string, obj interface{}, dryRun bool) (*unstructured.Unstructured, error)
- func (c *Client) UpdateStatusResource(kind string, namespace string, obj interface{}, dryRun bool) (*unstructured.Unstructured, error)
- func (c *Client) WriteTlsPair(props tls.TlsCertificateProps, pemPair *tls.TlsPemPair) error
- type IDiscovery
- type ServerPreferredResources
Constants ¶
const ( // Kind names are case sensitive //CSRs CertificateSigningRequest CSRs string = "CertificateSigningRequest" // Secrets Secret Secrets string = "Secret" // ConfigMaps ConfigMap ConfigMaps string = "ConfigMap" // Namespaces Namespace Namespaces string = "Namespace" )
Variables ¶
This section is empty.
Functions ¶
func NewFakeDiscoveryClient ¶ added in v0.4.0
func NewFakeDiscoveryClient(registeredResouces []schema.GroupVersionResource) *fakeDiscoveryClient
NewFakeDiscoveryClient returns a fakediscovery client
Types ¶
type Client ¶
type Client struct {
DiscoveryClient IDiscovery
// contains filtered or unexported fields
}
Client enables interaction with k8 resource
func NewMockClient ¶ added in v0.4.0
---testing utilities
func (*Client) CreateResource ¶
func (c *Client) CreateResource(kind string, namespace string, obj interface{}, dryRun bool) (*unstructured.Unstructured, error)
CreateResource creates object for the specified resource/namespace
func (*Client) DeleteResource ¶ added in v1.1.0
DeleteResource deletes the specified resource
func (*Client) GetCSRInterface ¶
func (c *Client) GetCSRInterface() (csrtype.CertificateSigningRequestInterface, error)
GetCSRInterface provides type interface for CSR
func (*Client) GetEventsInterface ¶
func (c *Client) GetEventsInterface() (event.EventInterface, error)
GetEventsInterface provides typed interface for events TODO: can we use dynamic client to fetch the typed interface or generate a kube client value to access the interface
func (*Client) GetKubePolicyDeployment ¶
func (c *Client) GetKubePolicyDeployment() (*apps.Deployment, error)
GetKubePolicyDeployment returns kube policy depoyment value
func (*Client) GetResource ¶
func (c *Client) GetResource(kind string, namespace string, name string, subresources ...string) (*unstructured.Unstructured, error)
GetResource returns the resource in unstructured/json format
func (*Client) GetTLSCertProps ¶
func (c *Client) GetTLSCertProps(configuration *rest.Config) (certProps tls.TlsCertificateProps, err error)
GetTLSCertProps provides the TLS Certificate Properties
func (*Client) InitTLSPemPair ¶ added in v1.1.0
InitTLSPemPair Loads or creates PEM private key and TLS certificate for webhook server. Created pair is stored in cluster's secret. Returns struct with key/certificate pair.
func (*Client) ListResource ¶
func (c *Client) ListResource(kind string, namespace string, lselector *meta.LabelSelector) (*unstructured.UnstructuredList, error)
ListResource returns the list of resources in unstructured/json format Access items using []Items
func (*Client) NewDynamicSharedInformerFactory ¶ added in v1.1.0
func (c *Client) NewDynamicSharedInformerFactory(defaultResync time.Duration) dynamicinformer.DynamicSharedInformerFactory
func (*Client) PatchResource ¶ added in v0.6.0
func (c *Client) PatchResource(kind string, namespace string, name string, patch []byte) (*unstructured.Unstructured, error)
PatchResource patches the resource
func (*Client) ReadRootCASecret ¶
ReadRootCASecret returns the RootCA from the pre-defined secret
func (*Client) ReadTlsPair ¶
func (c *Client) ReadTlsPair(props tls.TlsCertificateProps) *tls.TlsPemPair
ReadTlsPair Reads the pair of TLS certificate and key from the specified secret.
func (*Client) SetDiscovery ¶ added in v0.4.0
func (c *Client) SetDiscovery(discoveryClient IDiscovery)
func (*Client) UpdateResource ¶
func (c *Client) UpdateResource(kind string, namespace string, obj interface{}, dryRun bool) (*unstructured.Unstructured, error)
UpdateResource updates object for the specified resource/namespace
func (*Client) UpdateStatusResource ¶
func (c *Client) UpdateStatusResource(kind string, namespace string, obj interface{}, dryRun bool) (*unstructured.Unstructured, error)
UpdateStatusResource updates the resource "status" subresource
func (*Client) WriteTlsPair ¶
func (c *Client) WriteTlsPair(props tls.TlsCertificateProps, pemPair *tls.TlsPemPair) error
WriteTlsPair Writes the pair of TLS certificate and key to the specified secret. Updates existing secret or creates new one.
type IDiscovery ¶ added in v0.4.0
type IDiscovery interface {
GetGVRFromKind(kind string) schema.GroupVersionResource
}
type ServerPreferredResources ¶ added in v0.4.0
type ServerPreferredResources struct {
// contains filtered or unexported fields
}
func (ServerPreferredResources) GetGVRFromKind ¶ added in v0.5.0
func (c ServerPreferredResources) GetGVRFromKind(kind string) schema.GroupVersionResource
GetGVRFromKind get the Group Version Resource from kind if kind is not found in first attempt we invalidate the cache, the retry will then fetch the new registered resources and check again if not found after 2 attempts, we declare kind is not found kind is Case sensitive
func (ServerPreferredResources) Poll ¶ added in v1.1.0
func (c ServerPreferredResources) Poll(resync time.Duration, stopCh <-chan struct{})
Poll will keep invalidate the local cache
Source Files