Versions in this module Expand all Collapse all v0 v0.7.1 Jul 25, 2023 v0.7.0 Jul 20, 2023 Changes in this version + type JobSpec struct + Asset map[string]string + Behavior JobSpecBehavior + Dependencies []JobSpecDependency + Description string + Hooks []JobSpecHook + Labels map[string]string + Metadata *JobSpecMetadata + Name string + Owner string + Path string + Schedule JobSpecSchedule + Task JobSpecTask + Version int + func ToJobSpec(protoSpec *pb.JobSpecification) *JobSpec + func (j *JobSpec) MergeFrom(anotherJobSpec *JobSpec) + func (j *JobSpec) ToProto() *pb.JobSpecification + type JobSpecBehavior struct + DependsOnPast bool + Notify []JobSpecBehaviorNotifier + Retry *JobSpecBehaviorRetry + type JobSpecBehaviorNotifier struct + Channels []string + Config map[string]string + On string + type JobSpecBehaviorRetry struct + Count int + Delay time.Duration + ExponentialBackoff bool + type JobSpecDependency struct + HTTP *JobSpecDependencyHTTP + JobName string + Type string + type JobSpecDependencyHTTP struct + Headers map[string]string + Name string + RequestParams map[string]string + URL string + type JobSpecHook struct + Config map[string]string + Name string + type JobSpecMetadata struct + Airflow *JobSpecMetadataAirflow + Resource *JobSpecMetadataResource + type JobSpecMetadataAirflow struct + Pool string + Queue string + type JobSpecMetadataResource struct + Limit *JobSpecMetadataResourceConfig + Request *JobSpecMetadataResourceConfig + type JobSpecMetadataResourceConfig struct + CPU string + Memory string + type JobSpecSchedule struct + EndDate string + Interval string + StartDate string + type JobSpecTask struct + Config map[string]string + Name string + Window JobSpecTaskWindow + type JobSpecTaskWindow struct + Offset string + Size string + TruncateTo string + type ResourceSpec struct + Labels map[string]string + Name string + Path string + Spec map[string]interface{} + Type string + Version int + func (r ResourceSpec) ToProto() (*pb.ResourceSpecification, error)
Go to main page