service

Documentation

Index

• Constants
• type EtcdCollection
• type EtcdServiceOpen
  • func GetEtcdOpen(name string, e EtcdCollection) *EtcdServiceOpen
  • func WatchEtcdOpen(name string, e EtcdCollection) *EtcdServiceOpen
  • func (e *EtcdServiceOpen) GetAddress() []string
  • func (e *EtcdServiceOpen) GetClient() *clientv3.Client
  • func (e *EtcdServiceOpen) GetConfig() interface{}
  • func (e *EtcdServiceOpen) Name() string
  • func (e *EtcdServiceOpen) ServerName() string
  • func (e *EtcdServiceOpen) Update(cs *source.ChangeSet)
• type MysqlCollection
• type MysqlServiceOpen
  • func GetMysqlOpen(name string, m MysqlCollection) *MysqlServiceOpen
  • func WatchMysqlOpen(name string, m MysqlCollection) *MysqlServiceOpen
  • func (m *MysqlServiceOpen) GetDB() *gorm.DB
  • func (m *MysqlServiceOpen) Name() string
  • func (m *MysqlServiceOpen) Update(cs *source.ChangeSet)
• type RedisCollection
• type RedisServiceOpen
  • func GetRedisOpen(name string, r RedisCollection) *RedisServiceOpen
  • func WatchRedisOpen(name string, r RedisCollection) *RedisServiceOpen
  • func (r *RedisServiceOpen) CloseWatch(name string)
  • func (r *RedisServiceOpen) GetAddress() string
  • func (r *RedisServiceOpen) GetClient() *redis.Client
  • func (r *RedisServiceOpen) GetConfig() interface{}
  • func (r *RedisServiceOpen) Name() string
  • func (r *RedisServiceOpen) Update(cs *source.ChangeSet)
  • func (r *RedisServiceOpen) Watch(name string) chan bool

Constants

const (
	EtcdWatch  = "watch"
	EtcdStatic = "static"
)

const (
	MysqlWatch  = "watch"
	MysqlStatic = "static"
)

const (
	RedisWatch  = "watch"
	RedisStatic = "static"
)

Types

type EtcdCollection

type EtcdCollection interface {
	EtcdCollection(config []byte) (*clientv3.Client, error)
	GetEtcdService() (*clientv3.Client, error)
	GetConfig() interface{}
	GetAddress() []string
	ServerName() string
}

type EtcdServiceOpen

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

func GetEtcdOpen

func GetEtcdOpen(name string, e EtcdCollection) *EtcdServiceOpen

func WatchEtcdOpen

func WatchEtcdOpen(name string, e EtcdCollection) *EtcdServiceOpen

func (*EtcdServiceOpen) GetAddress

func (e *EtcdServiceOpen) GetAddress() []string

func (*EtcdServiceOpen) GetClient

func (e *EtcdServiceOpen) GetClient() *clientv3.Client

func (*EtcdServiceOpen) GetConfig

func (e *EtcdServiceOpen) GetConfig() interface{}

func (*EtcdServiceOpen) Name

func (e *EtcdServiceOpen) Name() string

func (*EtcdServiceOpen) ServerName

func (e *EtcdServiceOpen) ServerName() string

func (*EtcdServiceOpen) Update

func (e *EtcdServiceOpen) Update(cs *source.ChangeSet)

type MysqlCollection

type MysqlCollection interface {
	MysqlCollection(config []byte) (*gorm.DB, error)
	GetMysqlService() (*gorm.DB, error)
}

type MysqlServiceOpen

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

func GetMysqlOpen

func GetMysqlOpen(name string, m MysqlCollection) *MysqlServiceOpen

func WatchMysqlOpen

func WatchMysqlOpen(name string, m MysqlCollection) *MysqlServiceOpen

func (*MysqlServiceOpen) GetDB

func (m *MysqlServiceOpen) GetDB() *gorm.DB

func (*MysqlServiceOpen) Name

func (m *MysqlServiceOpen) Name() string

func (*MysqlServiceOpen) Update

func (m *MysqlServiceOpen) Update(cs *source.ChangeSet)

type RedisCollection

type RedisCollection interface {
	RedisCollection([]byte) (*redis.Client, error)
	GetRedisService() (*redis.Client, error)
	GetConfig() interface{}
	GetAddress() string
}

type RedisServiceOpen

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

func GetRedisOpen

func GetRedisOpen(name string, r RedisCollection) *RedisServiceOpen

func WatchRedisOpen

func WatchRedisOpen(name string, r RedisCollection) *RedisServiceOpen

func (*RedisServiceOpen) CloseWatch

func (r *RedisServiceOpen) CloseWatch(name string)

func (*RedisServiceOpen) GetAddress

func (r *RedisServiceOpen) GetAddress() string

func (*RedisServiceOpen) GetClient

func (r *RedisServiceOpen) GetClient() *redis.Client

func (*RedisServiceOpen) GetConfig

func (r *RedisServiceOpen) GetConfig() interface{}

func (*RedisServiceOpen) Name

func (r *RedisServiceOpen) Name() string

func (*RedisServiceOpen) Update

func (r *RedisServiceOpen) Update(cs *source.ChangeSet)

func (*RedisServiceOpen) Watch

func (r *RedisServiceOpen) Watch(name string) chan bool