types

package
v1.31.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 2, 2025 License: BSD-3-Clause Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockSchemaReader 

type MockSchemaReader struct {
	mock.Mock
}

MockSchemaReader is an autogenerated mock type for the SchemaReader type

func NewMockSchemaReader 

func NewMockSchemaReader(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockSchemaReader

NewMockSchemaReader creates a new instance of MockSchemaReader. 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 (*MockSchemaReader) ClassEqual 

func (_m *MockSchemaReader) ClassEqual(name string) string

ClassEqual provides a mock function with given fields: name

func (*MockSchemaReader) ClassInfo 

func (_m *MockSchemaReader) ClassInfo(class string) schema.ClassInfo

ClassInfo provides a mock function with given fields: class

func (*MockSchemaReader) ClassInfoWithVersion 

func (_m *MockSchemaReader) ClassInfoWithVersion(ctx context.Context, class string, version uint64) (schema.ClassInfo, error)

ClassInfoWithVersion provides a mock function with given fields: ctx, class, version

func (*MockSchemaReader) CopyShardingState 

func (_m *MockSchemaReader) CopyShardingState(class string) *sharding.State

CopyShardingState provides a mock function with given fields: class

func (*MockSchemaReader) CopyShardingStateWithVersion 

func (_m *MockSchemaReader) CopyShardingStateWithVersion(ctx context.Context, class string, version uint64) (*sharding.State, error)

CopyShardingStateWithVersion provides a mock function with given fields: ctx, class, version

func (*MockSchemaReader) EXPECT 

func (_m *MockSchemaReader) EXPECT() *MockSchemaReader_Expecter

func (*MockSchemaReader) GetShardsStatus 

func (_m *MockSchemaReader) GetShardsStatus(class string, tenant string) (models.ShardStatusList, error)

GetShardsStatus provides a mock function with given fields: class, tenant

func (*MockSchemaReader) MultiTenancy 

func (_m *MockSchemaReader) MultiTenancy(class string) models.MultiTenancyConfig

MultiTenancy provides a mock function with given fields: class

func (*MockSchemaReader) MultiTenancyWithVersion 

func (_m *MockSchemaReader) MultiTenancyWithVersion(ctx context.Context, class string, version uint64) (models.MultiTenancyConfig, error)

MultiTenancyWithVersion provides a mock function with given fields: ctx, class, version

func (*MockSchemaReader) Read 

func (_m *MockSchemaReader) Read(class string, reader func(*models.Class, *sharding.State) error) error

Read provides a mock function with given fields: class, reader

func (*MockSchemaReader) ReadOnlyClass 

func (_m *MockSchemaReader) ReadOnlyClass(name string) *models.Class

ReadOnlyClass provides a mock function with given fields: name

func (*MockSchemaReader) ReadOnlyClassWithVersion 

func (_m *MockSchemaReader) ReadOnlyClassWithVersion(ctx context.Context, class string, version uint64) (*models.Class, error)

ReadOnlyClassWithVersion provides a mock function with given fields: ctx, class, version

func (*MockSchemaReader) ReadOnlySchema 

func (_m *MockSchemaReader) ReadOnlySchema() models.Schema

ReadOnlySchema provides a mock function with no fields

func (*MockSchemaReader) ReadOnlyVersionedClass 

func (_m *MockSchemaReader) ReadOnlyVersionedClass(name string) versioned.Class

ReadOnlyVersionedClass provides a mock function with given fields: name

func (*MockSchemaReader) ShardFromUUID 

func (_m *MockSchemaReader) ShardFromUUID(class string, uuid []byte) string

ShardFromUUID provides a mock function with given fields: class, uuid

func (*MockSchemaReader) ShardFromUUIDWithVersion 

func (_m *MockSchemaReader) ShardFromUUIDWithVersion(ctx context.Context, class string, uuid []byte, version uint64) (string, error)

ShardFromUUIDWithVersion provides a mock function with given fields: ctx, class, uuid, version

func (*MockSchemaReader) ShardOwner 

func (_m *MockSchemaReader) ShardOwner(class string, shard string) (string, error)

ShardOwner provides a mock function with given fields: class, shard

func (*MockSchemaReader) ShardOwnerWithVersion 

func (_m *MockSchemaReader) ShardOwnerWithVersion(ctx context.Context, lass string, shard string, version uint64) (string, error)

ShardOwnerWithVersion provides a mock function with given fields: ctx, lass, shard, version

func (*MockSchemaReader) ShardReplicas 

func (_m *MockSchemaReader) ShardReplicas(class string, shard string) ([]string, error)

ShardReplicas provides a mock function with given fields: class, shard

func (*MockSchemaReader) ShardReplicasWithVersion 

func (_m *MockSchemaReader) ShardReplicasWithVersion(ctx context.Context, class string, shard string, version uint64) ([]string, error)

ShardReplicasWithVersion provides a mock function with given fields: ctx, class, shard, version

func (*MockSchemaReader) TenantsShardsWithVersion 

func (_m *MockSchemaReader) TenantsShardsWithVersion(ctx context.Context, version uint64, class string, tenants ...string) (map[string]string, error)

TenantsShardsWithVersion provides a mock function with given fields: ctx, version, class, tenants

func (*MockSchemaReader) WaitForUpdate 

func (_m *MockSchemaReader) WaitForUpdate(ctx context.Context, version uint64) error

WaitForUpdate provides a mock function with given fields: ctx, version

type MockSchemaReader_ClassEqual_Call 

type MockSchemaReader_ClassEqual_Call struct {
	*mock.Call
}

MockSchemaReader_ClassEqual_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ClassEqual'

func (*MockSchemaReader_ClassEqual_Call) Return 

func (_c *MockSchemaReader_ClassEqual_Call) Return(_a0 string) *MockSchemaReader_ClassEqual_Call

func (*MockSchemaReader_ClassEqual_Call) Run 

func (_c *MockSchemaReader_ClassEqual_Call) Run(run func(name string)) *MockSchemaReader_ClassEqual_Call

func (*MockSchemaReader_ClassEqual_Call) RunAndReturn 

func (_c *MockSchemaReader_ClassEqual_Call) RunAndReturn(run func(string) string) *MockSchemaReader_ClassEqual_Call

type MockSchemaReader_ClassInfoWithVersion_Call 

type MockSchemaReader_ClassInfoWithVersion_Call struct {
	*mock.Call
}

MockSchemaReader_ClassInfoWithVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ClassInfoWithVersion'

func (*MockSchemaReader_ClassInfoWithVersion_Call) Return 

func (_c *MockSchemaReader_ClassInfoWithVersion_Call) Return(_a0 schema.ClassInfo, _a1 error) *MockSchemaReader_ClassInfoWithVersion_Call

func (*MockSchemaReader_ClassInfoWithVersion_Call) Run 

func (_c *MockSchemaReader_ClassInfoWithVersion_Call) Run(run func(ctx context.Context, class string, version uint64)) *MockSchemaReader_ClassInfoWithVersion_Call

func (*MockSchemaReader_ClassInfoWithVersion_Call) RunAndReturn 

func (_c *MockSchemaReader_ClassInfoWithVersion_Call) RunAndReturn(run func(context.Context, string, uint64) (schema.ClassInfo, error)) *MockSchemaReader_ClassInfoWithVersion_Call

type MockSchemaReader_ClassInfo_Call 

type MockSchemaReader_ClassInfo_Call struct {
	*mock.Call
}

MockSchemaReader_ClassInfo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ClassInfo'

func (*MockSchemaReader_ClassInfo_Call) Return 

func (_c *MockSchemaReader_ClassInfo_Call) Return(ci schema.ClassInfo) *MockSchemaReader_ClassInfo_Call

func (*MockSchemaReader_ClassInfo_Call) Run 

func (_c *MockSchemaReader_ClassInfo_Call) Run(run func(class string)) *MockSchemaReader_ClassInfo_Call

func (*MockSchemaReader_ClassInfo_Call) RunAndReturn 

func (_c *MockSchemaReader_ClassInfo_Call) RunAndReturn(run func(string) schema.ClassInfo) *MockSchemaReader_ClassInfo_Call

type MockSchemaReader_CopyShardingStateWithVersion_Call 

type MockSchemaReader_CopyShardingStateWithVersion_Call struct {
	*mock.Call
}

MockSchemaReader_CopyShardingStateWithVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CopyShardingStateWithVersion'

func (*MockSchemaReader_CopyShardingStateWithVersion_Call) Return 

func (_c *MockSchemaReader_CopyShardingStateWithVersion_Call) Return(_a0 *sharding.State, _a1 error) *MockSchemaReader_CopyShardingStateWithVersion_Call

func (*MockSchemaReader_CopyShardingStateWithVersion_Call) Run 

func (_c *MockSchemaReader_CopyShardingStateWithVersion_Call) Run(run func(ctx context.Context, class string, version uint64)) *MockSchemaReader_CopyShardingStateWithVersion_Call

func (*MockSchemaReader_CopyShardingStateWithVersion_Call) RunAndReturn 

func (_c *MockSchemaReader_CopyShardingStateWithVersion_Call) RunAndReturn(run func(context.Context, string, uint64) (*sharding.State, error)) *MockSchemaReader_CopyShardingStateWithVersion_Call

type MockSchemaReader_CopyShardingState_Call 

type MockSchemaReader_CopyShardingState_Call struct {
	*mock.Call
}

MockSchemaReader_CopyShardingState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CopyShardingState'

func (*MockSchemaReader_CopyShardingState_Call) Return 

func (_c *MockSchemaReader_CopyShardingState_Call) Return(_a0 *sharding.State) *MockSchemaReader_CopyShardingState_Call

func (*MockSchemaReader_CopyShardingState_Call) Run 

func (_c *MockSchemaReader_CopyShardingState_Call) Run(run func(class string)) *MockSchemaReader_CopyShardingState_Call

func (*MockSchemaReader_CopyShardingState_Call) RunAndReturn 

func (_c *MockSchemaReader_CopyShardingState_Call) RunAndReturn(run func(string) *sharding.State) *MockSchemaReader_CopyShardingState_Call

type MockSchemaReader_Expecter 

type MockSchemaReader_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockSchemaReader_Expecter) ClassEqual 

