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 + const DateLayout + const EntityJob + const MetricJobEvent + const MetricJobEventDisabled + const MetricJobEventEnabled + const MetricJobEventStateAdded + const MetricJobEventStateDeleteFailed + const MetricJobEventStateDeleted + const MetricJobEventStateUpdated + const MetricJobEventStateUpsertFailed + const MetricJobEventStateValidationFailed + const MetricJobRefreshResourceDownstream + const UpstreamStateResolved + const UpstreamStateUnresolved + const UpstreamTypeInferred + const UpstreamTypeStatic + func NewLabels(labels map[string]string) (map[string]string, error) + type AlertSpec struct + func NewAlertSpec(on string, channels []string, config Config) (*AlertSpec, error) + func (a AlertSpec) Channels() []string + func (a AlertSpec) Config() Config + func (a AlertSpec) On() string + type Asset map[string]string + func AssetFrom(fileNameToContent map[string]string) (Asset, error) + func (a Asset) Map() map[string]string + type Config map[string]string + func ConfigFrom(configs map[string]string) (Config, error) + func (c Config) Map() map[string]string + type Downstream struct + func NewDownstream(name Name, projectName tenant.ProjectName, namespaceName tenant.NamespaceName, ...) *Downstream + func (d Downstream) FullName() FullName + func (d Downstream) Name() Name + func (d Downstream) NamespaceName() tenant.NamespaceName + func (d Downstream) ProjectName() tenant.ProjectName + func (d Downstream) TaskName() TaskName + type DownstreamList []*Downstream + func (d DownstreamList) GetDownstreamFullNames() FullNames + type FullName string + func FullNameFrom(projectName tenant.ProjectName, jobName Name) FullName + func (f FullName) String() string + type FullNames []FullName + func (f FullNames) String() string + type Hook struct + func NewHook(name string, config Config) (*Hook, error) + func (h Hook) Config() Config + func (h Hook) Name() string + type Job struct + func NewJob(tenant tenant.Tenant, spec *Spec, destination ResourceURN, ...) *Job + func (j *Job) Destination() ResourceURN + func (j *Job) FullName() string + func (j *Job) GetJobWithUnresolvedUpstream() (*WithUpstream, error) + func (j *Job) GetName() string + func (j *Job) ProjectName() tenant.ProjectName + func (j *Job) Sources() []ResourceURN + func (j *Job) Spec() *Spec + func (j *Job) StaticUpstreamNames() []SpecUpstreamName + func (j *Job) Tenant() tenant.Tenant + type Jobs []*Job + func (j Jobs) GetJobNames() []Name + func (j Jobs) GetJobsWithUnresolvedUpstreams() ([]*WithUpstream, error) + func (j Jobs) GetNameAndJobMap() map[Name]*Job + func (j Jobs) GetNameAndSpecMap() map[Name]*Spec + func (j Jobs) GetNamespaceNameAndJobsMap() map[tenant.NamespaceName][]*Job + func (j Jobs) GetSpecs() []*Spec + type Metadata struct + func (m Metadata) Resource() *MetadataResource + func (m Metadata) Scheduler() map[string]string + type MetadataBuilder struct + func NewMetadataBuilder() *MetadataBuilder + func (m *MetadataBuilder) Build() (*Metadata, error) + func (m *MetadataBuilder) WithResource(resource *MetadataResource) *MetadataBuilder + func (m *MetadataBuilder) WithScheduler(scheduler map[string]string) *MetadataBuilder + type MetadataResource struct + func NewResourceMetadata(request, limit *MetadataResourceConfig) *MetadataResource + func (m MetadataResource) Limit() *MetadataResourceConfig + func (m MetadataResource) Request() *MetadataResourceConfig + type MetadataResourceConfig struct + func NewMetadataResourceConfig(cpu, memory string) *MetadataResourceConfig + func (m MetadataResourceConfig) CPU() string + func (m MetadataResourceConfig) Memory() string + type Name string + func NameFrom(name string) (Name, error) + func (n Name) String() string + type ResourceURN string + func (n ResourceURN) String() string + type Retry struct + func NewRetry(count int, delay int32, exponentialBackoff bool) *Retry + func (r Retry) Count() int + func (r Retry) Delay() int32 + func (r Retry) ExponentialBackoff() bool + type Schedule struct + func (s Schedule) DependsOnPast() bool + func (s Schedule) EndDate() ScheduleDate + func (s Schedule) Interval() string + func (s Schedule) Retry() *Retry + func (s Schedule) StartDate() ScheduleDate + type ScheduleBuilder struct + func NewScheduleBuilder(startDate ScheduleDate) *ScheduleBuilder + func (s *ScheduleBuilder) Build() (*Schedule, error) + func (s *ScheduleBuilder) WithDependsOnPast(dependsOnPast bool) *ScheduleBuilder + func (s *ScheduleBuilder) WithEndDate(endDate ScheduleDate) *ScheduleBuilder + func (s *ScheduleBuilder) WithInterval(interval string) *ScheduleBuilder + func (s *ScheduleBuilder) WithRetry(retry *Retry) *ScheduleBuilder + type ScheduleDate string + func ScheduleDateFrom(date string) (ScheduleDate, error) + func (s ScheduleDate) String() string + type Spec struct + func (s *Spec) AlertSpecs() []*AlertSpec + func (s *Spec) Asset() Asset + func (s *Spec) Description() string + func (s *Spec) Hooks() []*Hook + func (s *Spec) Labels() map[string]string + func (s *Spec) Metadata() *Metadata + func (s *Spec) Name() Name + func (s *Spec) Owner() string + func (s *Spec) Schedule() *Schedule + func (s *Spec) Task() Task + func (s *Spec) UpstreamSpec() *UpstreamSpec + func (s *Spec) Version() int + func (s *Spec) Window() models.Window + type SpecBuilder struct + func NewSpecBuilder(version int, name Name, owner string, schedule *Schedule, window models.Window, ...) *SpecBuilder + func (s *SpecBuilder) Build() (*Spec, error) + func (s *SpecBuilder) WithAlerts(alerts []*AlertSpec) *SpecBuilder + func (s *SpecBuilder) WithAsset(asset Asset) *SpecBuilder + func (s *SpecBuilder) WithDescription(description string) *SpecBuilder + func (s *SpecBuilder) WithHooks(hooks []*Hook) *SpecBuilder + func (s *SpecBuilder) WithLabels(labels map[string]string) *SpecBuilder + func (s *SpecBuilder) WithMetadata(metadata *Metadata) *SpecBuilder + func (s *SpecBuilder) WithSpecUpstream(specUpstream *UpstreamSpec) *SpecBuilder + type SpecHTTPUpstream struct + func (s SpecHTTPUpstream) Headers() map[string]string + func (s SpecHTTPUpstream) Name() string + func (s SpecHTTPUpstream) Params() map[string]string + func (s SpecHTTPUpstream) URL() string + type SpecHTTPUpstreamBuilder struct + func NewSpecHTTPUpstreamBuilder(name, url string) *SpecHTTPUpstreamBuilder + func (s *SpecHTTPUpstreamBuilder) Build() (*SpecHTTPUpstream, error) + func (s *SpecHTTPUpstreamBuilder) WithHeaders(headers map[string]string) *SpecHTTPUpstreamBuilder + func (s *SpecHTTPUpstreamBuilder) WithParams(params map[string]string) *SpecHTTPUpstreamBuilder + type SpecUpstreamBuilder struct + func NewSpecUpstreamBuilder() *SpecUpstreamBuilder + func (s *SpecUpstreamBuilder) Build() (*UpstreamSpec, error) + func (s *SpecUpstreamBuilder) WithSpecHTTPUpstream(httpUpstreams []*SpecHTTPUpstream) *SpecUpstreamBuilder + func (s *SpecUpstreamBuilder) WithUpstreamNames(names []SpecUpstreamName) *SpecUpstreamBuilder + type SpecUpstreamName string + func SpecUpstreamNameFrom(specUpstreamName string) SpecUpstreamName + func (s SpecUpstreamName) GetJobName() (Name, error) + func (s SpecUpstreamName) GetProjectName() (tenant.ProjectName, error) + func (s SpecUpstreamName) IsWithProjectName() bool + func (s SpecUpstreamName) String() string + type Specs []*Spec + func (s Specs) GetValid() []*Spec + func (s Specs) ToFullNameAndSpecMap(projectName tenant.ProjectName) map[FullName]*Spec + func (s Specs) ToNameAndSpecMap() map[Name]*Spec + func (s Specs) Validate() error + type State string + const DISABLED + const ENABLED + func StateFrom(name string) (State, error) + func (n State) String() string + type Task struct + func NewTask(name TaskName, config Config) Task + func (t Task) Config() Config + func (t Task) Name() TaskName + type TaskName string + func TaskNameFrom(name string) (TaskName, error) + func (t TaskName) String() string + type Upstream struct + func NewUpstreamResolved(name Name, host string, resource ResourceURN, jobTenant tenant.Tenant, ...) *Upstream + func NewUpstreamUnresolvedInferred(resource ResourceURN) *Upstream + func NewUpstreamUnresolvedStatic(name Name, projectName tenant.ProjectName) *Upstream + func (u *Upstream) External() bool + func (u *Upstream) FullName() string + func (u *Upstream) Host() string + func (u *Upstream) Name() Name + func (u *Upstream) NamespaceName() tenant.NamespaceName + func (u *Upstream) ProjectName() tenant.ProjectName + func (u *Upstream) Resource() ResourceURN + func (u *Upstream) State() UpstreamState + func (u *Upstream) TaskName() TaskName + func (u *Upstream) Type() UpstreamType + type UpstreamSpec struct + func (s UpstreamSpec) HTTPUpstreams() []*SpecHTTPUpstream + func (s UpstreamSpec) UpstreamNames() []SpecUpstreamName + type UpstreamState string + func (d UpstreamState) String() string + type UpstreamType string + func UpstreamTypeFrom(str string) (UpstreamType, error) + func (d UpstreamType) String() string + type Upstreams []*Upstream + func (u Upstreams) Deduplicate() []*Upstream + func (u Upstreams) ToFullNameAndUpstreamMap() map[string]*Upstream + func (u Upstreams) ToResourceDestinationAndUpstreamMap() map[string]*Upstream + type WithUpstream struct + func NewWithUpstream(job *Job, upstreams []*Upstream) *WithUpstream + func (w WithUpstream) GetName() string + func (w WithUpstream) GetResolvedUpstreams() []*Upstream + func (w WithUpstream) GetUnresolvedUpstreams() []*Upstream + func (w WithUpstream) Job() *Job + func (w WithUpstream) Name() Name + func (w WithUpstream) Upstreams() []*Upstream + type WithUpstreams []*WithUpstream + func (w WithUpstreams) GetSubjectJobNames() []Name + func (w WithUpstreams) MergeWithResolvedUpstreams(resolvedUpstreamsBySubjectJobMap map[Name][]*Upstream) []*WithUpstream
Go to main page