eventhubs

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 27, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Registry

type Registry struct {
	Endpoint string
}

Registry represents eventhub schema `Registry` object

func NewRegistry

func NewRegistry(uri string) *Registry

NewRegistry returns a new eventhub schema `Registry` object

func (*Registry) AquireTargets

AquireTargets for eventhubs is a no-op function (required by the interface)

func (*Registry) CreateExecConfiguration

func (r *Registry) CreateExecConfiguration(targets schemav1alpha1.ClusterTargets, cfgMap *v1.ConfigMap, failIfDataLoss bool) (schemav1alpha1.ExecutionConfiguration, error)

CreateExecConfiguration creates `ExecutionConfiguration` from the schema in the `ConfigMap`

func (*Registry) Execute

Execute registers the given schema in the schema registry

Directories

Path Synopsis
azure
schemaregistry
Package schemaregistry implements the Azure ARM Schemaregistry service API version 2021-10.
Package schemaregistry implements the Azure ARM Schemaregistry service API version 2021-10.

Jump to

Keyboard shortcuts

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