fakes

Documentation

Index

• type FakeClusterState
  • func NewFakeClusterState(hosts ...string) *FakeClusterState
  • func (f *FakeClusterState) AllNames() []string
  • func (f *FakeClusterState) ClusterHealthScore() int
  • func (f *FakeClusterState) Execute(cmd *command.ApplyRequest) error
  • func (f *FakeClusterState) Hostnames() []string
  • func (f *FakeClusterState) LocalName() string
  • func (f *FakeClusterState) NodeCount() int
  • func (f *FakeClusterState) NodeHostname(string) (string, bool)
  • func (f *FakeClusterState) ResolveParentNodes(string, string) (map[string]string, error)
  • func (f *FakeClusterState) SchemaSyncIgnored() bool
  • func (f *FakeClusterState) SkipSchemaRepair() bool
• type FakeRPCAddressResolver
  • func NewFakeRPCAddressResolver(addr string, err error) *FakeRPCAddressResolver
  • func (m *FakeRPCAddressResolver) Address(raftAddress string) (string, error)
• type MockAddressResolver
  • func NewMockAddressResolver(f func(id string) string) *MockAddressResolver
  • func (m *MockAddressResolver) NodeAddress(id string) string
• type MockParser
  • func NewMockParser() *MockParser
  • func (m *MockParser) ParseClass(class *models.Class) error
  • func (m *MockParser) ParseClassUpdate(class, update *models.Class) (*models.Class, error)
• type MockSchemaExecutor
  • func NewMockSchemaExecutor() *MockSchemaExecutor
  • func (m *MockSchemaExecutor) AddClass(req cmd.AddClassRequest) error
  • func (m *MockSchemaExecutor) AddProperty(class string, req cmd.AddPropertyRequest) error
  • func (m *MockSchemaExecutor) AddTenants(class string, req *cmd.AddTenantsRequest) error
  • func (m *MockSchemaExecutor) Close(ctx context.Context) error
  • func (m *MockSchemaExecutor) DeleteClass(name string, hasFrozen bool) error
  • func (m *MockSchemaExecutor) DeleteTenants(class string, tenants []*models.Tenant) error
  • func (m *MockSchemaExecutor) GetShardsStatus(class, tenant string) (models.ShardStatusList, error)
  • func (m *MockSchemaExecutor) Open(ctx context.Context) error
  • func (m *MockSchemaExecutor) ReloadLocalDB(ctx context.Context, all []cmd.UpdateClassRequest) error
  • func (m *MockSchemaExecutor) RestoreClassDir(class string) error
  • func (m *MockSchemaExecutor) TriggerSchemaUpdateCallbacks()
  • func (m *MockSchemaExecutor) UpdateClass(req cmd.UpdateClassRequest) error
  • func (m *MockSchemaExecutor) UpdateIndex(req cmd.UpdateClassRequest) error
  • func (m *MockSchemaExecutor) UpdateShardStatus(req *cmd.UpdateShardStatusRequest) error
  • func (m *MockSchemaExecutor) UpdateTenants(class string, req *cmd.UpdateTenantsRequest) error
  • func (m *MockSchemaExecutor) UpdateTenantsProcess(class string, req *cmd.TenantProcessRequest) error

Types

type FakeClusterState

type FakeClusterState struct {
	cluster.NodeSelector
	// contains filtered or unexported fields
}

func NewFakeClusterState

func NewFakeClusterState(hosts ...string) *FakeClusterState

func (*FakeClusterState) AllNames

func (f *FakeClusterState) AllNames() []string

func (*FakeClusterState) ClusterHealthScore

func (f *FakeClusterState) ClusterHealthScore() int

func (*FakeClusterState) Execute

func (f *FakeClusterState) Execute(cmd *command.ApplyRequest) error

func (*FakeClusterState) Hostnames

func (f *FakeClusterState) Hostnames() []string

func (*FakeClusterState) LocalName

func (f *FakeClusterState) LocalName() string

func (*FakeClusterState) NodeCount

func (f *FakeClusterState) NodeCount() int

func (*FakeClusterState) NodeHostname

