utils

Documentation

Index

• Variables
• func AddDatabaseDiagnosticsError(err error, diagnostics *diag.Diagnostics, errMsg string)
• func AddDatahubDiagnosticsError(err error, diagnostics *diag.Diagnostics, errMsg string)
• func AddDatalakeDiagnosticsError(err error, diagnostics *diag.Diagnostics, errMsg string)
• func AddDeDiagnosticsError(err error, diagnostics *diag.Diagnostics, errMsg string)
• func AddEnvironmentDiagnosticsError(err error, diagnostics *diag.Diagnostics, errMsg string)
• func AddIamDiagnosticsError(err error, diagnostics *diag.Diagnostics, errMsg string)
• func AddMlDiagnosticsError(err error, diagnostics *diag.Diagnostics, errMsg string)
• func Append(to map[string]schema.Attribute, from map[string]schema.Attribute)
• func CalculateCallFailureThresholdOrDefault(ctx context.Context, options *PollingOptions, fallback int) (int, error)
• func CalculateTimeoutOrDefault(ctx context.Context, options *PollingOptions, fallback time.Duration) (*time.Duration, error)
• func CheckStringEquals(name string, expected string, actual string) error
• func Concat(strs ...string) string
• func ContainsAsSubstring(slice []string, element string) bool
• func FromListValueToStringList(tl types.List) []string
• func FromMapValueToStringMap(tl types.Map) map[string]string
• func FromSetValueToStringList(tl types.Set) []string
• func GetCallFailureThreshold[T HasPollingOptions](p T, fallback int) int
• func GetCdpClientForDataSource(req datasource.ConfigureRequest, resp *datasource.ConfigureResponse) *cdp.Client
• func GetCdpClientForResource(req resource.ConfigureRequest, resp *resource.ConfigureResponse) *cdp.Client
• func GetPollingTimeout[T HasPollingOptions](p T, fallback time.Duration) time.Duration
• func Int64To32Pointer(in types.Int64) *int32
• func IsNonRetryableError(code int) bool
• func IsRetryableError(code int) bool
• func LogEnvironmentSilently(ctx context.Context, content *environmentsmodels.Environment, ...) *environmentsmodels.Environment
• func LogSilently(ctx context.Context, messagePrefix string, in any)
• type DatabaseErrorPayload
• type DatahubErrorPayload
• type DatalakeErrorPayload
• type DeErrorPayload
• type EnvironmentErrorPayload
• type HasPollingOptions
• type IamErrorPayload
• type MlErrorPayload
• type PollingOptions

Variables

var NonRetryableErrorCodes = [...]int{403}

Functions

func AddDatabaseDiagnosticsError

func AddDatabaseDiagnosticsError(err error, diagnostics *diag.Diagnostics, errMsg string)

func AddDatahubDiagnosticsError

func AddDatahubDiagnosticsError(err error, diagnostics *diag.Diagnostics, errMsg string)

func AddDatalakeDiagnosticsError

func AddDatalakeDiagnosticsError(err error, diagnostics *diag.Diagnostics, errMsg string)

func AddDeDiagnosticsError

func AddDeDiagnosticsError(err error, diagnostics *diag.Diagnostics, errMsg string)

func AddEnvironmentDiagnosticsError

func AddEnvironmentDiagnosticsError(err error, diagnostics *diag.Diagnostics, errMsg string)

func AddIamDiagnosticsError

func AddIamDiagnosticsError(err error, diagnostics *diag.Diagnostics, errMsg string)

func AddMlDiagnosticsError

func AddMlDiagnosticsError(err error, diagnostics *diag.Diagnostics, errMsg string)

func Append

func Append(to map[string]schema.Attribute, from map[string]schema.Attribute)

func CalculateCallFailureThresholdOrDefault

func CalculateCallFailureThresholdOrDefault(ctx context.Context, options *PollingOptions, fallback int) (int, error)

func CalculateTimeoutOrDefault

func CalculateTimeoutOrDefault(ctx context.Context, options *PollingOptions, fallback time.Duration) (*time.Duration, error)

func CheckStringEquals

func CheckStringEquals(name string, expected string, actual string) error

CheckStringEquals checks whether two strings are equal and returns nil if so, and an error otherwise.

func Concat

func Concat(strs ...string) string

Concat concatenates input strings

func ContainsAsSubstring

func ContainsAsSubstring(slice []string, element string) bool

func FromListValueToStringList

func FromListValueToStringList(tl types.List) []string

func FromMapValueToStringMap

func FromMapValueToStringMap(tl types.Map) map[string]string

func FromSetValueToStringList

func FromSetValueToStringList(tl types.Set) []string

func GetCallFailureThreshold

func GetCallFailureThreshold[T HasPollingOptions](p T, fallback int) int

GetCallFailureThreshold returns the call failure threshold from the given polling options or the fallback value. In case a negative value is given, it will be treated as zero.

func GetCdpClientForDataSource

func GetCdpClientForDataSource(req datasource.ConfigureRequest, resp *datasource.ConfigureResponse) *cdp.Client

func GetCdpClientForResource

func GetCdpClientForResource(req resource.ConfigureRequest, resp *resource.ConfigureResponse) *cdp.Client

func GetPollingTimeout

func GetPollingTimeout[T HasPollingOptions](p T, fallback time.Duration) time.Duration

GetPollingTimeout returns the polling timeout from the given polling options or the fallback value. In case a negative value is given, it will be treated as one minute.

func Int64To32Pointer

func Int64To32Pointer(in types.Int64) *int32

func IsNonRetryableError

func IsNonRetryableError(code int) bool

func IsRetryableError

func IsRetryableError(code int) bool

func LogEnvironmentSilently

func LogEnvironmentSilently(ctx context.Context, content *environmentsmodels.Environment, messagePrefix string) *environmentsmodels.Environment

func LogSilently

func LogSilently(ctx context.Context, messagePrefix string, in any)

Types

type DatabaseErrorPayload

type DatabaseErrorPayload interface {
	GetPayload() *opdbmodels.Error
}

type DatahubErrorPayload

type DatahubErrorPayload interface {
	GetPayload() *datahubmodels.Error
}

type DatalakeErrorPayload

type DatalakeErrorPayload interface {
	GetPayload() *datalakemodels.Error
}

type DeErrorPayload

type DeErrorPayload interface {
	GetPayload() *demodels.Error
}

type EnvironmentErrorPayload

type EnvironmentErrorPayload interface {
	GetPayload() *environmentsmodels.Error
}

type HasPollingOptions

type HasPollingOptions interface {
	GetPollingOptions() *PollingOptions
}

type IamErrorPayload

type IamErrorPayload interface {
	GetPayload() *iammodels.Error
}

type MlErrorPayload

type MlErrorPayload interface {
	GetPayload() *mlmodels.Error
}

type PollingOptions

type PollingOptions struct {
	Async                types.Bool  `tfsdk:"async"`
	PollingTimeout       types.Int64 `tfsdk:"polling_timeout"`
	CallFailureThreshold types.Int64 `tfsdk:"call_failure_threshold"`
}