utils

Documentation

Index

• Variables
• 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 CheckStringEquals(name string, expected string, actual string) error
• func Concat(strs ...string) string
• 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
• type DatalakeErrorPayload
• type EnvironmentErrorPayload
• type PollingOptions
• type Queue
  • func NewSliceQueue[T any]() Queue[T]
• type SliceQueue
  • func (q *SliceQueue[T]) Dequeue() (T, error)
  • func (q *SliceQueue[T]) Enqueue(value T) error
  • func (q *SliceQueue[T]) Len() int

Variables

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

Functions

func AddDatahubDiagnosticsError

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

func AddDatalakeDiagnosticsError

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

func AddEnvironmentDiagnosticsError

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

func Append

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

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 ContainsEitherSubstring

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

func FromListValueToStringList

func FromListValueToStringList(tl types.List) []string

func FromSetValueToStringList

func FromSetValueToStringList(tl types.Set) []string

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 GetMapFromSingleItemList

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

func GetMapFromSingleItemListInMap

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

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)

func ReadFileContent

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

func ToBaseTypesStringMap

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

func ToStringList

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

Types

type DatahubErrorPayload

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

type DatalakeErrorPayload

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

type EnvironmentErrorPayload

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

type PollingOptions

type PollingOptions struct {
	PollingTimeout types.Int64 `tfsdk:"polling_timeout"`
}

type Queue

type Queue[T any] interface {
	Enqueue(T) error
	Dequeue() (T, error)
	Len() int
}

func NewSliceQueue

func NewSliceQueue[T any]() Queue[T]

type SliceQueue

type SliceQueue[T any] []T

func (*SliceQueue[T]) Dequeue

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

func (*SliceQueue[T]) Enqueue

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

func (*SliceQueue[T]) Len

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