cluster

Documentation

Index

• Constants
• Variables
• type Cluster
• type DataExister
• type EventHandler
• type ReportFunc
• type Reporter

Constants

const (
	//syncStorageErr = "ZOOKEEPERErr"
	SyncSuccess = "SUCCESS"
	SyncFailure = "FAILURE"

	DataTypeApp       = "Application"
	DataTypeTaskGroup = "TaskGroup"
	DataTypeCfg       = "Configmap"
	//DataTypeSecret    = "Secret"
	DataTypeDeploy             = "Deployment"
	DataTypeSvr                = "Service"
	DataTypeExpSVR             = "ExportService"
	DataTypeIPPoolStatic       = "IPPoolStatic"
	DataTypeIPPoolStaticDetail = "IPPoolStaticDetail"
)

Variables

var (
	SyncTotal = prometheus.NewCounterVec(prometheus.CounterOpts{
		Namespace: "bkbcs_datawatch",
		Subsystem: "mesos",
		Name:      "sync_total",
		Help:      "The total number of data sync event.",
	}, []string{"datatype", "action", "status"})
)

Types

type Cluster

type Cluster interface {
	Run(cxt context.Context)  //start cluster
	Sync(tp string) error     //ready to sync data, type like services, pods and etc.
	Stop()                    //stop cluster
	GetClusterStatus() string //get curr status
}

Cluster is interface for reading Cluster info

type DataExister

type DataExister interface {
	IsExist(data interface{}) bool
}

DataExister checker interface for data exist

type EventHandler

type EventHandler interface {
	AddEvent(obj interface{})
	DeleteEvent(obj interface{})
	UpdateEvent(old, cur interface{})
}

EventHandler hold event interface for All Watch

type ReportFunc

type ReportFunc func(data *types.BcsSyncData) error

ReportFunc report function for handle detail report data

type Reporter

type Reporter interface {
	ReportData(data *types.BcsSyncData) error
}

Reporter for report data