upstream

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

type PushData struct {
	Canaries                     []models.Canary                        `json:"canaries,omitempty"`
	Checks                       []models.Check                         `json:"checks,omitempty"`
	Components                   []models.Component                     `json:"components,omitempty"`
	ConfigScrapers               []models.ConfigScraper                 `json:"config_scrapers,omitempty"`
	ConfigAnalysis               []models.ConfigAnalysis                `json:"config_analysis,omitempty"`
	ConfigChanges                []models.ConfigChange                  `json:"config_changes,omitempty"`
	ConfigItems                  []models.ConfigItem                    `json:"config_items,omitempty"`
	CheckStatuses                []models.CheckStatus                   `json:"check_statuses,omitempty"`
	ConfigRelationships          []models.ConfigRelationship            `json:"config_relationships,omitempty"`
	ComponentRelationships       []models.ComponentRelationship         `json:"component_relationships,omitempty"`
	ConfigComponentRelationships []models.ConfigComponentRelationship   `json:"config_component_relationships,omitempty"`
	Topologies                   []models.Topology                      `json:"topologies,omitempty"`
	PlaybookActions              []models.PlaybookRunAction             `json:"playbook_actions,omitempty"`
	Artifacts                    []models.Artifact                      `json:"artifacts,omitempty"`
	JobHistory                   []models.JobHistory                    `json:"job_history,omitempty"`
	ViewPanels                   []models.ViewPanel                     `json:"view_panels,omitempty"`
	GeneratedViews               map[string][]models.GeneratedViewTable `json:"generated_views,omitempty"`
}

type PushFKError struct {
	IDs []string `json:"ids"`
}

type PushGroup struct {
	Name   string
	Tables []pushableTable

	// DependsOn is a list of tables that need to be reconciled
	// for this group to be reconciled.
	DependsOn []string
}

type ReconcileSummary map[string]ReconcileTableSummary

type ReconcileTableSummary struct {
	Success   int                    `json:"success,omitempty"`
	FKeyError ForeignKeyErrorSummary `json:"foreign_error,omitempty"`
	Skipped   bool                   `json:"skipped,omitempty"`
	Error     *oops.OopsError        `json:"error,omitempty"`
}

type StatusRingManager interface {
	// Add adds the given history to the corresponding status ring of the agent.
	// if the status ring doesn't exist then it creates a new one.
	Add(ctx context.Context, agentID string, history models.JobHistory)
}

type UpstreamClient struct {
	*http.Client
	AgentName string
	// contains filtered or unexported fields
}

type UpstreamConfig struct {
	AgentName          string
	Host               string
	InsecureSkipVerify bool
	Username           string
	Password           string
	Labels             []string
	Debug              bool
	Options            []func(c *http.Client)
}

type ViewIdentifier struct {
	Namespace string `json:"namespace"`
	Name      string `json:"name"`
}

type ViewWithColumns struct {
	Namespace string              `json:"namespace"`
	Name      string              `json:"name"`
	Columns   []pkgView.ColumnDef `json:"columns"`
}