pipelines

Documentation

Index

• Constants
• func Create(w *databricks.WorkspaceClient, ctx context.Context, d *schema.ResourceData, ...) error
• func DataSourcePipelines() common.Resource
• func Delete(w *databricks.WorkspaceClient, ctx context.Context, id string, ...) error
• func Read(w *databricks.WorkspaceClient, ctx context.Context, id string) (*pipelines.GetPipelineResponse, error)
• func ResourcePipeline() common.Resource
• func Update(w *databricks.WorkspaceClient, ctx context.Context, d *schema.ResourceData, ...) error
• type Pipeline
  • func (Pipeline) Aliases() map[string]map[string]string
  • func (Pipeline) CustomizeSchema(s *common.CustomizableSchema) *common.CustomizableSchema

Constants

const DefaultTimeout = 20 * time.Minute

DefaultTimeout is the default amount of time that Terraform will wait when creating, updating and deleting pipelines.

Functions

func Create

func Create(w *databricks.WorkspaceClient, ctx context.Context, d *schema.ResourceData, timeout time.Duration) error

func DataSourcePipelines

func DataSourcePipelines() common.Resource

func Delete

func Delete(w *databricks.WorkspaceClient, ctx context.Context, id string, timeout time.Duration) error

func Read

func Read(w *databricks.WorkspaceClient, ctx context.Context, id string) (*pipelines.GetPipelineResponse, error)

func ResourcePipeline

func ResourcePipeline() common.Resource

func Update

func Update(w *databricks.WorkspaceClient, ctx context.Context, d *schema.ResourceData, timeout time.Duration) error

Types

type Pipeline

type Pipeline struct {
	pipelines.PipelineSpec
	AllowDuplicateNames  bool                                `json:"allow_duplicate_names,omitempty"`
	Cause                string                              `json:"cause,omitempty"`
	ClusterId            string                              `json:"cluster_id,omitempty"`
	CreatorUserName      string                              `json:"creator_user_name,omitempty"`
	Health               pipelines.GetPipelineResponseHealth `json:"health,omitempty"`
	LastModified         int64                               `json:"last_modified,omitempty"`
	LatestUpdates        []pipelines.UpdateStateInfo         `json:"latest_updates,omitempty"`
	RunAs                *pipelines.RunAs                    `json:"run_as,omitempty"`
	RunAsUserName        string                              `json:"run_as_user_name,omitempty"`
	ExpectedLastModified int64                               `json:"expected_last_modified,omitempty"`
	State                pipelines.PipelineState             `json:"state,omitempty"`
	// Provides the URL to the pipeline in the Databricks UI.
	URL string `json:"url,omitempty"`
}

func (Pipeline) Aliases

func (Pipeline) Aliases() map[string]map[string]string

func (Pipeline) CustomizeSchema

func (Pipeline) CustomizeSchema(s *common.CustomizableSchema) *common.CustomizableSchema