provider

Documentation

Index

• func New(version, userAgent string) func() *schema.Provider
• func ResponseHasExpectedStatusCode(response *http.Response, expectedStatusCode int) bool
• func ResponseHasStatusForbiddenDueToInvalidAPIKey(response *http.Response) bool
• type Acl
• type Client
• type GenericOpenAPIError
• type KafkaRestClient
• type KafkaRestClientFactory
• type RetryableClientFactory
  • func NewRetryableClientFactory(opts ...RetryableClientFactoryOption) *RetryableClientFactory
  • func (f RetryableClientFactory) CreateRetryableClient() *http.Client
• type RetryableClientFactoryOption
  • func WithMaxRetries(maxRetries int) RetryableClientFactoryOption
• type SchemaRegistryRestClient
• type SchemaRegistryRestClientFactory

Functions

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.

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
}

steal the client setup code from https://github.com/confluentinc/terraform-provider-confluent/blob/master/internal/provider/provider.go

type GenericOpenAPIError

type GenericOpenAPIError interface {
	Model() interface{}
}

type KafkaRestClient

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

type KafkaRestClientFactory

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

type RetryableClientFactory

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

func NewRetryableClientFactory

func NewRetryableClientFactory(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
}