provider

Documentation

Index

• Variables
• func ImportVariablesTf(mode ImporterMode, outputPath string) error
• func New(version, userAgent string) func() *schema.Provider
• func ResponseHasExpectedStatusCode(response *http.Response, expectedStatusCode int) bool
• func ResponseHasStatusForbiddenDueToInvalidAPIKey(response *http.Response) bool
• func SetSchemaDiff(ctx context.Context, diff *schema.ResourceDiff, meta interface{}) error
• func SleepIfNotTestMode(d time.Duration, isAcceptanceTestMode bool)
• type Acl
• type Client
• type ClusterLinkMetadata
• type FlinkRestClient
• type FlinkRestClientFactory
  • func (f FlinkRestClientFactory) CreateFlinkRestClient(...) *FlinkRestClient
• type GenericOpenAPIError
• type Importer
  • func (r *Importer) LoadInstances(ctx context.Context, client *Client) diag.Diagnostics
• type ImporterMode
• type InstanceId
• type InstanceIdsToNameMap
• type InstanceName
• type KafkaRestClient
• type KafkaRestClientFactory
  • func (f KafkaRestClientFactory) CreateKafkaRestClient(restEndpoint, clusterId, clusterApiKey, clusterApiSecret string, ...) *KafkaRestClient
• type LoadInstanceIdsFunc
• type RetryableClientFactory
  • func NewRetryableClientFactory(ctx context.Context, opts ...RetryableClientFactoryOption) *RetryableClientFactory
  • func (f RetryableClientFactory) CreateRetryableClient() *http.Client
• type RetryableClientFactoryOption
  • func WithMaxRetries(maxRetries int) RetryableClientFactoryOption
• type SchemaRegistryRestClient
• type SchemaRegistryRestClientFactory
  • func (f SchemaRegistryRestClientFactory) CreateDataCatalogClient(restEndpoint, clusterId, clusterApiKey, clusterApiSecret string, ...) *SchemaRegistryRestClient
  • func (f SchemaRegistryRestClientFactory) CreateSchemaRegistryRestClient(restEndpoint, clusterId, clusterApiKey, clusterApiSecret string, ...) *SchemaRegistryRestClient
• type WiremockContainer

Variables

var ImportableResources = []string{

	"confluent_service_account",
	"confluent_kafka_cluster",
	"confluent_environment",
	"confluent_connector",

	"confluent_kafka_topic",
	"confluent_kafka_acl",

	"confluent_schema",
}

Functions

func ImportVariablesTf

func ImportVariablesTf(mode ImporterMode, outputPath string) error

func New

func New(version, userAgent string) func() *schema.Provider

func ResponseHasExpectedStatusCode

func ResponseHasExpectedStatusCode(response *http.Response, expectedStatusCode int) bool

func ResponseHasStatusForbiddenDueToInvalidAPIKey

func ResponseHasStatusForbiddenDueToInvalidAPIKey(response *http.Response) bool

Reports whether the response has http.StatusForbidden status due to an invalid Cloud API Key vs other reasons which is useful to distinguish from scenarios where http.StatusForbidden represents http.StatusNotFound for security purposes.

func SetSchemaDiff

func SetSchemaDiff(ctx context.Context, diff *schema.ResourceDiff, meta interface{}) error

func SleepIfNotTestMode

func SleepIfNotTestMode(d time.Duration, isAcceptanceTestMode bool)

Types

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

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

type FlinkRestClient

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

type FlinkRestClientFactory

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

func (FlinkRestClientFactory) CreateFlinkRestClient

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

type GenericOpenAPIError

type GenericOpenAPIError interface {
	Model() interface{}
}

type Importer

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 (*Importer) LoadInstances

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

type ImporterMode

type ImporterMode int

const (
	Cloud ImporterMode = iota
	Kafka
	SchemaRegistry
)

type InstanceId

type InstanceId string

type InstanceIdsToNameMap

type InstanceIdsToNameMap map[string]string

type InstanceName

type InstanceName string

type KafkaRestClient

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

type KafkaRestClientFactory

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

func (KafkaRestClientFactory) CreateKafkaRestClient

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

type LoadInstanceIdsFunc

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

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

func NewRetryableClientFactory

func NewRetryableClientFactory(ctx context.Context, opts ...RetryableClientFactoryOption) *RetryableClientFactory

func (RetryableClientFactory) CreateRetryableClient

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

CreateRetryableClient creates retryable HTTP client that performs automatic retries with exponential backoff for 429 and 5** (except 501) errors. Otherwise, the response is returned and left to the caller to interpret.

type RetryableClientFactoryOption

type RetryableClientFactoryOption = func(c *RetryableClientFactory)

func WithMaxRetries

func WithMaxRetries(maxRetries int) RetryableClientFactoryOption

type SchemaRegistryRestClient

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

type SchemaRegistryRestClientFactory

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

func (SchemaRegistryRestClientFactory) CreateDataCatalogClient

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

func (SchemaRegistryRestClientFactory) CreateSchemaRegistryRestClient

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

type WiremockContainer

type WiremockContainer struct {
	testcontainers.Container
	URI string
}