controller

type ApiMetricStream struct {
	CollectionID string
	StreamClient chan *ApiMetricStreamEvent
	ClientID     string
}

type ApiMetricStreamEvent struct {
	CollectionID string `json:"collection_id"`
	Raw          string `json:"metrics"`
	PlanID       string `json:"plan_id"`
}

type Controller struct {
	LabelStore         sync.Map
	StatusStore        sync.Map
	ApiNewClients      chan *ApiMetricStream
	ApiStreamClients   map[string]map[string]chan *ApiMetricStreamEvent
	ApiMetricStreamBus chan *ApiMetricStreamEvent
	ApiClosingClients  chan *ApiMetricStream

	Scheduler scheduler.EngineScheduler
	// contains filtered or unexported fields
}

type GCPNodesInfo struct {
	smodel.NodesInfo
	Status string
}

type GCPOperator struct {
	*config.ClusterConfig
	// contains filtered or unexported fields
}

type PlanController struct {
	// contains filtered or unexported fields
}

type RunningPlan struct {
	// contains filtered or unexported fields
}