func (f *FakeClusterState) NodeHostname(string) (string, bool)

func (*FakeClusterState) ResolveParentNodes

func (f *FakeClusterState) ResolveParentNodes(string, string,
) (map[string]string, error)

func (*FakeClusterState) SchemaSyncIgnored

func (f *FakeClusterState) SchemaSyncIgnored() bool

func (*FakeClusterState) SkipSchemaRepair

func (f *FakeClusterState) SkipSchemaRepair() bool

type FakeRPCAddressResolver

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

func NewFakeRPCAddressResolver

func NewFakeRPCAddressResolver(addr string, err error) *FakeRPCAddressResolver

func (*FakeRPCAddressResolver) Address

func (m *FakeRPCAddressResolver) Address(raftAddress string) (string, error)

type MockAddressResolver

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

func NewMockAddressResolver

func NewMockAddressResolver(f func(id string) string) *MockAddressResolver

func (*MockAddressResolver) NodeAddress

func (m *MockAddressResolver) NodeAddress(id string) string

type MockParser

type MockParser struct {
	mock.Mock
}

func NewMockParser

func NewMockParser() *MockParser

func (*MockParser) ParseClass

func (m *MockParser) ParseClass(class *models.Class) error

func (*MockParser) ParseClassUpdate

func (m *MockParser) ParseClassUpdate(class, update *models.Class) (*models.Class, error)

type MockSchemaExecutor

type MockSchemaExecutor struct {
	mock.Mock
}

func NewMockSchemaExecutor

func NewMockSchemaExecutor() *MockSchemaExecutor

func (*MockSchemaExecutor) AddClass

func (m *MockSchemaExecutor) AddClass(req cmd.AddClassRequest) error

func (*MockSchemaExecutor) AddProperty

func (m *MockSchemaExecutor) AddProperty(class string, req cmd.AddPropertyRequest) error

func (*MockSchemaExecutor) AddTenants

func (m *MockSchemaExecutor) AddTenants(class string, req *cmd.AddTenantsRequest) error

func (*MockSchemaExecutor) Close

func (m *MockSchemaExecutor) Close(ctx context.Context) error

func (*MockSchemaExecutor) DeleteClass

func (m *MockSchemaExecutor) DeleteClass(name string, hasFrozen bool) error

func (*MockSchemaExecutor) DeleteTenants

func (m *MockSchemaExecutor) DeleteTenants(class string, tenants []*models.Tenant) error

func (*MockSchemaExecutor) GetShardsStatus

func (m *MockSchemaExecutor) GetShardsStatus(class, tenant string) (models.ShardStatusList, error)

func (*MockSchemaExecutor) Open

func (m *MockSchemaExecutor) Open(ctx context.Context) error

func (*MockSchemaExecutor) ReloadLocalDB

func (m *MockSchemaExecutor) ReloadLocalDB(ctx context.Context, all []cmd.UpdateClassRequest) error

func (*MockSchemaExecutor) RestoreClassDir

func (m *MockSchemaExecutor) RestoreClassDir(class string) error

func (*MockSchemaExecutor) TriggerSchemaUpdateCallbacks

func (m *MockSchemaExecutor) TriggerSchemaUpdateCallbacks()

func (*MockSchemaExecutor) UpdateClass

func (m *MockSchemaExecutor) UpdateClass(req cmd.UpdateClassRequest) error

func (*MockSchemaExecutor) UpdateIndex

func (m *MockSchemaExecutor) UpdateIndex(req cmd.UpdateClassRequest) error

func (*MockSchemaExecutor) UpdateShardStatus

func (m *MockSchemaExecutor) UpdateShardStatus(req *cmd.UpdateShardStatusRequest) error

func (*MockSchemaExecutor) UpdateTenants

func (m *MockSchemaExecutor) UpdateTenants(class string, req *cmd.UpdateTenantsRequest) error

func (*MockSchemaExecutor) UpdateTenantsProcess

func (m *MockSchemaExecutor) UpdateTenantsProcess(class string, req *cmd.TenantProcessRequest) error