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 WithErrGroup(eg errgroup.Group) Option
  • func WithGateway(client vald.Client) Option
  • func WithIndexReplica(num int) Option
  • func WithKVSCompactionInterval(dur string) Option
  • func WithKVSSyncInterval(dur string) 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 WithErrGroup

func WithErrGroup(eg errgroup.Group) Option

WithErrGroup returns Option that set errgroup.

func WithGateway

func WithGateway(client vald.Client) Option

WithGateway returns Option that sets discoverer client.

func WithIndexReplica

func WithIndexReplica(num int) Option

WithIndexReplica returns Option that sets index replica.

func WithKVSCompactionInterval

func WithKVSCompactionInterval(dur string) Option

WithKVSCompactionInterval returns Option that sets interval for background file compaction.

func WithKVSSyncInterval

func WithKVSSyncInterval(dur string) Option

WithKVSSyncInterval returns Option that sets interval for background file sync.

func WithStreamListConcurrency

func WithStreamListConcurrency(num int) Option

WithStreamListConcurrency returns Option that sets concurrency for StreamList field value.