mocks

Documentation

Index

• type NamespaceService
  • func NewNamespaceService(t mockConstructorTestingTNewNamespaceService) *NamespaceService
  • func (_m *NamespaceService) Create(ctx context.Context, ns namespace.Namespace) (namespace.Namespace, error)
  • func (_m *NamespaceService) Delete(ctx context.Context, name string) error
  • func (_m *NamespaceService) Get(ctx context.Context, name string) (namespace.Namespace, error)
  • func (_m *NamespaceService) List(ctx context.Context) ([]namespace.Namespace, error)
  • func (_m *NamespaceService) Update(ctx context.Context, ns namespace.Namespace) (namespace.Namespace, error)
• type SchemaService
  • func NewSchemaService(t mockConstructorTestingTNewSchemaService) *SchemaService
  • func (_m *SchemaService) CheckCompatibility(ctx context.Context, nsName string, schemaName string, compatibility string, ...) error
  • func (_m *SchemaService) Create(ctx context.Context, nsName string, schemaName string, ...) (schema.SchemaInfo, error)
  • func (_m *SchemaService) Delete(ctx context.Context, namespace string, schemaName string) error
  • func (_m *SchemaService) DeleteVersion(ctx context.Context, namespace string, schemaName string, version int32) error
  • func (_m *SchemaService) Get(ctx context.Context, namespace string, schemaName string, version int32) (*schema.Metadata, []byte, error)
  • func (_m *SchemaService) GetLatest(ctx context.Context, namespace string, schemaName string) (*schema.Metadata, []byte, error)
  • func (_m *SchemaService) GetMetadata(ctx context.Context, namespace string, schemaName string) (*schema.Metadata, error)
  • func (_m *SchemaService) List(ctx context.Context, namespaceID string) ([]schema.Schema, error)
  • func (_m *SchemaService) ListVersions(ctx context.Context, namespaceID string, schemaName string) ([]int32, error)
  • func (_m *SchemaService) UpdateMetadata(ctx context.Context, namespace string, schemaName string, ...) (*schema.Metadata, error)
• type SearchService
  • func NewSearchService(t testing.TB) *SearchService
  • func (_m *SearchService) Search(ctx context.Context, req *search.SearchRequest) (*search.SearchResponse, error)

Types

type NamespaceService

type NamespaceService struct {
	mock.Mock
}

NamespaceService is an autogenerated mock type for the NamespaceService type

func NewNamespaceService

func NewNamespaceService(t mockConstructorTestingTNewNamespaceService) *NamespaceService

NewNamespaceService creates a new instance of NamespaceService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*NamespaceService) Create

func (_m *NamespaceService) Create(ctx context.Context, ns namespace.Namespace) (namespace.Namespace, error)

Create provides a mock function with given fields: ctx, ns

func (*NamespaceService) Delete

func (_m *NamespaceService) Delete(ctx context.Context, name string) error

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

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

func (*NamespaceService) List

func (_m *NamespaceService) List(ctx context.Context) ([]namespace.Namespace, error)

List provides a mock function with given fields: ctx

func (*NamespaceService) Update

func (_m *NamespaceService) Update(ctx context.Context, ns namespace.Namespace) (namespace.Namespace, error)

Update provides a mock function with given fields: ctx, ns

type SchemaService

type SchemaService struct {
	mock.Mock
}

SchemaService is an autogenerated mock type for the SchemaService type

func NewSchemaService

func NewSchemaService(t mockConstructorTestingTNewSchemaService) *SchemaService

NewSchemaService creates a new instance of SchemaService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*SchemaService) CheckCompatibility

func (_m *SchemaService) CheckCompatibility(ctx context.Context, nsName string, schemaName string, compatibility string, data []byte) error

CheckCompatibility provides a mock function with given fields: ctx, nsName, schemaName, compatibility, data

func (*SchemaService) Create

func (_m *SchemaService) Create(ctx context.Context, nsName string, schemaName string, metadata *schema.Metadata, data []byte) (schema.SchemaInfo, error)

Create provides a mock function with given fields: ctx, nsName, schemaName, metadata, data

func (*SchemaService) Delete

func (_m *SchemaService) Delete(ctx context.Context, namespace string, schemaName string) error

Delete provides a mock function with given fields: ctx, namespace, schemaName

func (*SchemaService) DeleteVersion

func (_m *SchemaService) DeleteVersion(ctx context.Context, namespace string, schemaName string, version int32) error

DeleteVersion provides a mock function with given fields: ctx, namespace, schemaName, version

func (*SchemaService) Get

func (_m *SchemaService) Get(ctx context.Context, namespace string, schemaName string, version int32) (*schema.Metadata, []byte, error)

Get provides a mock function with given fields: ctx, namespace, schemaName, version

func (*SchemaService) GetLatest

func (_m *SchemaService) GetLatest(ctx context.Context, namespace string, schemaName string) (*schema.Metadata, []byte, error)

GetLatest provides a mock function with given fields: ctx, namespace, schemaName

func (*SchemaService) GetMetadata

func (_m *SchemaService) GetMetadata(ctx context.Context, namespace string, schemaName string) (*schema.Metadata, error)

GetMetadata provides a mock function with given fields: ctx, namespace, schemaName

func (*SchemaService) List

func (_m *SchemaService) List(ctx context.Context, namespaceID string) ([]schema.Schema, error)

List provides a mock function with given fields: ctx, namespaceID

func (*SchemaService) ListVersions

func (_m *SchemaService) ListVersions(ctx context.Context, namespaceID string, schemaName string) ([]int32, error)

ListVersions provides a mock function with given fields: ctx, namespaceID, schemaName

func (*SchemaService) UpdateMetadata

func (_m *SchemaService) UpdateMetadata(ctx context.Context, namespace string, schemaName string, meta *schema.Metadata) (*schema.Metadata, error)

UpdateMetadata provides a mock function with given fields: ctx, namespace, schemaName, meta

type SearchService

type SearchService struct {
	mock.Mock
}

SearchService is an autogenerated mock type for the SearchService type

func NewSearchService

func NewSearchService(t testing.TB) *SearchService

NewSearchService creates a new instance of SearchService. It also registers the testing.TB interface on the mock and a cleanup function to assert the mocks expectations.

func (*SearchService) Search

func (_m *SearchService) Search(ctx context.Context, req *search.SearchRequest) (*search.SearchResponse, error)

Search provides a mock function with given fields: ctx, req