func (_e *MockSchemaReader_Expecter) ClassEqual(name interface{}) *MockSchemaReader_ClassEqual_Call

ClassEqual is a helper method to define mock.On call

  • name string

func (*MockSchemaReader_Expecter) ClassInfo 

func (_e *MockSchemaReader_Expecter) ClassInfo(class interface{}) *MockSchemaReader_ClassInfo_Call

ClassInfo is a helper method to define mock.On call

  • class string

func (*MockSchemaReader_Expecter) ClassInfoWithVersion 

func (_e *MockSchemaReader_Expecter) ClassInfoWithVersion(ctx interface{}, class interface{}, version interface{}) *MockSchemaReader_ClassInfoWithVersion_Call

ClassInfoWithVersion is a helper method to define mock.On call

  • ctx context.Context
  • class string
  • version uint64

func (*MockSchemaReader_Expecter) CopyShardingState 

func (_e *MockSchemaReader_Expecter) CopyShardingState(class interface{}) *MockSchemaReader_CopyShardingState_Call

CopyShardingState is a helper method to define mock.On call

  • class string

func (*MockSchemaReader_Expecter) CopyShardingStateWithVersion 

func (_e *MockSchemaReader_Expecter) CopyShardingStateWithVersion(ctx interface{}, class interface{}, version interface{}) *MockSchemaReader_CopyShardingStateWithVersion_Call

