Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

storage

package

Go to main page

Versions in this module

v0

v0.2.4

Oct 31, 2018

v0.2.3

Oct 16, 2018

v0.2.2

Oct 16, 2018

Changes in this version

+ func GetFileConfigVersion() string

+ type ConsulConfigDao struct

+ func GetConsulConfigDao() *ConsulConfigDao

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

+ func (dao *ConsulConfigDao) GetLatestVersion(sub *model.EnvoySubscriber) string

+ func (dao *ConsulConfigDao) GetLatestVersionFor(subscriberKey string) string

+ func (dao *ConsulConfigDao) IsRepoPresent(sub *model.EnvoySubscriber) bool

+ func (dao *ConsulConfigDao) IsRepoPresentFor(subscriberKey string) bool

+ type FileConfigDao struct

+ func GetFileConfigDao() *FileConfigDao

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

+ func (dao *FileConfigDao) GetLatestVersion(sub *model.EnvoySubscriber) string

+ func (dao *FileConfigDao) GetLatestVersionFor(subscriberKey string) string

+ func (dao *FileConfigDao) IsRepoPresent(sub *model.EnvoySubscriber) bool

+ func (dao *FileConfigDao) IsRepoPresentFor(subscriberKey string) bool

type XdsConfigDao

+ IsRepoPresentFor func(subscriberKey string) bool

v0.2.0

Oct 12, 2018

Changes in this version

+ type SubscriberDao struct

+ func GetSubscriberDao() *SubscriberDao

+ func (dao *SubscriberDao) DeleteSubscriber(sub *model.EnvoySubscriber)

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

+ func (dao *SubscriberDao) RegisterSubscriber(sub *model.EnvoySubscriber)

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

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

type XdsConfigDao

+ func (dao *XdsConfigDao) GetLatestVersionFor(subscriberKey string) string

v0.1.7

Aug 28, 2018

Changes in this version

+ func GetSequenceKey() string

v0.1.6

Aug 25, 2018

v0.1.5

Aug 22, 2018

Changes in this version

+ var CONSUL_PATH string

+ type ConsulWrapper struct

+ 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 struct

+ 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)