storage

Documentation

Index

• Variables
• func GetFileConfigVersion() string
• func GetSequenceKey() string
• type ConsulConfigDao
  • 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 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 FileConfigDao
  • 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 SubscriberDao
  • 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 GetXdsConfigDao() XdsConfigDao

Variables

var CONSUL_PATH string

Functions

func GetFileConfigVersion

func GetFileConfigVersion() string

func GetSequenceKey

func GetSequenceKey() string

Types

type ConsulConfigDao

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

func GetConsulConfigDao

func GetConsulConfigDao() *ConsulConfigDao

func (*ConsulConfigDao) GetConfigJson

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

func (*ConsulConfigDao) GetLatestVersion

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

func (*ConsulConfigDao) GetLatestVersionFor

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

func (*ConsulConfigDao) IsRepoPresent

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

func (*ConsulConfigDao) IsRepoPresentFor

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

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 FileConfigDao

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

func GetFileConfigDao

func GetFileConfigDao() *FileConfigDao

func (*FileConfigDao) GetConfigJson

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

func (*FileConfigDao) GetLatestVersion

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

func (*FileConfigDao) GetLatestVersionFor

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

func (*FileConfigDao) IsRepoPresent

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

func (*FileConfigDao) IsRepoPresentFor

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

type SubscriberDao

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

func GetSubscriberDao

func GetSubscriberDao() *SubscriberDao

func (*SubscriberDao) DeleteSubscriber

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

func (*SubscriberDao) IsACK

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

func (*SubscriberDao) RegisterSubscriber

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

func (*SubscriberDao) RemoveNonce

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

func (*SubscriberDao) SaveNonce

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

type XdsConfigDao

type XdsConfigDao interface {
	GetLatestVersion(sub *model.EnvoySubscriber) string
	GetLatestVersionFor(subscriberKey string) string
	IsRepoPresent(sub *model.EnvoySubscriber) bool
	IsRepoPresentFor(subscriberKey string) bool
	GetConfigJson(sub *model.EnvoySubscriber) (string, string)
}

func GetXdsConfigDao

func GetXdsConfigDao() XdsConfigDao