logic

Documentation

Index

• func NewEventStoreLogEventService(httpPublisher service.HttpClient) service.Observer
• func NewEventStoreProcessEventService(httpPublisher service.HttpClient) service.Observer
• func NewEventStoreProcessLifeCycleService(httpPublisher service.HttpClient) service.Observer
• func NewHttpClientService() service.HttpClient
• func NewJwtService() service.Jwt
• func NewK8sService(Kcs *kubernetes.Clientset, dynamicClient dynamic.Interface, ...) service.K8s
• func NewKubeEventHttpPublisher(httpPublisher service.HttpClient) service.KubeEventPublisher
• func NewKubeEventKafkaPublisher() service.KubeEventPublisher
• func NewKubeEventService(k8s service.K8s) service.KubeEvent
• func NewResourceService(k8s service.K8s, observerList []service.Observer, ...) service.Resource
• type KubeObject

Functions

func NewEventStoreLogEventService

func NewEventStoreLogEventService(httpPublisher service.HttpClient) service.Observer

NewEventStoreLogEventService returns Observer type service

func NewEventStoreProcessEventService

func NewEventStoreProcessEventService(httpPublisher service.HttpClient) service.Observer

NewEventStoreProcessEventService returns Observer type service

func NewEventStoreProcessLifeCycleService

func NewEventStoreProcessLifeCycleService(httpPublisher service.HttpClient) service.Observer

NewEventStoreProcessLifeCycleService returns Observer type service

func NewHttpClientService

func NewHttpClientService() service.HttpClient

NewHttpClientService returns HttpClient type service

func NewJwtService

func NewJwtService() service.Jwt

NewJwtService returns Jwt type service

func NewK8sService

func NewK8sService(Kcs *kubernetes.Clientset, dynamicClient dynamic.Interface, discoveryClient *discovery.DiscoveryClient, observerList []service.Observer, kubeEventPublisher service.KubeEventPublisher) service.K8s

NewK8sService returns K8s type service.

func NewKubeEventHttpPublisher

func NewKubeEventHttpPublisher(httpPublisher service.HttpClient) service.KubeEventPublisher

func NewKubeEventKafkaPublisher

func NewKubeEventKafkaPublisher() service.KubeEventPublisher

func NewKubeEventService

func NewKubeEventService(k8s service.K8s) service.KubeEvent

func NewResourceService

func NewResourceService(k8s service.K8s, observerList []service.Observer, httpClient service.HttpClient) service.Resource

NewResourceService returns resource type service.

Types

type KubeObject

type KubeObject struct {
	OldK8sObj interface{} `json:"old_k8s_obj" bson:"old_k8s_obj"`
	NewK8sObj interface{} `json:"new_k8s_obj" bson:"new_k8s_obj"`
}