storage

Documentation

Index

• Variables
• type ConsulWrapper
  • func GetConsulWrapper() ConsulWrapper
  • func (c *ConsulWrapper) Delete(key string) error
  • func (c *ConsulWrapper) Get(key string) *consul.KVPair
  • func (c *ConsulWrapper) GetInt(key string) int
  • func (c *ConsulWrapper) GetString(key string) string
  • func (c *ConsulWrapper) GetUniqId() int
  • func (c *ConsulWrapper) Set(key string, value string)
• type XdsConfigDao
  • func GetXdsConfigDao() *XdsConfigDao
  • func (dao *XdsConfigDao) GetConfigJson(sub *model.EnvoySubscriber) (string, string)
  • func (dao *XdsConfigDao) GetLatestVersion(sub *model.EnvoySubscriber) string
  • func (dao *XdsConfigDao) IsACK(sub *model.EnvoySubscriber, ack string) bool
  • func (dao *XdsConfigDao) IsListenerACK(sub *model.EnvoySubscriber, ack string) bool
  • func (dao *XdsConfigDao) IsRepoPresent(sub *model.EnvoySubscriber) bool
  • func (dao *XdsConfigDao) RegisterSubscriber(sub *model.EnvoySubscriber)
  • func (dao *XdsConfigDao) RemoveListenerNonce(sub *model.EnvoySubscriber, nonce string)
  • func (dao *XdsConfigDao) RemoveNonce(sub *model.EnvoySubscriber, nonce string)
  • func (dao *XdsConfigDao) SaveNonce(sub *model.EnvoySubscriber, nonce string)
  • func (dao *XdsConfigDao) UpdateEnvoySubscriber(sub *model.EnvoySubscriber)

Variables

var CONSUL_PATH string

Types

type ConsulWrapper

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

func GetConsulWrapper

func GetConsulWrapper() ConsulWrapper

func (*ConsulWrapper) Delete

func (c *ConsulWrapper) Delete(key string) error

func (*ConsulWrapper) Get

func (c *ConsulWrapper) Get(key string) *consul.KVPair

func (*ConsulWrapper) GetInt

func (c *ConsulWrapper) GetInt(key string) int

func (*ConsulWrapper) GetString

func (c *ConsulWrapper) GetString(key string) string

func (*ConsulWrapper) GetUniqId

func (c *ConsulWrapper) GetUniqId() int

TODO add retry

func (*ConsulWrapper) Set

func (c *ConsulWrapper) Set(key string, value string)

type XdsConfigDao

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

func GetXdsConfigDao

func GetXdsConfigDao() *XdsConfigDao

func (*XdsConfigDao) GetConfigJson

func (dao *XdsConfigDao) GetConfigJson(sub *model.EnvoySubscriber) (string, string)

func (*XdsConfigDao) GetLatestVersion

func (dao *XdsConfigDao) GetLatestVersion(sub *model.EnvoySubscriber) string

func (*XdsConfigDao) IsACK

func (dao *XdsConfigDao) IsACK(sub *model.EnvoySubscriber, ack string) bool

func (*XdsConfigDao) IsListenerACK

func (dao *XdsConfigDao) IsListenerACK(sub *model.EnvoySubscriber, ack string) bool

func (*XdsConfigDao) IsRepoPresent

func (dao *XdsConfigDao) IsRepoPresent(sub *model.EnvoySubscriber) bool

func (*XdsConfigDao) RegisterSubscriber

func (dao *XdsConfigDao) RegisterSubscriber(sub *model.EnvoySubscriber)

func (*XdsConfigDao) RemoveListenerNonce

func (dao *XdsConfigDao) RemoveListenerNonce(sub *model.EnvoySubscriber, nonce string)

func (*XdsConfigDao) RemoveNonce

func (dao *XdsConfigDao) RemoveNonce(sub *model.EnvoySubscriber, nonce string)

func (*XdsConfigDao) SaveNonce

func (dao *XdsConfigDao) SaveNonce(sub *model.EnvoySubscriber, nonce string)

func (*XdsConfigDao) UpdateEnvoySubscriber

func (dao *XdsConfigDao) UpdateEnvoySubscriber(sub *model.EnvoySubscriber)