insight

type ApplicationCounts struct {
	Counts    []model.InsightApplicationCount
	UpdatedAt int64
}

type ApplicationData struct {
	ID     string            `json:"id"`
	Labels map[string]string `json:"labels"`
	Kind   string            `json:"kind"`
	Status string            `json:"status"`
}

type ApplicationGetter interface {
	GetApplications(ctx context.Context, projectID string) (*ProjectApplicationData, error)
}

type ApplicationStore interface {
	ApplicationGetter
	PutApplications(ctx context.Context, projectID string, as *ProjectApplicationData) error
}

type CompletedDeploymentGetter interface {
	GetMilestone(ctx context.Context) (*Milestone, error)
	ListCompletedDeployments(ctx context.Context, projectID string, from, to int64) ([]*DeploymentData, error)
}

type CompletedDeploymentStore interface {
	CompletedDeploymentGetter
	PutMilestone(ctx context.Context, m *Milestone) error
	PutCompletedDeployments(ctx context.Context, projectID string, ds []*DeploymentData) error
}

type DeploymentData struct {
	ID                string            `json:"id"`
	AppID             string            `json:"app_id"`
	Labels            map[string]string `json:"labels"`
	StartedAt         int64             `json:"started_at"`
	CompletedAt       int64             `json:"completed_at"`
	CompleteStatus    string            `json:"complete_status"`
	RollbackStartedAt int64             `json:"rollback_started_at"`
}

type Getter interface {
	ApplicationGetter
	CompletedDeploymentGetter
}

type Milestone struct {
	// Mark that our collector has accumulated all deployments
	// that was completed before this value.
	DeploymentCompletedAtMilestone int64 `json:"deployment_completed_at_milestone"`
}

type ProjectApplicationData struct {
	Applications []*ApplicationData `json:"applications"`
	UpdatedAt    int64              `json:"updated_at"`
}

type Provider interface {
	GetApplicationCounts(ctx context.Context, projectID string) (*ApplicationCounts, error)
	GetDeploymentFrequencyDataPoints(ctx context.Context, projectID, appID string, labels map[string]string, rangeFrom, rangeTo int64, resolution model.InsightResolution) ([]*model.InsightDataPoint, error)
	GetDeploymentChangeFailureRateDataPoints(ctx context.Context, projectID, appID string, labels map[string]string, rangeFrom, rangeTo int64, resolution model.InsightResolution) ([]*model.InsightDataPoint, error)
}

type Store interface {
	ApplicationStore
	CompletedDeploymentStore
}