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
- type RetryableClientFactoryOption
- type SchemaRegistryRestClient
- type SchemaRegistryRestClientFactory
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ResponseHasStatusForbiddenDueToInvalidAPIKey ¶
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
}
Source Files
Click to show internal directories.
Click to hide internal directories.