feat(dlq): update kubejob entropy model

entropy/job.go

@@ -0,0 +1,39 @@
+package entropy
+
+type JobConfig struct {
+	Stopped    bool              `json:"stopped,omitempty"`
+	Replicas   int32             `json:"replicas"`
+	Namespace  string            `json:"namespace,omitempty"`
+	Name       string            `json:"name,omitempty"`
+	Containers []JobContainer    `json:"containers,omitempty"`
+	JobLabels  map[string]string `json:"job_labels,omitempty"`
+	Volumes    []JobVolume       `json:"volumes,omitempty"`
+}
+
+type JobVolume struct {
+	Name string
+	Kind string // secret or config-map. secret is for gcs/bq credential
+}
+
+type JobContainer struct {
+	Name              string            `json:"name"`
+	Image             string            `json:"image"`
+	ImagePullPolicy   string            `json:"image_pull_policy,omitempty"`
+	Command           []string          `json:"command,omitempty"`
+	SecretsVolumes    []JobSecret       `json:"secrets_volumes,omitempty"`
+	ConfigMapsVolumes []JobConfigMap    `json:"config_maps_volumes,omitempty"`
+	Limits            *UsageSpec        `json:"limits,omitempty"`
+	Requests          *UsageSpec        `json:"requests,omitempty"`
+	EnvConfigMaps     []string          `json:"env_config_maps,omitempty"`
+	EnvVariables      map[string]string `json:"env_variables,omitempty"`
+}
+
+type JobSecret struct {
+	Name  string `json:"name"`
+	Mount string `json:"mount"`
+}
+
+type JobConfigMap struct {
+	Name  string `json:"name"`
+	Mount string `json:"mount"`
+}

entropy/kind.go

@@ -0,0 +1,6 @@
+package entropy
+
+const (
+	ResourceKindFirehose = "firehose"
+	ResourceKindJob      = "job"
+)

swagger.yml

@@ -1242,7 +1242,8 @@ definitions:
         type: string
       resource_type:
         type: string
-        default: firehose
+        enum:
+          - firehose
       error_types:
         type: string
         description: "List of firehose error types, comma separated"