dataproc

Documentation

Index

• func DataprocClusterOperationWait(config *transport_tpg.Config, op *dataproc.Operation, ...) error
• func DataprocDeleteOperationWait(config *transport_tpg.Config, ...) error
• func DataprocJobOperationWait(config *transport_tpg.Config, ...) error
• func ResourceDataprocCluster() *schema.Resource
• func ResourceDataprocClusterStateUpgradeV0(_ context.Context, rawState map[string]interface{}, meta interface{}) (map[string]interface{}, error)
• type DataprocClusterOperationWaiter
  • func (w *DataprocClusterOperationWaiter) QueryOp() (interface{}, error)
• type DataprocDeleteJobOperationWaiter
  • func (w *DataprocDeleteJobOperationWaiter) PendingStates() []string
  • func (w *DataprocDeleteJobOperationWaiter) QueryOp() (interface{}, error)
  • func (w *DataprocDeleteJobOperationWaiter) TargetStates() []string
• type DataprocJobOperationWaiter
  • func (w *DataprocJobOperationWaiter) Error() error
  • func (w *DataprocJobOperationWaiter) IsRetryable(error) bool
  • func (w *DataprocJobOperationWaiter) OpName() string
  • func (w *DataprocJobOperationWaiter) PendingStates() []string
  • func (w *DataprocJobOperationWaiter) QueryOp() (interface{}, error)
  • func (w *DataprocJobOperationWaiter) SetOp(job interface{}) error
  • func (w *DataprocJobOperationWaiter) State() string
  • func (w *DataprocJobOperationWaiter) TargetStates() []string

Functions

func DataprocClusterOperationWait

func DataprocClusterOperationWait(config *transport_tpg.Config, op *dataproc.Operation, activity, userAgent string, timeout time.Duration) error

func DataprocDeleteOperationWait

func DataprocDeleteOperationWait(config *transport_tpg.Config, region, projectId, jobId, activity, userAgent string, timeout time.Duration) error

func DataprocJobOperationWait

func DataprocJobOperationWait(config *transport_tpg.Config, region, projectId, jobId, activity, userAgent string, timeout time.Duration) error

func ResourceDataprocCluster

func ResourceDataprocCluster() *schema.Resource

func ResourceDataprocClusterStateUpgradeV0

func ResourceDataprocClusterStateUpgradeV0(_ context.Context, rawState map[string]interface{}, meta interface{}) (map[string]interface{}, error)

Types

type DataprocClusterOperationWaiter

type DataprocClusterOperationWaiter struct {
	Service *dataproc.Service
	tpgresource.CommonOperationWaiter
}

func (*DataprocClusterOperationWaiter) QueryOp

func (w *DataprocClusterOperationWaiter) QueryOp() (interface{}, error)

type DataprocDeleteJobOperationWaiter

type DataprocDeleteJobOperationWaiter struct {
	DataprocJobOperationWaiter
}

func (*DataprocDeleteJobOperationWaiter) PendingStates

func (w *DataprocDeleteJobOperationWaiter) PendingStates() []string

func (*DataprocDeleteJobOperationWaiter) QueryOp

func (w *DataprocDeleteJobOperationWaiter) QueryOp() (interface{}, error)

func (*DataprocDeleteJobOperationWaiter) TargetStates

func (w *DataprocDeleteJobOperationWaiter) TargetStates() []string

type DataprocJobOperationWaiter

type DataprocJobOperationWaiter struct {
	Service   *dataproc.Service
	Region    string
	ProjectId string
	JobId     string
	Status    string
}

func (*DataprocJobOperationWaiter) Error

func (w *DataprocJobOperationWaiter) Error() error

func (*DataprocJobOperationWaiter) IsRetryable

func (w *DataprocJobOperationWaiter) IsRetryable(error) bool

func (*DataprocJobOperationWaiter) OpName

func (w *DataprocJobOperationWaiter) OpName() string

func (*DataprocJobOperationWaiter) PendingStates

func (w *DataprocJobOperationWaiter) PendingStates() []string

func (*DataprocJobOperationWaiter) QueryOp

func (w *DataprocJobOperationWaiter) QueryOp() (interface{}, error)

func (*DataprocJobOperationWaiter) SetOp

func (w *DataprocJobOperationWaiter) SetOp(job interface{}) error

func (*DataprocJobOperationWaiter) State

func (w *DataprocJobOperationWaiter) State() string

func (*DataprocJobOperationWaiter) TargetStates

func (w *DataprocJobOperationWaiter) TargetStates() []string