utils

Apr 29, 2024

Changes in this version

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

+ type IamErrorPayload interface

+ GetPayload func() *iammodels.Error

Mar 28, 2024

Changes in this version

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

+ func Int64To32Pointer(in types.Int64) *int32

+ type DatabaseErrorPayload interface

+ GetPayload func() *opdbmodels.Error

Feb 26, 2024

Changes in this version

type PollingOptions

+ Async types.Bool

Dec 6, 2023

Changes in this version

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

+ func Concat(strs ...string) string

Sep 12, 2023

Changes in this version

+ var ErrQueueEmpty = fmt.Errorf("QUEUE EMPTY")

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

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

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

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

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

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

+ func ContainsEitherSubstring(slice []string, elements []string) bool

+ func FromListValueToStringList(tl types.List) []string

+ func FromSetValueToStringList(tl types.Set) []string

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

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

+ func GetMapFromSingleItemList(d *schema.ResourceData, name string) (map[string]interface{}, error)

+ func GetMapFromSingleItemListInMap(d map[string]interface{}, name string) (map[string]interface{}, error)

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

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

+ func ReadFileContent(ctx context.Context, path string) (*string, error)

+ func ToBaseTypesStringMap(in map[string]string) map[string]types.String

+ func ToStringList(configured []interface{}) []string

+ type DatahubErrorPayload interface

+ GetPayload func() *datahubmodels.Error

+ type DatalakeErrorPayload interface

+ GetPayload func() *datalakemodels.Error

+ type EnvironmentErrorPayload interface

+ GetPayload func() *environmentsmodels.Error

+ type PollingOptions struct

+ PollingTimeout types.Int64

+ type Queue interface

+ Dequeue func() (T, error)

+ Enqueue func(T) error

+ Len func() int

+ func NewSliceQueue() Queue[T]

+ type SliceQueue []T

+ func (q *SliceQueue[T]) Dequeue() (T, error)

+ func (q *SliceQueue[T]) Enqueue(value T) error

+ func (q *SliceQueue[T]) Len() int