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 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 ToBaseTypesStringMap(in map[string]string) map[string]types.String
• func ToStringList(configured []interface{}) []string
• type DatahubErrorPayload
• type DatalakeErrorPayload
• type EnvironmentErrorPayload
• 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 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 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 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