viper

README

Viper Topology Provider

The Viper topology provider allows you to work with Tarantool configuration and retrieve topology from all sources, which are supported by Viper in file formats.

There are 2 supported configuration formats: moonlibs and tarantool3.

Examples

ETCD v3

import (
	"context"
        "github.com/spf13/viper"
	_ "github.com/spf13/viper/remote" // dont forget to import remote pkg for viper remote
        vprovider "github.com/tarantool/go-vshard-router/providers/viper"
)

// ...
ctx := context.TODO()
key := "/myapp"
etcdViper := viper.New()
err = etcdViper.AddRemoteProvider("etcd3", "http://127.0.0.1:2379", key)
if err != nil {
	panic(err)
}

etcdViper.SetConfigType("yaml")
err = etcdViper.ReadRemoteConfig()
if err != nil {
panic(err)
}

provider := vprovider.NewProvider(ctx, etcdViper, vprovider.ConfigTypeTarantool3)

/// ...

Check more config examples in test dir or inside provider_test.go

Documentation

Index

• type ConfigType
• type Convertable
• type Provider
  • func NewProvider(ctx context.Context, v *srcviper.Viper, cfgType ConfigType) *Provider
  • func (p *Provider) Close()
  • func (p *Provider) Init(c vshardrouter.TopologyController) error
  • func (p *Provider) Topology() map[vshardrouter.ReplicasetInfo][]vshardrouter.InstanceInfo
  • func (p *Provider) Validate() error
  • func (p *Provider) WatchChanges() *Provider

Types

type ConfigType

type ConfigType int

const (
	ConfigTypeMoonlibs ConfigType = iota
	ConfigTypeTarantool3
)

type Convertable

type Convertable interface {
	Convert() map[vshardrouter.ReplicasetInfo][]vshardrouter.InstanceInfo
}

type Provider

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

func NewProvider

func NewProvider(ctx context.Context, v *srcviper.Viper, cfgType ConfigType) *Provider

func (*Provider) Close

func (p *Provider) Close()

func (*Provider) Init

func (p *Provider) Init(c vshardrouter.TopologyController) error

func (*Provider) Topology

func (p *Provider) Topology() map[vshardrouter.ReplicasetInfo][]vshardrouter.InstanceInfo

func (*Provider) Validate

func (p *Provider) Validate() error

func (*Provider) WatchChanges

func (p *Provider) WatchChanges() *Provider