clustersql

Documentation

Index

• func GetClusterSetting(ctx context.Context, db *sql.DB, name string) (string, error)
• func IsValidClusterSettingName(name string) error
• func RangeMoveDuration(ctx context.Context, db *sql.DB) (time.Duration, error)
• func SetClusterSetting(ctx context.Context, db *sql.DB, name, value string) error
• type GarbageCollectionConfig
• type Zone
  • func ZoneConfigs(ctx context.Context, db *sql.DB) ([]Zone, error)
• type ZoneConfig
  • func (c *ZoneConfig) Scan(value interface{}) error

Functions

func GetClusterSetting

func GetClusterSetting(ctx context.Context, db *sql.DB, name string) (string, error)

GetClusterSetting func

func IsValidClusterSettingName

func IsValidClusterSettingName(name string) error

IsValidClusterSettingName func

func RangeMoveDuration

func RangeMoveDuration(ctx context.Context, db *sql.DB) (time.Duration, error)

RangeMoveDuration calculates the slowest time.Duration that a range would reasonably take to move from one node to another. This duration does not account for IOPs or cluster load. If used as a timeout a multiple of this value should be used.

func SetClusterSetting

func SetClusterSetting(ctx context.Context, db *sql.DB, name, value string) error

SetClusterSetting func

Types

type GarbageCollectionConfig

type GarbageCollectionConfig struct {
	TTLSeconds uint `yaml:"ttlseconds"`
}

GarbageCollectionConfig struct

type Zone

type Zone struct {
	Target string
	Config ZoneConfig
}

Zone struct

func ZoneConfigs

func ZoneConfigs(ctx context.Context, db *sql.DB) ([]Zone, error)

ZoneConfigs func

type ZoneConfig

type ZoneConfig struct {
	RangeMinBytes     uint64                  `yaml:"range_min_bytes"`
	RangeMaxBytes     uint64                  `yaml:"range_max_bytes"`
	Replicas          uint                    `yaml:"num_replicas"`
	GarbageCollection GarbageCollectionConfig `yaml:"gc"`
}

ZoneConfig struct

func (*ZoneConfig) Scan

func (c *ZoneConfig) Scan(value interface{}) error

Scan func