CopyShardingStateWithVersion is a helper method to define mock.On call

  • ctx context.Context
  • class string
  • version uint64

func (*MockSchemaReader_Expecter) GetShardsStatus 

func (_e *MockSchemaReader_Expecter) GetShardsStatus(class interface{}, tenant interface{}) *MockSchemaReader_GetShardsStatus_Call

GetShardsStatus is a helper method to define mock.On call

  • class string
  • tenant string

func (*MockSchemaReader_Expecter) MultiTenancy 

func (_e *MockSchemaReader_Expecter) MultiTenancy(class interface{}) *MockSchemaReader_MultiTenancy_Call

MultiTenancy is a helper method to define mock.On call

  • class string

func (*MockSchemaReader_Expecter) MultiTenancyWithVersion 

func (_e *MockSchemaReader_Expecter) MultiTenancyWithVersion(ctx interface{}, class interface{}, version interface{}) *MockSchemaReader_MultiTenancyWithVersion_Call

MultiTenancyWithVersion is a helper method to define mock.On call

  • ctx context.Context
  • class string
  • version uint64

func (*MockSchemaReader_Expecter) Read 

func (_e *MockSchemaReader_Expecter) Read(class interface{}, reader interface{}) *MockSchemaReader_Read_Call

Read is a helper method to define mock.On call

  • class string
  • reader func(*models.Class , *sharding.State) error

func (*MockSchemaReader_Expecter) ReadOnlyClass 

func (_e *MockSchemaReader_Expecter) ReadOnlyClass(name interface{}) *MockSchemaReader_ReadOnlyClass_Call

ReadOnlyClass is a helper method to define mock.On call

  • name string

