service

Documentation

Overview

Copyright (C) 2019-2024 vdaas.org vald team <vald@vdaas.org>

Licensed under the Apache License, Version 2.0 (the "License"); You may not use this file except in compliance with the License. You may obtain a copy of the License at

https://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright (C) 2019-2024 vdaas.org vald team <vald@vdaas.org>

Licensed under the Apache License, Version 2.0 (the "License"); You may not use this file except in compliance with the License. You may obtain a copy of the License at

https://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• type Corrector
  • func New(opts ...Option) (_ Corrector, err error)
• type Option
  • func WithDiscoverer(client discoverer.Client) Option
  • func WithIndexReplica(num int) Option
  • func WithKvsAsyncWriteConcurrency(num int) Option
  • func WithStreamListConcurrency(num int) Option

Types

type Corrector

type Corrector interface {
	Start(ctx context.Context) error
	StartClient(ctx context.Context) (<-chan error, error)
	PreStop(ctx context.Context) error
	// For metrics
	NumberOfCheckedIndex() uint64
	NumberOfCorrectedOldIndex() uint64
	NumberOfCorrectedReplication() uint64
}

func New

func New(opts ...Option) (_ Corrector, err error)

type Option

type Option func(*correct) error

Option represents the functional option for index corrector.

func WithDiscoverer

func WithDiscoverer(client discoverer.Client) Option

WithDiscoverer returns Option that sets discoverer client.

func WithIndexReplica

func WithIndexReplica(num int) Option

WithIndexReplica returns Option that sets index replica.

func WithKvsAsyncWriteConcurrency

func WithKvsAsyncWriteConcurrency(num int) Option

WithKvsAsyncWriteConcurrency returns Option that sets concurrency for kvs async write.

func WithStreamListConcurrency

func WithStreamListConcurrency(num int) Option

WithStreamListConcurrency returns Option that sets concurrency for StreamList field value.