provider

type Acl ¶

type Acl struct {
	ResourceType kafkarestv3.AclResourceType
	ResourceName string
	PatternType  string
	Principal    string
	Host         string
	Operation    string
	Permission   string
}

type Client ¶

type Client struct {
	// contains filtered or unexported fields
}

type ClusterLinkMetadata ¶ added in v1.50.0

type ClusterLinkMetadata struct {
	// contains filtered or unexported fields
}

type FlinkRestClient ¶ added in v1.56.0

type FlinkRestClient struct {
	// contains filtered or unexported fields
}

type FlinkRestClientFactory ¶ added in v1.56.0

type FlinkRestClientFactory struct {
	// contains filtered or unexported fields
}

func (f FlinkRestClientFactory) CreateFlinkRestClient(restEndpoint, organizationId, environmentId, computePoolId, principalId, flinkApiKey, flinkApiSecret string, isMetadataSetInProviderBlock bool) *FlinkRestClient

type GenericOpenAPIError ¶

type GenericOpenAPIError interface {
	Model() interface{}
}

type Importer ¶ added in v1.39.0

type Importer struct {
	LoadInstanceIds LoadInstanceIdsFunc

	// Map of resource id->names. This is set after a call to LoadInstanceIds
	InstanceIdMap InstanceIdsToNameMap
}

Importer is an interface that every Importable resource should implement

func (r *Importer) LoadInstances(ctx context.Context, client *Client) diag.Diagnostics

type ImporterMode ¶ added in v1.39.0

type ImporterMode int

const (
	Cloud ImporterMode = iota
	Kafka
	SchemaRegistry
)

type InstanceId ¶ added in v1.39.0

type InstanceId string

type InstanceIdsToNameMap ¶ added in v1.39.0

type InstanceIdsToNameMap map[string]string

type InstanceName ¶ added in v1.39.0

type InstanceName string

type KafkaRestClient ¶

type KafkaRestClient struct {
	// contains filtered or unexported fields
}

type KafkaRestClientFactory ¶

type KafkaRestClientFactory struct {
	// contains filtered or unexported fields
}

func (f KafkaRestClientFactory) CreateKafkaRestClient(restEndpoint, clusterId, clusterApiKey, clusterApiSecret string, isMetadataSetInProviderBlock, isClusterIdSetInProviderBlock bool) *KafkaRestClient

type LoadInstanceIdsFunc ¶ added in v1.39.0

type LoadInstanceIdsFunc func(context.Context, *Client) (InstanceIdsToNameMap, diag.Diagnostics)

LoadInstanceIdsFunc is a method that returns a map of all instances of a specific resource where key is an instance ID and value is an instance name. For example, this method might return { "sa-abc123": "app-manager", "sa-xyz123: "test" } for confluent_service_account resource.

type RetryableClientFactory ¶ added in v1.17.0

type RetryableClientFactory struct {
	// contains filtered or unexported fields
}

func NewRetryableClientFactory(opts ...RetryableClientFactoryOption) *RetryableClientFactory

func (f RetryableClientFactory) CreateRetryableClient() *http.Client

type RetryableClientFactoryOption ¶ added in v1.17.0

type RetryableClientFactoryOption = func(c *RetryableClientFactory)

func WithMaxRetries(maxRetries int) RetryableClientFactoryOption

type SchemaRegistryRestClient ¶ added in v1.20.0

type SchemaRegistryRestClient struct {
	// contains filtered or unexported fields
}

type SchemaRegistryRestClientFactory ¶ added in v1.20.0

type SchemaRegistryRestClientFactory struct {
	// contains filtered or unexported fields
}

func (f SchemaRegistryRestClientFactory) CreateDataCatalogClient(restEndpoint, clusterId, clusterApiKey, clusterApiSecret string, isMetadataSetInProviderBlock bool) *SchemaRegistryRestClient

func (f SchemaRegistryRestClientFactory) CreateSchemaRegistryRestClient(restEndpoint, clusterId, clusterApiKey, clusterApiSecret string, isMetadataSetInProviderBlock bool) *SchemaRegistryRestClient

type WiremockContainer ¶ added in v1.5.0

type WiremockContainer struct {
	testcontainers.Container
	URI string
}