storage

package

v0.2.0 Latest Latest Go to latest Published: Oct 12, 2018 License: MIT Imports: 12 Imported by: 0

Documentation ¶

This section is empty.

View Source

var CONSUL_PATH string

func GetSequenceKey() string

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

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

TODO add retry

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

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

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 struct {
	// contains filtered or unexported fields
}

func GetXdsConfigDao() *XdsConfigDao

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

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

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

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