schema_registry

package
v0.7.2 Latest Latest
Warning

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

Go to latest
Published: Apr 7, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewScanSchemaRegistryCmd

func NewScanSchemaRegistryCmd() *cobra.Command

Types

type GlueSchemaRegistryScanner added in v0.7.2

type GlueSchemaRegistryScanner struct {
	GlueService GlueSchemaRegistryScannerService

	StateFile    string
	State        types.State
	Region       string
	RegistryName string
}

func NewGlueSchemaRegistryScanner added in v0.7.2

func NewGlueSchemaRegistryScanner(glueService GlueSchemaRegistryScannerService, opts GlueSchemaRegistryScannerOpts) *GlueSchemaRegistryScanner

func (*GlueSchemaRegistryScanner) Run added in v0.7.2

type GlueSchemaRegistryScannerOpts added in v0.7.2

type GlueSchemaRegistryScannerOpts struct {
	StateFile    string
	State        types.State
	Region       string
	RegistryName string
}

type GlueSchemaRegistryScannerService added in v0.7.2

type GlueSchemaRegistryScannerService interface {
	GetRegistryInfo(ctx context.Context, registryName string) (string, error)
	GetAllSchemasWithVersions(ctx context.Context, registryName string) ([]types.GlueSchema, error)
}

type SchemaRegistryScanner

type SchemaRegistryScanner struct {
	SchemaRegistryService SchemaRegistryScannerService

	StateFile string
	State     types.State
	Url       string
}

func NewSchemaRegistryScanner

func NewSchemaRegistryScanner(schemaRegistryService SchemaRegistryScannerService, opts SchemaRegistryScannerOpts) *SchemaRegistryScanner

func (*SchemaRegistryScanner) Run

func (srs *SchemaRegistryScanner) Run() error

type SchemaRegistryScannerOpts

type SchemaRegistryScannerOpts struct {
	StateFile string
	State     types.State
	Url       string
}

type SchemaRegistryScannerService

type SchemaRegistryScannerService interface {
	GetDefaultCompatibility() (schemaregistry.Compatibility, error)
	GetAllSubjectsWithVersions() ([]types.Subject, error)
	GetAllContexts() ([]string, error)
}

Jump to

Keyboard shortcuts

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