service

Documentation

Overview

Copyright (C) 2019-2021 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-2021 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-2021 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-2021 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 Loader
  • func NewLoader(opts ...Option) (Loader, error)
• type Option
  • func WithAddr(a string) Option
  • func WithBatchSize(b int) Option
  • func WithClient(c grpc.Client) Option
  • func WithConcurrency(c int) Option
  • func WithDataset(n string) Option
  • func WithErrGroup(eg errgroup.Group) Option
  • func WithOperation(op string) Option
  • func WithProgressDuration(pd string) Option

Types

type Loader

type Loader interface {
	Prepare(context.Context) error
	Do(context.Context) <-chan error
}

Loader is representation of load test.

func NewLoader

func NewLoader(opts ...Option) (Loader, error)

NewLoader returns Loader implementation.

type Option

type Option func(*loader) error

Option is load test configuration.

func WithAddr

func WithAddr(a string) Option

WithAddr sets load test server address.

func WithBatchSize

func WithBatchSize(b int) Option

WithBatchSize sets load test batch size.

func WithClient

func WithClient(c grpc.Client) Option

WithClient sets grpc Client.

func WithConcurrency

func WithConcurrency(c int) Option

WithConcurrency sets load test concurrency.

func WithDataset

func WithDataset(n string) Option

WithDataset sets dataset name.

func WithErrGroup

func WithErrGroup(eg errgroup.Group) Option

WithErrGroup sets user specified error group.

func WithOperation

func WithOperation(op string) Option

WithOperation sets operation of load test.

func WithProgressDuration

func WithProgressDuration(pd string) Option

WithProgressDuration sets duration of progress show.