informer

Documentation

Index

• Constants
• type ClusterInfo
• type K8sInformer
• type K8sInformerImpl
  • func NewK8sInformerImpl(logger *zap.SugaredLogger, clusterRepository repository.ClusterRepository, ...) *K8sInformerImpl
  • func (impl *K8sInformerImpl) BuildInformerForAllClusters() error
  • func (impl *K8sInformerImpl) StopAllSystemWorkflowInformer()

Constants

const (
	CLUSTER_MODIFY_EVENT_SECRET_TYPE = "cluster.request/modify"
	DEFAULT_CLUSTER                  = "default_cluster"
	INFORMER_ALREADY_EXIST_MESSAGE   = "INFORMER_ALREADY_EXIST"
	ADD                              = "add"
	UPDATE                           = "update"
	POD_DELETED_MESSAGE              = "pod deleted"
	EXIT_CODE_143_ERROR              = "Error (exit code 143)"
	CI_WORKFLOW_NAME                 = "ci"
	CD_WORKFLOW_NAME                 = "cd"
	WORKFLOW_TYPE_LABEL_KEY          = "workflowType"
	JobKind                          = "Job"
)

Types

type ClusterInfo

type ClusterInfo struct {
	ClusterId   int    `json:"clusterId"`
	ClusterName string `json:"clusterName"`
	BearerToken string `json:"bearerToken"`
	ServerUrl   string `json:"serverUrl"`
}

type K8sInformer

type K8sInformer interface {
	BuildInformerForAllClusters() error
}

type K8sInformerImpl

type K8sInformerImpl struct {
	DefaultK8sConfig *rest.Config
	// contains filtered or unexported fields
}

func NewK8sInformerImpl

func NewK8sInformerImpl(logger *zap.SugaredLogger, clusterRepository repository.ClusterRepository, client *pubsub.PubSubClientServiceImpl, httpTransportConfig *k8s1.CustomK8sHttpTransportConfig) *K8sInformerImpl

func (*K8sInformerImpl) BuildInformerForAllClusters

func (impl *K8sInformerImpl) BuildInformerForAllClusters() error

func (*K8sInformerImpl) StopAllSystemWorkflowInformer

func (impl *K8sInformerImpl) StopAllSystemWorkflowInformer()