func (*MockSchemaReader_Expecter) ReadOnlyClassWithVersion 

func (_e *MockSchemaReader_Expecter) ReadOnlyClassWithVersion(ctx interface{}, class interface{}, version interface{}) *MockSchemaReader_ReadOnlyClassWithVersion_Call

ReadOnlyClassWithVersion is a helper method to define mock.On call

  • ctx context.Context
  • class string
  • version uint64

func (*MockSchemaReader_Expecter) ReadOnlySchema 

func (_e *MockSchemaReader_Expecter) ReadOnlySchema() *MockSchemaReader_ReadOnlySchema_Call

ReadOnlySchema is a helper method to define mock.On call

func (*MockSchemaReader_Expecter) ReadOnlyVersionedClass 

func (_e *MockSchemaReader_Expecter) ReadOnlyVersionedClass(name interface{}) *MockSchemaReader_ReadOnlyVersionedClass_Call

ReadOnlyVersionedClass is a helper method to define mock.On call

  • name string

func (*MockSchemaReader_Expecter) ShardFromUUID 

func (_e *MockSchemaReader_Expecter) ShardFromUUID(class interface{}, uuid interface{}) *MockSchemaReader_ShardFromUUID_Call

ShardFromUUID is a helper method to define mock.On call

  • class string
  • uuid []byte

func (*MockSchemaReader_Expecter) ShardFromUUIDWithVersion 

func (_e *MockSchemaReader_Expecter) ShardFromUUIDWithVersion(ctx interface{}, class interface{}, uuid interface{}, version interface{}) *MockSchemaReader_ShardFromUUIDWithVersion_Call

ShardFromUUIDWithVersion is a helper method to define mock.On call

  • ctx context.Context
  • class string
  • uuid []byte
  • version uint64

func (*MockSchemaReader_Expecter) ShardOwner 

func (_e *MockSchemaReader_Expecter) ShardOwner(class interface{}, shard interface{}) *MockSchemaReader_ShardOwner_Call

ShardOwner is a helper method to define mock.On call

  • class string
  • shard string

func (*MockSchemaReader_Expecter) ShardOwnerWithVersion 

func (_e *MockSchemaReader_Expecter) ShardOwnerWithVersion(ctx interface{}, lass interface{}, shard interface{}, version interface{}) *MockSchemaReader_ShardOwnerWithVersion_Call

ShardOwnerWithVersion is a helper method to define mock.On call

  • ctx context.Context
  • lass string
  • shard string
  • version uint64

func (*MockSchemaReader_Expecter) ShardReplicas 

func (_e *MockSchemaReader_Expecter) ShardReplicas(class interface{}, shard interface{}) *MockSchemaReader_ShardReplicas_Call

ShardReplicas is a helper method to define mock.On call

  • class string
  • shard string

func (*MockSchemaReader_Expecter) ShardReplicasWithVersion 

func (_e *MockSchemaReader_Expecter) ShardReplicasWithVersion(ctx interface{}, class interface{}, shard interface{}, version interface{}) *MockSchemaReader_ShardReplicasWithVersion_Call

ShardReplicasWithVersion is a helper method to define mock.On call

  • ctx context.Context
  • class string
  • shard string
  • version uint64

func (*MockSchemaReader_Expecter) TenantsShardsWithVersion 

func (_e *MockSchemaReader_Expecter) TenantsShardsWithVersion(ctx interface{}, version interface{}, class interface{}, tenants ...interface{}) *MockSchemaReader_TenantsShardsWithVersion_Call

TenantsShardsWithVersion is a helper method to define mock.On call

  • ctx context.Context
  • version uint64
  • class string
  • tenants ...string

func (*MockSchemaReader_Expecter) WaitForUpdate 

func (_e *MockSchemaReader_Expecter) WaitForUpdate(ctx interface{}, version interface{}) *MockSchemaReader_WaitForUpdate_Call

WaitForUpdate is a helper method to define mock.On call

  • ctx context.Context
  • version uint64

type MockSchemaReader_GetShardsStatus_Call 

type MockSchemaReader_GetShardsStatus_Call struct {
	*mock.Call
}

MockSchemaReader_GetShardsStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetShardsStatus'

func (*MockSchemaReader_GetShardsStatus_Call) Return 

func (_c *MockSchemaReader_GetShardsStatus_Call) Return(_a0 models.ShardStatusList, _a1 error) *MockSchemaReader_GetShardsStatus_Call

