schemaregistry

package

v0.2.0 Latest Latest Go to latest Published: Apr 20, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/90poe/kafkaobjects-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Client
- func NewClient(options ...Option) (*Client, error)
- func (c *Client) CreateSchema(schema *v1alpha1.KafkaSchemaSpec) error
type Option
- func URL(url string) Option

Constants ¶

View Source

const (
	// SchemaRegistry specific constant
	// Compatibility modes - see https://docs.confluent.io/platform/current/schema-registry/develop/api.html#schemaregistry-api
	KafkaSchemaRegistryCompatibilityBackward      = "BACKWARD"
	KafkaSchemaRegistryCompatibilityBackwardTrans = "BACKWARD_TRANSITIVE"
	KafkaSchemaRegistryCompatibilityForward       = "FORWARD"
	KafkaSchemaRegistryCompatibilityForwardTrans  = "FORWARD_TRANSITIVE"
	KafkaSchemaRegistryCompatibilityFull          = "FULL"
	KafkaSchemaRegistryCompatibilityFullTrans     = "FULL_TRANSITIVE"
	KafkaSchemaRegistryCompatibilityNone          = "NONE"
	// Cache timeout
	CacheConnTimeout = 10 * time.Second
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Client ¶

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

func NewClient ¶

func NewClient(options ...Option) (*Client, error)

func (*Client) CreateSchema ¶

func (c *Client) CreateSchema(schema *v1alpha1.KafkaSchemaSpec) error

CreateSchema creates or updates a schema or returns an error

type Option ¶

type Option func(*Client) error

Option is a type of options for Client

func URL ¶

func URL(url string) Option

SchemeRegistryURL allows the Schema Registry URL to be set

Source Files ¶

View all Source files

client.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL