dataset

type AdvanceParams struct {
	Namespace string
	Name      string
	Watermark string
}

type AdvanceResult struct {
	Outcome freshness.Outcome   `json:"outcome"`
	State   models.DatasetState `json:"state"`
}

type DerivationsParams struct {
	Namespace string
	Name      string
	Limit     int
	Offset    int
}

type DerivationsResult struct {
	Derivations []models.DatasetDerivation `json:"derivations"`
	Total       int64                      `json:"total"`
	Limit       int                        `json:"limit"`
	Offset      int                        `json:"offset"`
}

type Detail struct {
	State        models.DatasetState        `json:"state"`
	Declaration  *models.DatasetDeclaration `json:"declaration,omitempty"`
	SLO          *SLO                       `json:"slo,omitempty"`
	Producing    *ProducingJob              `json:"producing_job,omitempty"`
	LastDecision *models.DatasetDerivation  `json:"last_decision,omitempty"`
}

type ListParams struct {
	Status string
	Limit  int
	Offset int
}

type ListResult struct {
	Datasets []models.DatasetState `json:"datasets"`
	Total    int64                 `json:"total"`
	Limit    int                   `json:"limit"`
	Offset   int                   `json:"offset"`
}

type ProducingJob struct {
	ID       uuid.UUID `json:"id"`
	Alias    string    `json:"alias"`
	StepName string    `json:"step_name,omitempty"`
}

type SLO struct {
	Freshness     string `json:"freshness,omitempty"`
	MaxStaleness  string `json:"max_staleness,omitempty"`
	ExpectedEvery string `json:"expected_every,omitempty"`
}

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