eventhubs

Documentation

Index

• type Registry
  • func NewRegistry(uri string) *Registry
  • func (r *Registry) AquireTargets(filter schemav1alpha1.TargetFilter) (schemav1alpha1.ClusterTargets, error)
  • func (r *Registry) CreateExecConfiguration(targets schemav1alpha1.ClusterTargets, cfgMap *v1.ConfigMap, ...) (schemav1alpha1.ExecutionConfiguration, error)
  • func (r *Registry) Execute(targets schemav1alpha1.ClusterTargets, ...) (schemav1alpha1.ClusterTargets, error)

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

func (r *Registry) AquireTargets(filter schemav1alpha1.TargetFilter) (schemav1alpha1.ClusterTargets, error)

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

func (r *Registry) Execute(targets schemav1alpha1.ClusterTargets, config schemav1alpha1.ExecutionConfiguration) (schemav1alpha1.ClusterTargets, error)

Execute registers the given schema in the schema registry