Documentation ¶
Index ¶
- type ChangeDetectorService
- type NamespaceService
- type NotificationEventRepository
- func (_m *NotificationEventRepository) Create(ctx context.Context, event changedetector.NotificationEvent) (changedetector.NotificationEvent, error)
- func (_m *NotificationEventRepository) GetByNameSpaceSchemaVersionAndSuccess(ctx context.Context, namespace string, schemaID int32, versionID string, ...) (changedetector.NotificationEvent, error)
- func (_m *NotificationEventRepository) Update(ctx context.Context, Id string, success bool) (changedetector.NotificationEvent, error)
- type ParsedSchema
- func (_m *ParsedSchema) Format() string
- func (_m *ParsedSchema) GetCanonicalValue() *schema.SchemaFile
- func (_m *ParsedSchema) IsBackwardCompatible(_a0 schema.ParsedSchema) error
- func (_m *ParsedSchema) IsForwardCompatible(_a0 schema.ParsedSchema) error
- func (_m *ParsedSchema) IsFullCompatible(_a0 schema.ParsedSchema) error
- type Producer
- type SchemaCache
- type SchemaProvider
- type SchemaRepository
- func (_m *SchemaRepository) Create(ctx context.Context, namespace string, _a2 string, metadata *schema.Metadata, ...) (int32, error)
- func (_m *SchemaRepository) Delete(_a0 context.Context, _a1 string, _a2 string) error
- func (_m *SchemaRepository) DeleteVersion(_a0 context.Context, _a1 string, _a2 string, _a3 int32) error
- func (_m *SchemaRepository) Get(_a0 context.Context, _a1 string, _a2 string, _a3 int32) ([]byte, error)
- func (_m *SchemaRepository) GetLatestVersion(_a0 context.Context, _a1 string, _a2 string) (int32, error)
- func (_m *SchemaRepository) GetMetadata(_a0 context.Context, _a1 string, _a2 string) (*schema.Metadata, error)
- func (_m *SchemaRepository) GetSchemaID(ctx context.Context, ns string, sc string) (int32, error)
- func (_m *SchemaRepository) List(_a0 context.Context, _a1 string) ([]schema.Schema, error)
- func (_m *SchemaRepository) ListVersions(_a0 context.Context, _a1 string, _a2 string) ([]int32, error)
- func (_m *SchemaRepository) UpdateMetadata(_a0 context.Context, _a1 string, _a2 string, _a3 *schema.Metadata) (*schema.Metadata, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChangeDetectorService ¶ added in v0.8.0
ChangeDetectorService is an autogenerated mock type for the ChangeDetectorService type
func NewChangeDetectorService ¶ added in v0.8.0
func NewChangeDetectorService(t interface { mock.TestingT Cleanup(func()) }) *ChangeDetectorService
NewChangeDetectorService creates a new instance of ChangeDetectorService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ChangeDetectorService) IdentifySchemaChange ¶ added in v0.8.0
func (_m *ChangeDetectorService) IdentifySchemaChange(ctx context.Context, request *changedetector.ChangeRequest) (*stencilv1beta1.SchemaChangedEvent, error)
IdentifySchemaChange provides a mock function with given fields: ctx, request
type NamespaceService ¶
NamespaceService is an autogenerated mock type for the NamespaceService type
func NewNamespaceService ¶
func NewNamespaceService(t testing.TB) *NamespaceService
NewNamespaceService creates a new instance of NamespaceService. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
type NotificationEventRepository ¶ added in v0.8.0
NotificationEventRepository is an autogenerated mock type for the NotificationEventRepository type
func NewNotificationEventRepository ¶ added in v0.8.0
func NewNotificationEventRepository(t interface { mock.TestingT Cleanup(func()) }) *NotificationEventRepository
NewNotificationEventRepository creates a new instance of NotificationEventRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*NotificationEventRepository) Create ¶ added in v0.8.0
func (_m *NotificationEventRepository) Create(ctx context.Context, event changedetector.NotificationEvent) (changedetector.NotificationEvent, error)
Create provides a mock function with given fields: ctx, event
func (*NotificationEventRepository) GetByNameSpaceSchemaVersionAndSuccess ¶ added in v0.8.0
func (_m *NotificationEventRepository) GetByNameSpaceSchemaVersionAndSuccess(ctx context.Context, namespace string, schemaID int32, versionID string, success bool) (changedetector.NotificationEvent, error)
GetByNameSpaceSchemaVersionAndSuccess provides a mock function with given fields: ctx, namespace, schemaID, versionID, success
func (*NotificationEventRepository) Update ¶ added in v0.8.0
func (_m *NotificationEventRepository) Update(ctx context.Context, Id string, success bool) (changedetector.NotificationEvent, error)
Update provides a mock function with given fields: ctx, Id, success
type ParsedSchema ¶
ParsedSchema is an autogenerated mock type for the ParsedSchema type
func NewParsedSchema ¶
func NewParsedSchema(t testing.TB) *ParsedSchema
NewParsedSchema creates a new instance of ParsedSchema. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*ParsedSchema) Format ¶
func (_m *ParsedSchema) Format() string
Format provides a mock function with given fields:
func (*ParsedSchema) GetCanonicalValue ¶
func (_m *ParsedSchema) GetCanonicalValue() *schema.SchemaFile
GetCanonicalValue provides a mock function with given fields:
func (*ParsedSchema) IsBackwardCompatible ¶
func (_m *ParsedSchema) IsBackwardCompatible(_a0 schema.ParsedSchema) error
IsBackwardCompatible provides a mock function with given fields: _a0
func (*ParsedSchema) IsForwardCompatible ¶
func (_m *ParsedSchema) IsForwardCompatible(_a0 schema.ParsedSchema) error
IsForwardCompatible provides a mock function with given fields: _a0
func (*ParsedSchema) IsFullCompatible ¶
func (_m *ParsedSchema) IsFullCompatible(_a0 schema.ParsedSchema) error
IsFullCompatible provides a mock function with given fields: _a0
type Producer ¶ added in v0.8.0
Producer is an autogenerated mock type for the Producer type
func NewProducer ¶ added in v0.8.0
NewProducer creates a new instance of Producer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Producer) Write ¶ added in v0.8.0
func (_m *Producer) Write(topic string, protoMessage protoreflect.ProtoMessage) error
Write provides a mock function with given fields: topic, protoMessage
type SchemaCache ¶
SchemaCache is an autogenerated mock type for the Cache type
func NewSchemaCache ¶
func NewSchemaCache(t testing.TB) *SchemaCache
NewSchemaCache creates a new instance of SchemaCache. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*SchemaCache) Get ¶
func (_m *SchemaCache) Get(_a0 interface{}) (interface{}, bool)
Get provides a mock function with given fields: _a0
func (*SchemaCache) Set ¶
func (_m *SchemaCache) Set(_a0 interface{}, _a1 interface{}, _a2 int64) bool
Set provides a mock function with given fields: _a0, _a1, _a2
type SchemaProvider ¶
SchemaProvider is an autogenerated mock type for the Provider type
func NewSchemaProvider ¶
func NewSchemaProvider(t testing.TB) *SchemaProvider
NewSchemaProvider creates a new instance of SchemaProvider. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.
func (*SchemaProvider) ParseSchema ¶
func (_m *SchemaProvider) ParseSchema(format string, data []byte) (schema.ParsedSchema, error)
ParseSchema provides a mock function with given fields: format, data
type SchemaRepository ¶
SchemaRepository is an autogenerated mock type for the SchemaRepository type
func NewSchemaRepository ¶
func NewSchemaRepository(t interface { mock.TestingT Cleanup(func()) }) *SchemaRepository
NewSchemaRepository creates a new instance of SchemaRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SchemaRepository) Create ¶
func (_m *SchemaRepository) Create(ctx context.Context, namespace string, _a2 string, metadata *schema.Metadata, versionID string, schemaFile *schema.SchemaFile) (int32, error)
Create provides a mock function with given fields: ctx, namespace, _a2, metadata, versionID, schemaFile
func (*SchemaRepository) DeleteVersion ¶
func (_m *SchemaRepository) DeleteVersion(_a0 context.Context, _a1 string, _a2 string, _a3 int32) error
DeleteVersion provides a mock function with given fields: _a0, _a1, _a2, _a3
func (*SchemaRepository) Get ¶
func (_m *SchemaRepository) Get(_a0 context.Context, _a1 string, _a2 string, _a3 int32) ([]byte, error)
Get provides a mock function with given fields: _a0, _a1, _a2, _a3
func (*SchemaRepository) GetLatestVersion ¶
func (_m *SchemaRepository) GetLatestVersion(_a0 context.Context, _a1 string, _a2 string) (int32, error)
GetLatestVersion provides a mock function with given fields: _a0, _a1, _a2
func (*SchemaRepository) GetMetadata ¶
func (_m *SchemaRepository) GetMetadata(_a0 context.Context, _a1 string, _a2 string) (*schema.Metadata, error)
GetMetadata provides a mock function with given fields: _a0, _a1, _a2
func (*SchemaRepository) GetSchemaID ¶ added in v0.8.0
GetSchemaID provides a mock function with given fields: ctx, ns, sc
func (*SchemaRepository) ListVersions ¶
func (_m *SchemaRepository) ListVersions(_a0 context.Context, _a1 string, _a2 string) ([]int32, error)
ListVersions provides a mock function with given fields: _a0, _a1, _a2