srclient

package module

Go to main page

Versions in this module

v0

v0.9.0

Jun 11, 2024

Changes in this version

+ type TokenProvider interface

+ ObtainToken func(ctx context.Context) (string, error)

v0.8.1

Feb 23, 2024

v0.8.0

Feb 22, 2024

Changes in this version

type SchemaRegistryClient

+ func (client *SchemaRegistryClient) CacheLatest(value bool)

v0.7.1

Feb 9, 2024

v0.7.0

Feb 9, 2024

Changes in this version

+ type CompatibilityLevel string

+ const Backward

+ const BackwardTransitive

+ const Forward

+ const ForwardTransitive

+ const Full

+ const FullTransitive

+ const None

+ func (s CompatibilityLevel) String() string

+ type Error struct

+ Code int

+ Message string

+ func (e Error) Error() string

+ type ISchemaRegistryClient interface

+ CachingEnabled func(value bool)

+ ChangeSubjectCompatibilityLevel func(subject string, compatibility CompatibilityLevel) (*CompatibilityLevel, error)

+ CodecCreationEnabled func(value bool)

+ CreateSchema func(subject string, schema string, schemaType SchemaType, references ...Reference) (*Schema, error)

+ DeleteSubject func(subject string, permanent bool) error

+ DeleteSubjectByVersion func(subject string, version int, permanent bool) error

+ GetCompatibilityLevel func(subject string, defaultToGlobal bool) (*CompatibilityLevel, error)

+ GetGlobalCompatibilityLevel func() (*CompatibilityLevel, error)

+ GetLatestSchema func(subject string) (*Schema, error)

+ GetSchema func(schemaID int) (*Schema, error)

+ GetSchemaByVersion func(subject string, version int) (*Schema, error)

+ GetSchemaVersions func(subject string) ([]int, error)

+ GetSubjects func() ([]string, error)

+ GetSubjectsIncludingDeleted func() ([]string, error)

+ IsSchemaCompatible func(subject, schema, version string, schemaType SchemaType, ...) (bool, error)

+ LookupSchema func(subject string, schema string, schemaType SchemaType, references ...Reference) (*Schema, error)

+ ResetCache func()

+ SetBearerToken func(token string)

+ SetCredentials func(username string, password string)

+ SetTimeout func(timeout time.Duration)

+ type MockSchemaRegistryClient struct

+ func CreateMockSchemaRegistryClient(mockURL string) *MockSchemaRegistryClient

+ func (mck *MockSchemaRegistryClient) CachingEnabled(bool)

+ func (mck *MockSchemaRegistryClient) ChangeSubjectCompatibilityLevel(string, CompatibilityLevel) (*CompatibilityLevel, error)

+ func (mck *MockSchemaRegistryClient) CodecCreationEnabled(bool)

+ func (mck *MockSchemaRegistryClient) CreateSchema(subject string, schema string, schemaType SchemaType, _ ...Reference) (*Schema, error)

+ func (mck *MockSchemaRegistryClient) DeleteSubject(subject string, _ bool) error

+ func (mck *MockSchemaRegistryClient) DeleteSubjectByVersion(subject string, version int, _ bool) error

+ func (mck *MockSchemaRegistryClient) GetCompatibilityLevel(string, bool) (*CompatibilityLevel, error)

+ func (mck *MockSchemaRegistryClient) GetGlobalCompatibilityLevel() (*CompatibilityLevel, error)

+ func (mck *MockSchemaRegistryClient) GetLatestSchema(subject string) (*Schema, error)

+ func (mck *MockSchemaRegistryClient) GetSchema(schemaID int) (*Schema, error)

+ func (mck *MockSchemaRegistryClient) GetSchemaByVersion(subject string, version int) (*Schema, error)

+ func (mck *MockSchemaRegistryClient) GetSchemaVersions(subject string) ([]int, error)

+ func (mck *MockSchemaRegistryClient) GetSubjects() ([]string, error)

