Versions in this module Expand all Collapse all v1 v1.1.0 Jun 30, 2020 v1.0.0 Oct 3, 2018 Changes in this version + const Backward + const EmptySubject + const Forward + const Full + const None + const TestRequiredEnvVar + const TestURLEnvVar + const Zero + var EmptySchema = Schema("") + func CheckIsCompatibleRequest(baseURL string, subject Subject, version string, body *SchemaJSON) (*http.Request, error) + func GetConfigRequest(baseURL string) (*http.Request, error) + func GetFunctionalTestURL(t *testing.T) string + func GetSchemaRequest(baseURL string, id uint32) (*http.Request, error) + func GetSubjectConfigRequest(baseURL string, subject Subject) (*http.Request, error) + func GetVersionRequest(baseURL string, subject Subject, version string) (*http.Request, error) + func HandleFunctionalTestError(t testing.TB, err error) + func HasSchema(client HTTPClient, url string, subject Subject, schema Schema) (version int, id int, err error) + func HasSchemaRequest(baseURL string, subject Subject, body *SchemaJSON) (*http.Request, error) + func IsCompatible(client HTTPClient, url string, subject Subject, version string, schema Schema) (is bool, err error) + func IsFunctionalTestRequired() bool + func ListSubjectsRequest(baseURL string) (*http.Request, error) + func ListVersions(client HTTPClient, url string, subject Subject) (versions []int, err error) + func ListVersionsRequest(baseURL string, subject Subject) (*http.Request, error) + func PutSubjectConfigRequest(baseURL string, subject Subject, body *ConfigPutJSON) (*http.Request, error) + func Register(client HTTPClient, url string, subject Subject, schema Schema) (id uint32, err error) + func RegisterRequest(baseURL string, subject Subject, body *SchemaJSON) (*http.Request, error) + type Compatibility string + func GetDefaultCompatibility(client HTTPClient, url string) (compatibility Compatibility, err error) + func GetSubjectCompatibility(client HTTPClient, url string, subject Subject) (compatibility Compatibility, err error) + func GetSubjectDerivedCompatibility(client HTTPClient, url string, subject Subject) (compatibility Compatibility, err error) + func SetSubjectCompatibility(client HTTPClient, url string, subject Subject, compatibility Compatibility) (result Compatibility, err error) + type ConfigGetJSON struct + Compatibility string + type ConfigPutJSON struct + Compatibility string + type HTTPClient interface + Do func(request *http.Request) (*http.Response, error) + type Schema string + func GetLatestSchema(client HTTPClient, url string, subject Subject) (id uint32, schema Schema, err error) + func GetSchema(client HTTPClient, url string, id uint32) (schema Schema, err error) + func GetVersion(client HTTPClient, url string, subject Subject, version string) (id uint32, schema Schema, err error) + func TestSchema(unique int64) Schema + func UniqueSchema() Schema + type SchemaJSON struct + Schema Schema + type Subject string + func KeySubject(topic string) Subject + func ListSubjects(client HTTPClient, url string) (subjects []Subject, err error) + func UniqueSubject() Subject + func ValueSubject(topic string) Subject