service

Documentation

Index

• type HttpClient
• type Jwt
• type K8s
• type KubeEvent
• type KubeEventPublisher
• type Observer
• type Resource

Types

type HttpClient

type HttpClient interface {
	Post(url string, header map[string]string, body []byte) error
	Get(url string, header map[string]string) ([]byte, error)
}

HttpClient HttpClient operations.

type Jwt

type Jwt interface {
	ValidateToken(tokenString string) (bool, *jwt.Token)
}

Jwt Jwt operations.

type K8s

type K8s interface {
	GetDeployment(name, namespace string) (*apiV1.Deployment, error)
	GetPod(name, namespace string) (*coreV1.Pod, error)
	GetStatefulSet(name, namespace string) (*apiV1.StatefulSet, error)
	GetDaemonSet(name, namespace string) (*apiV1.DaemonSet, error)
	UpdateDeployment(resource v1.Resource) error
	UpdatePod(resource v1.Resource) error
	UpdateStatefulSet(resource v1.Resource) error
	UpdateDaemonSet(resource v1.Resource) error
	Apply(data unstructured.Unstructured) error
	Deploy(data *unstructured.Unstructured) (bool, error)
	ListenNamespaceEvents() (cache.Store, cache.Controller)
	ListenServiceEvents() (cache.Store, cache.Controller)
	ListenPodEvents() (cache.Store, cache.Controller)
	ListenDeployEvents() (cache.Store, cache.Controller)
	ListenIngressEvents() (cache.Store, cache.Controller)
	ListenNetworkPolicyEvents() (cache.Store, cache.Controller)
	ListenClusterRoleBindingEvents() (cache.Store, cache.Controller)
	ListenClusterRoleEvents() (cache.Store, cache.Controller)
	ListenRoleBindingEvents() (cache.Store, cache.Controller)
	ListenRoleEvents() (cache.Store, cache.Controller)
	ListenServiceAccountEvents() (cache.Store, cache.Controller)
	ListenSecretEvents() (cache.Store, cache.Controller)
	ListenConfigMapEvents() (cache.Store, cache.Controller)
	ListenPVCEvents() (cache.Store, cache.Controller)
	ListenPVEvents() (cache.Store, cache.Controller)
	ListenDaemonSetEvents() (cache.Store, cache.Controller)
	ListenReplicaSetEvents() (cache.Store, cache.Controller)
	ListenStateFullSetSetEvents() (cache.Store, cache.Controller)
	ListenKubeEvents() (cache.Store, cache.Controller)
}

K8s operations.

type KubeEvent

type KubeEvent interface {
	GetK8sObjectChangeEvents()
}

type KubeEventPublisher

type KubeEventPublisher interface {
	Publish(message v1.KubeEventMessage)
}

type Observer

type Observer interface {
	Listen(v1.Subject)
}

Observer Observer operations.

type Resource

type Resource interface {
	Update(resource v1.Resource) error
	Pull()
}

Resource K8s Resource operations.