func (*MockSchemaReader_GetShardsStatus_Call) Run 

func (_c *MockSchemaReader_GetShardsStatus_Call) Run(run func(class string, tenant string)) *MockSchemaReader_GetShardsStatus_Call

func (*MockSchemaReader_GetShardsStatus_Call) RunAndReturn 

func (_c *MockSchemaReader_GetShardsStatus_Call) RunAndReturn(run func(string, string) (models.ShardStatusList, error)) *MockSchemaReader_GetShardsStatus_Call

type MockSchemaReader_MultiTenancyWithVersion_Call 

type MockSchemaReader_MultiTenancyWithVersion_Call struct {
	*mock.Call
}

MockSchemaReader_MultiTenancyWithVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MultiTenancyWithVersion'

func (*MockSchemaReader_MultiTenancyWithVersion_Call) Return 

func (_c *MockSchemaReader_MultiTenancyWithVersion_Call) Return(_a0 models.MultiTenancyConfig, _a1 error) *MockSchemaReader_MultiTenancyWithVersion_Call

func (*MockSchemaReader_MultiTenancyWithVersion_Call) Run 

func (_c *MockSchemaReader_MultiTenancyWithVersion_Call) Run(run func(ctx context.Context, class string, version uint64)) *MockSchemaReader_MultiTenancyWithVersion_Call

func (*MockSchemaReader_MultiTenancyWithVersion_Call) RunAndReturn 

func (_c *MockSchemaReader_MultiTenancyWithVersion_Call) RunAndReturn(run func(context.Context, string, uint64) (models.MultiTenancyConfig, error)) *MockSchemaReader_MultiTenancyWithVersion_Call

type MockSchemaReader_MultiTenancy_Call 

type MockSchemaReader_MultiTenancy_Call struct {
	*mock.Call
}

MockSchemaReader_MultiTenancy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MultiTenancy'

func (*MockSchemaReader_MultiTenancy_Call) Return 

func (_c *MockSchemaReader_MultiTenancy_Call) Return(_a0 models.MultiTenancyConfig) *MockSchemaReader_MultiTenancy_Call

func (*MockSchemaReader_MultiTenancy_Call) Run 

func (_c *MockSchemaReader_MultiTenancy_Call) Run(run func(class string)) *MockSchemaReader_MultiTenancy_Call

func (*MockSchemaReader_MultiTenancy_Call) RunAndReturn 

func (_c *MockSchemaReader_MultiTenancy_Call) RunAndReturn(run func(string) models.MultiTenancyConfig) *MockSchemaReader_MultiTenancy_Call

type MockSchemaReader_ReadOnlyClassWithVersion_Call 

type MockSchemaReader_ReadOnlyClassWithVersion_Call struct {
	*mock.Call
}

MockSchemaReader_ReadOnlyClassWithVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReadOnlyClassWithVersion'

func (*MockSchemaReader_ReadOnlyClassWithVersion_Call) Return 

func (_c *MockSchemaReader_ReadOnlyClassWithVersion_Call) Return(_a0 *models.Class, _a1 error) *MockSchemaReader_ReadOnlyClassWithVersion_Call

func (*MockSchemaReader_ReadOnlyClassWithVersion_Call) Run 

func (_c *MockSchemaReader_ReadOnlyClassWithVersion_Call) Run(run func(ctx context.Context, class string, version uint64)) *MockSchemaReader_ReadOnlyClassWithVersion_Call

func (*MockSchemaReader_ReadOnlyClassWithVersion_Call) RunAndReturn 

func (_c *MockSchemaReader_ReadOnlyClassWithVersion_Call) RunAndReturn(run func(context.Context, string, uint64) (*models.Class, error)) *MockSchemaReader_ReadOnlyClassWithVersion_Call

type MockSchemaReader_ReadOnlyClass_Call 

type MockSchemaReader_ReadOnlyClass_Call struct {
	*mock.Call
}

MockSchemaReader_ReadOnlyClass_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReadOnlyClass'

func (*MockSchemaReader_ReadOnlyClass_Call) Return 

func (_c *MockSchemaReader_ReadOnlyClass_Call) Return(_a0 *models.Class) *MockSchemaReader_ReadOnlyClass_Call

func (*MockSchemaReader_ReadOnlyClass_Call) Run 

func (_c *MockSchemaReader_ReadOnlyClass_Call) Run(run func(name string)) *MockSchemaReader_ReadOnlyClass_Call

