mocks

Documentation

Index

• type NamespaceService
  • func NewNamespaceService(t testing.TB) *NamespaceService
  • func (_m *NamespaceService) Get(ctx context.Context, name string) (namespace.Namespace, error)
• type ParsedSchema
  • func NewParsedSchema(t testing.TB) *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 SchemaCache
  • func NewSchemaCache(t testing.TB) *SchemaCache
  • func (_m *SchemaCache) Get(_a0 interface{}) (interface{}, bool)
  • func (_m *SchemaCache) Set(_a0 interface{}, _a1 interface{}, _a2 int64) bool
• type SchemaProvider
  • func NewSchemaProvider(t testing.TB) *SchemaProvider
  • func (_m *SchemaProvider) ParseSchema(format string, data []byte) (schema.ParsedSchema, error)
• type SchemaRepository
  • func NewSchemaRepository(t mockConstructorTestingTNewSchemaRepository) *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) 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)

Types

type NamespaceService

type NamespaceService struct {
	mock.Mock
}

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.

func (*NamespaceService) Get

func (_m *NamespaceService) Get(ctx context.Context, name string) (namespace.Namespace, error)

Get provides a mock function with given fields: ctx, name

type ParsedSchema

type ParsedSchema struct {
	mock.Mock
}

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 SchemaCache

type SchemaCache struct {
	mock.Mock
}

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

type SchemaProvider struct {
	mock.Mock
}

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

type SchemaRepository struct {
	mock.Mock
}

SchemaRepository is an autogenerated mock type for the Repository type

func NewSchemaRepository

func NewSchemaRepository(t mockConstructorTestingTNewSchemaRepository) *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.

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) Delete

func (_m *SchemaRepository) Delete(_a0 context.Context, _a1 string, _a2 string) error

Delete provides a mock function with given fields: _a0, _a1, _a2

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) List

func (_m *SchemaRepository) List(_a0 context.Context, _a1 string) ([]schema.Schema, error)

List provides a mock function with given fields: _a0, _a1

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

func (*SchemaRepository) UpdateMetadata

func (_m *SchemaRepository) UpdateMetadata(_a0 context.Context, _a1 string, _a2 string, _a3 *schema.Metadata) (*schema.Metadata, error)

UpdateMetadata provides a mock function with given fields: _a0, _a1, _a2, _a3