schema

package

v0.2.0 Latest Latest Go to latest Published: Sep 2, 2025 License: AGPL-3.0 Imports: 10 Imported by: 0

Details

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

Repository

github.com/electric-saw/kafta

Links

Open Source Insights

Documentation ¶

Index ¶

func BuildGetRequestSchemaRegistry(config *configuration.Configuration, path string) *http.Response
func BuildPostRequestSchemaRegistry(config *configuration.Configuration, path string, body string) *http.Response
func NewGlobalCompatibility(config *configuration.Configuration) (string, error)
func NewSchemaList(config *configuration.Configuration, subjectName string, version string) (string, error)
func NewSubjectCompatibility(config *configuration.Configuration, subjectName string) (string, error)
func NewSubjectCreate(config *configuration.Configuration, subjectName string, schema string) (string, error)
func NewSubjectList(config *configuration.Configuration) ([]string, error)
func NewSubjectVersion(config *configuration.Configuration, subsubjectName string) (string, error)
type SubjectConfig
type SubjectVersionInfo
type SubjectVersionWithCompatibility
- func NewSubjectVersionsWithCompatibility(config *configuration.Configuration, subjectName string) ([]SubjectVersionWithCompatibility, error)
type SubjectWithCompatibility
- func NewSubjectListWithCompatibility(config *configuration.Configuration) ([]SubjectWithCompatibility, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func BuildGetRequestSchemaRegistry ¶

func BuildGetRequestSchemaRegistry(
	config *configuration.Configuration,
	path string,
) *http.Response

func BuildPostRequestSchemaRegistry ¶ added in v0.1.9

func BuildPostRequestSchemaRegistry(
	config *configuration.Configuration,
	path string,
	body string,
) *http.Response

func NewGlobalCompatibility ¶ added in v0.2.0

func NewGlobalCompatibility(config *configuration.Configuration) (string, error)

func NewSchemaList ¶ added in v0.1.9

func NewSchemaList(
	config *configuration.Configuration,
	subjectName string,
	version string,
) (string, error)

func NewSubjectCompatibility ¶ added in v0.2.0

func NewSubjectCompatibility(
	config *configuration.Configuration,
	subjectName string,
) (string, error)

func NewSubjectCreate ¶ added in v0.1.9

func NewSubjectCreate(
	config *configuration.Configuration,
	subjectName string,
	schema string,
) (string, error)

func NewSubjectList ¶

func NewSubjectList(config *configuration.Configuration) ([]string, error)

func NewSubjectVersion ¶ added in v0.1.9

func NewSubjectVersion(config *configuration.Configuration, subsubjectName string) (string, error)

Types ¶

type SubjectConfig ¶ added in v0.2.0

type SubjectConfig struct {
	CompatibilityLevel string `json:"compatibilityLevel"`
}

type SubjectVersionInfo ¶ added in v0.2.0

type SubjectVersionInfo struct {
	Version    int    `json:"version"`
	ID         int    `json:"id"`
	Schema     string `json:"schema"`
	Subject    string `json:"subject"`
	References []any  `json:"references"`
}

type SubjectVersionWithCompatibility ¶ added in v0.2.0

type SubjectVersionWithCompatibility struct {
	Version            int    `json:"version"`
	ID                 int    `json:"id"`
	Schema             string `json:"schema"`
	Subject            string `json:"subject"`
	CompatibilityLevel string `json:"compatibilityLevel,omitempty"`
}

func NewSubjectVersionsWithCompatibility ¶ added in v0.2.0

func NewSubjectVersionsWithCompatibility(
	config *configuration.Configuration,
	subjectName string,
) ([]SubjectVersionWithCompatibility, error)

type SubjectWithCompatibility ¶ added in v0.2.0

type SubjectWithCompatibility struct {
	Name               string `json:"name"`
	CompatibilityLevel string `json:"compatibilityLevel"`
	VersionCount       int    `json:"versionCount"`
}

func NewSubjectListWithCompatibility ¶ added in v0.2.0

func NewSubjectListWithCompatibility(
	config *configuration.Configuration,
) ([]SubjectWithCompatibility, error)

Source Files ¶

View all Source files

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