+ func (mck *MockSchemaRegistryClient) GetSubjectsIncludingDeleted() ([]string, error)

+ func (mck *MockSchemaRegistryClient) IsSchemaCompatible(string, string, string, SchemaType, ...Reference) (bool, error)

+ func (mck *MockSchemaRegistryClient) LookupSchema(string, string, SchemaType, ...Reference) (*Schema, error)

+ func (mck *MockSchemaRegistryClient) ResetCache()

+ func (mck *MockSchemaRegistryClient) SetBearerToken(string)

+ func (mck *MockSchemaRegistryClient) SetCredentials(string, string)

+ func (mck *MockSchemaRegistryClient) SetSchema(id int, subject string, schema string, schemaType SchemaType, version int) (*Schema, error)

+ func (mck *MockSchemaRegistryClient) SetTimeout(time.Duration)

+ type Reference struct

+ Name string

+ Subject string

+ Version int

+ type Schema struct

+ func NewSchema(id int, schema string, schemaType SchemaType, version int, ...) (*Schema, error)

+ func (schema *Schema) Codec() *goavro.Codec

+ func (schema *Schema) ID() int

+ func (schema *Schema) JsonSchema() *jsonschema.Schema

+ func (schema *Schema) References() []Reference

+ func (schema *Schema) Schema() string

+ func (schema *Schema) SchemaType() *SchemaType

+ func (schema *Schema) Version() int

+ type SchemaRegistryClient struct

+ func CreateSchemaRegistryClient(schemaRegistryURL string) *SchemaRegistryClient

+ func CreateSchemaRegistryClientWithOptions(schemaRegistryURL string, client *http.Client, semaphoreWeight int) *SchemaRegistryClient

+ func (client *SchemaRegistryClient) CachingEnabled(value bool)

+ func (client *SchemaRegistryClient) ChangeSubjectCompatibilityLevel(subject string, compatibility CompatibilityLevel) (*CompatibilityLevel, error)

+ func (client *SchemaRegistryClient) CodecCreationEnabled(value bool)

+ func (client *SchemaRegistryClient) CreateSchema(subject string, schema string, schemaType SchemaType, references ...Reference) (*Schema, error)

+ func (client *SchemaRegistryClient) DeleteSubject(subject string, permanent bool) error

+ func (client *SchemaRegistryClient) DeleteSubjectByVersion(subject string, version int, permanent bool) error

+ func (client *SchemaRegistryClient) GetCompatibilityLevel(subject string, defaultToGlobal bool) (*CompatibilityLevel, error)

+ func (client *SchemaRegistryClient) GetGlobalCompatibilityLevel() (*CompatibilityLevel, error)

+ func (client *SchemaRegistryClient) GetLatestSchema(subject string) (*Schema, error)

+ func (client *SchemaRegistryClient) GetSchema(schemaID int) (*Schema, error)

+ func (client *SchemaRegistryClient) GetSchemaByVersion(subject string, version int) (*Schema, error)

+ func (client *SchemaRegistryClient) GetSchemaVersions(subject string) ([]int, error)

+ func (client *SchemaRegistryClient) GetSubjects() ([]string, error)

+ func (client *SchemaRegistryClient) GetSubjectsIncludingDeleted() ([]string, error)

+ func (client *SchemaRegistryClient) IsSchemaCompatible(subject, schema, version string, schemaType SchemaType, ...) (bool, error)

+ func (client *SchemaRegistryClient) LookupSchema(subject string, schema string, schemaType SchemaType, references ...Reference) (*Schema, error)

+ func (client *SchemaRegistryClient) ResetCache()

+ func (client *SchemaRegistryClient) SetBearerToken(token string)

+ func (client *SchemaRegistryClient) SetCredentials(username string, password string)

+ func (client *SchemaRegistryClient) SetTimeout(timeout time.Duration)

+ type SchemaType string

+ const Avro

+ const Json

+ const Protobuf

+ func (s SchemaType) String() string

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