framework

Documentation

Overview

tests/e2e/pkg/framework/framework.go

Index

• func WithConfig(cfg *Config) func(*Config)
• func WithIdleDuration(d time.Duration) func(*Config)
• func WithMaxCount(count int32) func(*Config)
• func WithMaxSize(size int64) func(*Config)
• func WithRetentionCheckInterval(d time.Duration) func(*Config)
• func WithRetentionPeriod(d time.Duration) func(*Config)
• func WithShardDuration(d time.Duration) func(*Config)
• type Config
  • func DefaultConfig(name string) *Config
• type TestHarness
  • func NewTestHarness(name string, opts ...func(*Config)) (*TestHarness, error)
  • func (h *TestHarness) Close() error
  • func (h *TestHarness) Config() *Config
  • func (h *TestHarness) DB() *microts.DB
  • func (h *TestHarness) DataDir() string
  • func (h *TestHarness) QueryRange(ctx context.Context, start, end int64) (*types.QueryRangeResponse, error)
  • func (h *TestHarness) StartTime() int64
  • func (h *TestHarness) TempDir() string
  • func (h *TestHarness) VerifyDataIntegrity(count int, interval time.Duration) error
  • func (h *TestHarness) WritePoints(ctx context.Context, count int, interval time.Duration) error

Functions

func WithConfig

func WithConfig(cfg *Config) func(*Config)

WithConfig 自定义配置选项

func WithIdleDuration

func WithIdleDuration(d time.Duration) func(*Config)

WithIdleDuration 设置空闲刷盘时间

func WithMaxCount

func WithMaxCount(count int32) func(*Config)

WithMaxCount 设置最大条目数

func WithMaxSize

func WithMaxSize(size int64) func(*Config)

WithMaxSize 设置最大内存大小

func WithRetentionCheckInterval

func WithRetentionCheckInterval(d time.Duration) func(*Config)

WithRetentionCheckInterval 设置 retention 检查间隔

func WithRetentionPeriod

func WithRetentionPeriod(d time.Duration) func(*Config)

WithRetentionPeriod 设置数据保留期

func WithShardDuration

func WithShardDuration(d time.Duration) func(*Config)

WithShardDuration 设置 shard duration

Types

type Config

type Config struct {
	DBName                 string
	MeasurementName        string
	ShardDuration          time.Duration
	MaxSize                int64
	MaxCount               int32
	IdleDurationNanos      int64
	RetentionPeriod        time.Duration
	RetentionCheckInterval time.Duration
}

Config 数据库配置选项

func DefaultConfig

func DefaultConfig(name string) *Config

DefaultConfig 返回默认配置

type TestHarness

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

TestHarness 测试工具，管理数据库生命周期

func NewTestHarness

func NewTestHarness(name string, opts ...func(*Config)) (*TestHarness, error)

NewTestHarness 创建测试工具

func (*TestHarness) Close

func (h *TestHarness) Close() error

Close 关闭数据库并清理临时目录

func (*TestHarness) Config

func (h *TestHarness) Config() *Config

Config 返回配置

func (*TestHarness) DB

func (h *TestHarness) DB() *microts.DB

DB 返回数据库实例

func (*TestHarness) DataDir

func (h *TestHarness) DataDir() string

DataDir 返回数据目录

func (*TestHarness) QueryRange

func (h *TestHarness) QueryRange(ctx context.Context, start, end int64) (*types.QueryRangeResponse, error)

QueryRange 查询指定时间范围的数据

func (*TestHarness) StartTime

func (h *TestHarness) StartTime() int64

StartTime 返回测试开始时间

func (*TestHarness) TempDir

func (h *TestHarness) TempDir() string

TempDir 返回临时目录

func (*TestHarness) VerifyDataIntegrity

func (h *TestHarness) VerifyDataIntegrity(count int, interval time.Duration) error

VerifyDataIntegrity 验证数据完整性

func (*TestHarness) WritePoints

func (h *TestHarness) WritePoints(ctx context.Context, count int, interval time.Duration) error

WritePoints写入多个数据点