func (*MockSchemaReader_ReadOnlyClass_Call) RunAndReturn 

func (_c *MockSchemaReader_ReadOnlyClass_Call) RunAndReturn(run func(string) *models.Class) *MockSchemaReader_ReadOnlyClass_Call

type MockSchemaReader_ReadOnlySchema_Call 

type MockSchemaReader_ReadOnlySchema_Call struct {
	*mock.Call
}

MockSchemaReader_ReadOnlySchema_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReadOnlySchema'

func (*MockSchemaReader_ReadOnlySchema_Call) Return 

func (_c *MockSchemaReader_ReadOnlySchema_Call) Return(_a0 models.Schema) *MockSchemaReader_ReadOnlySchema_Call

func (*MockSchemaReader_ReadOnlySchema_Call) Run 

func (_c *MockSchemaReader_ReadOnlySchema_Call) Run(run func()) *MockSchemaReader_ReadOnlySchema_Call

func (*MockSchemaReader_ReadOnlySchema_Call) RunAndReturn 

func (_c *MockSchemaReader_ReadOnlySchema_Call) RunAndReturn(run func() models.Schema) *MockSchemaReader_ReadOnlySchema_Call

type MockSchemaReader_ReadOnlyVersionedClass_Call 

type MockSchemaReader_ReadOnlyVersionedClass_Call struct {
	*mock.Call
}

MockSchemaReader_ReadOnlyVersionedClass_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReadOnlyVersionedClass'

func (*MockSchemaReader_ReadOnlyVersionedClass_Call) Return 

func (_c *MockSchemaReader_ReadOnlyVersionedClass_Call) Return(_a0 versioned.Class) *MockSchemaReader_ReadOnlyVersionedClass_Call

func (*MockSchemaReader_ReadOnlyVersionedClass_Call) Run 

func (_c *MockSchemaReader_ReadOnlyVersionedClass_Call) Run(run func(name string)) *MockSchemaReader_ReadOnlyVersionedClass_Call

func (*MockSchemaReader_ReadOnlyVersionedClass_Call) RunAndReturn 

func (_c *MockSchemaReader_ReadOnlyVersionedClass_Call) RunAndReturn(run func(string) versioned.Class) *MockSchemaReader_ReadOnlyVersionedClass_Call

type MockSchemaReader_Read_Call 

type MockSchemaReader_Read_Call struct {
	*mock.Call
}

MockSchemaReader_Read_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Read'

func (*MockSchemaReader_Read_Call) Return 

func (_c *MockSchemaReader_Read_Call) Return(_a0 error) *MockSchemaReader_Read_Call

func (*MockSchemaReader_Read_Call) Run 

func (_c *MockSchemaReader_Read_Call) Run(run func(class string, reader func(*models.Class, *sharding.State) error)) *MockSchemaReader_Read_Call

func (*MockSchemaReader_Read_Call) RunAndReturn 

func (_c *MockSchemaReader_Read_Call) RunAndReturn(run func(string, func(*models.Class, *sharding.State) error) error) *MockSchemaReader_Read_Call

type MockSchemaReader_ShardFromUUIDWithVersion_Call 

type MockSchemaReader_ShardFromUUIDWithVersion_Call struct {
	*mock.Call
}

MockSchemaReader_ShardFromUUIDWithVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ShardFromUUIDWithVersion'

func (*MockSchemaReader_ShardFromUUIDWithVersion_Call) Return 

func (_c *MockSchemaReader_ShardFromUUIDWithVersion_Call) Return(_a0 string, _a1 error) *MockSchemaReader_ShardFromUUIDWithVersion_Call

func (*MockSchemaReader_ShardFromUUIDWithVersion_Call) Run 

func (_c *MockSchemaReader_ShardFromUUIDWithVersion_Call) Run(run func(ctx context.Context, class string, uuid []byte, version uint64)) *MockSchemaReader_ShardFromUUIDWithVersion_Call

func (*MockSchemaReader_ShardFromUUIDWithVersion_Call) RunAndReturn 

func (_c *MockSchemaReader_ShardFromUUIDWithVersion_Call) RunAndReturn(run func(context.Context, string, []byte, uint64) (string, error)) *MockSchemaReader_ShardFromUUIDWithVersion_Call

type MockSchemaReader_ShardFromUUID_Call 

type MockSchemaReader_ShardFromUUID_Call struct {
	*mock.Call
}

MockSchemaReader_ShardFromUUID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ShardFromUUID'

func (*MockSchemaReader_ShardFromUUID_Call) Return 

