clients

Documentation

Index

• Variables
• func GetSqlDriver(dbConf config.DBConfig) (*gorm.DB, error)
• func InitDBClients()
• func MustInit()
• type EtcdClient
  • func NewEtcdClient(config *config.EtcdConfig) (*EtcdClient, error)
  • func (e *EtcdClient) GetConfig(group, dataId string) (string, error)
  • func (e *EtcdClient) PublishConfig(group, dataId, content string) error
  • func (e *EtcdClient) SyncRun(TTL int, key string, job func() error) error

Variables

var ErrReviewFailed = errors.New("review key already exists")

var ReadDBCli *gorm.DB

var WriteDBCli *gorm.DB

Functions

func GetSqlDriver

func GetSqlDriver(dbConf config.DBConfig) (*gorm.DB, error)

func InitDBClients

func InitDBClients()

func MustInit

func MustInit()

Types

type EtcdClient

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

func NewEtcdClient

func NewEtcdClient(config *config.EtcdConfig) (*EtcdClient, error)

func (*EtcdClient) GetConfig

func (e *EtcdClient) GetConfig(group, dataId string) (string, error)

func (*EtcdClient) PublishConfig

func (e *EtcdClient) PublishConfig(group, dataId, content string) error

func (*EtcdClient) SyncRun

func (e *EtcdClient) SyncRun(TTL int, key string, job func() error) error