operator

type ADXClusterSchema struct {
	Database     string            `json:"database"`
	Tables       []string          `json:"tables"`
	TableSchemas map[string]string `json:"tableSchemas,omitempty"`
	Views        []string          `json:"views"`
}

type AdxReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

type AlerterReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

type CollectorReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

type DatabaseExistsRec struct {
	Count int64 `kusto:"Count"`
}

type DatabaseRec struct {
	DatabaseName string `json:"DatabaseName"`
}

type DatabaseSchemaRec struct {
	TableName  string `kusto:"TableName"`
	ColumnName string `kusto:"ColumnName"`
	ColumnType string `kusto:"ColumnType"`
}

type FederationState struct {
	// DBSet contains unique databases discovered from all endpoints
	DBSet map[string]struct{}

	// DBTableEndpoints maps database -> table/view -> list of endpoints
	DBTableEndpoints map[string]map[string][]string

	// SpokeDBEndpoints maps database -> list of endpoints (for entity group generation)
	SpokeDBEndpoints map[string][]string

	// EndpointCount is the number of successfully processed endpoints
	EndpointCount int

	// ParseErrors collects non-fatal schema parsing errors
	ParseErrors []string
}

type FunctionKind struct {
	Kind string `kusto:"FunctionKind"`
}

type FunctionRec struct {
	Name       string `kusto:"Name"`
	Parameters string `kusto:"Parameters"`
	Body       string `kusto:"Body"`
	Folder     string `kusto:"Folder"`
	DocString  string `kusto:"DocString"`
}

type FunctionSchemaRec struct {
	Kind          string          `kusto:"FunctionKind"`
	OutputColumns json.RawMessage `kusto:"OutputColumns"`
}

type HeartbeatRow struct {
	Timestamp       time.Time       `kusto:"Timestamp"`
	ClusterEndpoint string          `kusto:"ClusterEndpoint"`
	Schema          json.RawMessage `kusto:"Schema"`
}

type IngestorReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

type OutputColumn struct {
	Name    string `json:"Name"`
	CslType string `json:"CslType"`
}

type TableExists struct {
	Count int64 `kusto:"Count"`
}

type TableRec struct {
	TableName string `json:"TableName"`
}