func (_c *MockSchemaReader_ShardFromUUID_Call) Return(_a0 string) *MockSchemaReader_ShardFromUUID_Call

func (*MockSchemaReader_ShardFromUUID_Call) Run 

func (_c *MockSchemaReader_ShardFromUUID_Call) Run(run func(class string, uuid []byte)) *MockSchemaReader_ShardFromUUID_Call

func (*MockSchemaReader_ShardFromUUID_Call) RunAndReturn 

func (_c *MockSchemaReader_ShardFromUUID_Call) RunAndReturn(run func(string, []byte) string) *MockSchemaReader_ShardFromUUID_Call

type MockSchemaReader_ShardOwnerWithVersion_Call 

type MockSchemaReader_ShardOwnerWithVersion_Call struct {
	*mock.Call
}

MockSchemaReader_ShardOwnerWithVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ShardOwnerWithVersion'

func (*MockSchemaReader_ShardOwnerWithVersion_Call) Return 

func (_c *MockSchemaReader_ShardOwnerWithVersion_Call) Return(_a0 string, _a1 error) *MockSchemaReader_ShardOwnerWithVersion_Call

func (*MockSchemaReader_ShardOwnerWithVersion_Call) Run 

func (_c *MockSchemaReader_ShardOwnerWithVersion_Call) Run(run func(ctx context.Context, lass string, shard string, version uint64)) *MockSchemaReader_ShardOwnerWithVersion_Call

func (*MockSchemaReader_ShardOwnerWithVersion_Call) RunAndReturn 

func (_c *MockSchemaReader_ShardOwnerWithVersion_Call) RunAndReturn(run func(context.Context, string, string, uint64) (string, error)) *MockSchemaReader_ShardOwnerWithVersion_Call

type MockSchemaReader_ShardOwner_Call 

type MockSchemaReader_ShardOwner_Call struct {
	*mock.Call
}

MockSchemaReader_ShardOwner_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ShardOwner'

func (*MockSchemaReader_ShardOwner_Call) Return 

func (_c *MockSchemaReader_ShardOwner_Call) Return(_a0 string, _a1 error) *MockSchemaReader_ShardOwner_Call

func (*MockSchemaReader_ShardOwner_Call) Run 

func (_c *MockSchemaReader_ShardOwner_Call) Run(run func(class string, shard string)) *MockSchemaReader_ShardOwner_Call

func (*MockSchemaReader_ShardOwner_Call) RunAndReturn 

func (_c *MockSchemaReader_ShardOwner_Call) RunAndReturn(run func(string, string) (string, error)) *MockSchemaReader_ShardOwner_Call

type MockSchemaReader_ShardReplicasWithVersion_Call 

type MockSchemaReader_ShardReplicasWithVersion_Call struct {
	*mock.Call
}

MockSchemaReader_ShardReplicasWithVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ShardReplicasWithVersion'

func (*MockSchemaReader_ShardReplicasWithVersion_Call) Return 

func (_c *MockSchemaReader_ShardReplicasWithVersion_Call) Return(_a0 []string, _a1 error) *MockSchemaReader_ShardReplicasWithVersion_Call

func (*MockSchemaReader_ShardReplicasWithVersion_Call) Run 

func (_c *MockSchemaReader_ShardReplicasWithVersion_Call) Run(run func(ctx context.Context, class string, shard string, version uint64)) *MockSchemaReader_ShardReplicasWithVersion_Call

func (*MockSchemaReader_ShardReplicasWithVersion_Call) RunAndReturn 

func (_c *MockSchemaReader_ShardReplicasWithVersion_Call) RunAndReturn(run func(context.Context, string, string, uint64) ([]string, error)) *MockSchemaReader_ShardReplicasWithVersion_Call

type MockSchemaReader_ShardReplicas_Call 

type MockSchemaReader_ShardReplicas_Call struct {
	*mock.Call
}

MockSchemaReader_ShardReplicas_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ShardReplicas'

func (*MockSchemaReader_ShardReplicas_Call) Return 

func (_c *MockSchemaReader_ShardReplicas_Call) Return(_a0 []string, _a1 error) *MockSchemaReader_ShardReplicas_Call

func (*MockSchemaReader_ShardReplicas_Call) Run 

func (_c *MockSchemaReader_ShardReplicas_Call) Run(run func(class string, shard string)) *MockSchemaReader_ShardReplicas_Call

func (*MockSchemaReader_ShardReplicas_Call) RunAndReturn 

