kubesys

package
v1.1.13 Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2023 License: Apache-2.0 Imports: 16 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HTTPClientFor 

func HTTPClientFor(config *Config) (*http.Client, error)

func TLSConfigFor 

func TLSConfigFor(config *Config) (*tls.Config, error)

func ToGolangMap 

func ToGolangMap(bytes []byte) map[string]interface{}

func ToJsonObject 

func ToJsonObject(bytes []byte) gjson.Result

Types

type Config 

type Config struct {
	Server                   string
	ClientCertificateData    string
	ClientKeyData            string
	CertificateAuthorityData string
}

func NewForConfig 

func NewForConfig(kubeConfig string) (*Config, error)

type KubernetesAnalyzer 

type KubernetesAnalyzer struct {
	RuleBase *RuleBase
	Registry *Registry
}

func NewKubernetesAnalyzer 

func NewKubernetesAnalyzer() *KubernetesAnalyzer

func (*KubernetesAnalyzer) Learning 

func (analyzer *KubernetesAnalyzer) Learning(client *KubernetesClient)

type KubernetesClient 

type KubernetesClient struct {
	Url   string // required, user input
	Token string // required, user input
	// contains filtered or unexported fields
}

func NewKubernetesClient 

func NewKubernetesClient(url string, token string) *KubernetesClient

func NewKubernetesClientInCluster added in v1.1.9 

func NewKubernetesClientInCluster() *KubernetesClient

returns a kubernetesClient which uses the service account kubernetes gives to pods. It's intended for clients that expect to be running inside a pod running on kubernetes.

func NewKubernetesClientWithAnalyzer 

func NewKubernetesClientWithAnalyzer(url string, token string, analyzer *KubernetesAnalyzer) *KubernetesClient

func NewKubernetesClientWithDefaultKubeConfig 

func NewKubernetesClientWithDefaultKubeConfig() *KubernetesClient

NewKubernetesClientWithDefaultKubeConfig TODO

func NewKubernetesClientWithKubeConfig 

func NewKubernetesClientWithKubeConfig(kubeConfig string) *KubernetesClient

NewKubernetesClientWithKubeConfig TODO

func (*KubernetesClient) BindResources 

func (client *KubernetesClient) BindResources(pod gjson.Result, host string) ([]byte, error)

BindResources TODO

func (*KubernetesClient) BindingResourceStatusUrl 

func (client *KubernetesClient) BindingResourceStatusUrl(fullKind string, namespace string, name string) string

func (*KubernetesClient) CreateResource 

func (client *KubernetesClient) CreateResource(jsonStr string) ([]byte, error)

func (*KubernetesClient) CreateResourceUrl 

func (client *KubernetesClient) CreateResourceUrl(fullKind string, namespace string) string

func (*KubernetesClient) DeleteResource 

func (client *KubernetesClient) DeleteResource(kind string, namespace string, name string) ([]byte, error)

func (*KubernetesClient) DeleteResourceUrl 

func (client *KubernetesClient) DeleteResourceUrl(fullKind string, namespace string, name string) string

func (*KubernetesClient) GetFullKinds 

func (client *KubernetesClient) GetFullKinds() []string

func (*KubernetesClient) GetKindDesc 

func (client *KubernetesClient) GetKindDesc() []byte

func (*KubernetesClient) GetKinds 

func (client *KubernetesClient) GetKinds() []string

func (*KubernetesClient) GetResource 

func (client *KubernetesClient) GetResource(kind string, namespace string, name string) ([]byte, error)

func (*KubernetesClient) GetResourceUrl 

func (client *KubernetesClient) GetResourceUrl(fullKind string, namespace string, name string) string

func (*KubernetesClient) Init 

func (client *KubernetesClient) Init()

func (*KubernetesClient) ListResources 

func (client *KubernetesClient) ListResources(kind string, namespace string) ([]byte, error)

func (*KubernetesClient) ListResourcesUrl 

func (client *KubernetesClient) ListResourcesUrl(fullKind string, namespace string) string

func (*KubernetesClient) ListResourcesWithFieldSelector 

func (client *KubernetesClient) ListResourcesWithFieldSelector(kind string, namespace string, fields map[string]string) ([]byte, error)

func (*KubernetesClient) ListResourcesWithLabelSelector 

func (client *KubernetesClient) ListResourcesWithLabelSelector(kind string, namespace string, labels map[string]string) ([]byte, error)

func (*KubernetesClient) UpdateResource 

func (client *KubernetesClient) UpdateResource(jsonStr string) ([]byte, error)

func (*KubernetesClient) UpdateResourceStatus 

func (client *KubernetesClient) UpdateResourceStatus(jsonStr string) ([]byte, error)

func (*KubernetesClient) UpdateResourceStatusUrl 

func (client *KubernetesClient) UpdateResourceStatusUrl(fullKind string, namespace string, name string) string

func (*KubernetesClient) UpdateResourceUrl 

func (client *KubernetesClient) UpdateResourceUrl(fullKind string, namespace string, name string) string

func (*KubernetesClient) WatchResource 

func (client *KubernetesClient) WatchResource(kind string, namespace string, name string, watcher *KubernetesWatcher)

func (*KubernetesClient) WatchResources 

func (client *KubernetesClient) WatchResources(kind string, namespace string, watcher *KubernetesWatcher)

type KubernetesWatcher 

type KubernetesWatcher struct {
	Client *KubernetesClient
	// contains filtered or unexported fields
}

func NewKubernetesWatcher 

func NewKubernetesWatcher(client *KubernetesClient, handler WatchHandler) *KubernetesWatcher

func (*KubernetesWatcher) Watching 

func (watcher *KubernetesWatcher) Watching(url string)

type Registry 

type Registry struct {
	RuleBase *RuleBase
}

func NewRegistry 

func NewRegistry(ruleBase *RuleBase) *Registry

type RuleBase 

type RuleBase struct {
	KindToFullKindMapper      map[string][]string
	FullKindToApiPrefixMapper map[string]string

	FullKindToNameMapper      map[string]string
	FullKindToNamespaceMapper map[string]bool

	FullKindToVersionMapper map[string]string
	FullKindToGroupMapper   map[string]string
	FullKindToVerbsMapper   map[string]interface{}
}

type WatchHandler 

type WatchHandler interface {
	DoAdded(obj map[string]interface{})
	DoModified(obj map[string]interface{})
	DoDeleted(obj map[string]interface{})
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.