func (_c *MockSchemaReader_ShardReplicas_Call) RunAndReturn(run func(string, string) ([]string, error)) *MockSchemaReader_ShardReplicas_Call

type MockSchemaReader_TenantsShardsWithVersion_Call 

type MockSchemaReader_TenantsShardsWithVersion_Call struct {
	*mock.Call
}

MockSchemaReader_TenantsShardsWithVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TenantsShardsWithVersion'

func (*MockSchemaReader_TenantsShardsWithVersion_Call) Return 

func (_c *MockSchemaReader_TenantsShardsWithVersion_Call) Return(_a0 map[string]string, _a1 error) *MockSchemaReader_TenantsShardsWithVersion_Call

func (*MockSchemaReader_TenantsShardsWithVersion_Call) Run 

func (_c *MockSchemaReader_TenantsShardsWithVersion_Call) Run(run func(ctx context.Context, version uint64, class string, tenants ...string)) *MockSchemaReader_TenantsShardsWithVersion_Call

func (*MockSchemaReader_TenantsShardsWithVersion_Call) RunAndReturn 

func (_c *MockSchemaReader_TenantsShardsWithVersion_Call) RunAndReturn(run func(context.Context, uint64, string, ...string) (map[string]string, error)) *MockSchemaReader_TenantsShardsWithVersion_Call

type MockSchemaReader_WaitForUpdate_Call 

type MockSchemaReader_WaitForUpdate_Call struct {
	*mock.Call
}

MockSchemaReader_WaitForUpdate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WaitForUpdate'

func (*MockSchemaReader_WaitForUpdate_Call) Return 

func (_c *MockSchemaReader_WaitForUpdate_Call) Return(_a0 error) *MockSchemaReader_WaitForUpdate_Call

func (*MockSchemaReader_WaitForUpdate_Call) Run 

func (_c *MockSchemaReader_WaitForUpdate_Call) Run(run func(ctx context.Context, version uint64)) *MockSchemaReader_WaitForUpdate_Call

func (*MockSchemaReader_WaitForUpdate_Call) RunAndReturn 

func (_c *MockSchemaReader_WaitForUpdate_Call) RunAndReturn(run func(context.Context, uint64) error) *MockSchemaReader_WaitForUpdate_Call

type SchemaReader 

type SchemaReader interface {
	// WaitForUpdate ensures that the local schema has caught up to version.
	WaitForUpdate(ctx context.Context, version uint64) error

	// These schema reads function reads the metadata immediately present in the local schema and can be eventually
	// consistent.
	// For details about each endpoint see [github.com/weaviate/weaviate/cluster/schema.SchemaReader].
	ClassEqual(name string) string
	MultiTenancy(class string) models.MultiTenancyConfig
	ClassInfo(class string) (ci schema.ClassInfo)
	ReadOnlyClass(name string) *models.Class
	ReadOnlyVersionedClass(name string) versioned.Class
	ReadOnlySchema() models.Schema
	CopyShardingState(class string) *sharding.State
	ShardReplicas(class, shard string) ([]string, error)
	ShardFromUUID(class string, uuid []byte) string
	ShardOwner(class, shard string) (string, error)
	Read(class string, reader func(*models.Class, *sharding.State) error) error
	GetShardsStatus(class, tenant string) (models.ShardStatusList, error)

	// These schema reads function (...WithVersion) return the metadata once the local schema has caught up to the
	// version parameter. If version is 0 is behaves exactly the same as eventual consistent reads.
	// For details about each endpoint see [github.com/weaviate/weaviate/cluster/schema.VersionedSchemaReader].
	ClassInfoWithVersion(ctx context.Context, class string, version uint64) (schema.ClassInfo, error)
	MultiTenancyWithVersion(ctx context.Context, class string, version uint64) (models.MultiTenancyConfig, error)
	ReadOnlyClassWithVersion(ctx context.Context, class string, version uint64) (*models.Class, error)
	ShardOwnerWithVersion(ctx context.Context, lass, shard string, version uint64) (string, error)
	ShardFromUUIDWithVersion(ctx context.Context, class string, uuid []byte, version uint64) (string, error)
	ShardReplicasWithVersion(ctx context.Context, class, shard string, version uint64) ([]string, error)
	TenantsShardsWithVersion(ctx context.Context, version uint64, class string, tenants ...string) (map[string]string, error)
	CopyShardingStateWithVersion(ctx context.Context, class string, version uint64) (*sharding.State, error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.