common

Documentation

Index

• Constants
• func ServiceEventKeyToFileName(svcKey model.ServiceEventKey) string
• type CacheFileInfo
• type CachePersistHandler
  • func NewCachePersistHandler(persistDir string, maxWriteRetry int, maxReadRetry int, ...) (*CachePersistHandler, error)
  • func (cph *CachePersistHandler) DeleteCacheFromFile(fileName string)
  • func (cph *CachePersistHandler) LoadMessageFromFile(relativeFile string, message proto.Message) error
  • func (cph *CachePersistHandler) LoadPersistedServices() map[model.ServiceEventKey]CacheFileInfo
  • func (cph *CachePersistHandler) SaveMessageToFile(fileName string, svcResp proto.Message)

Constants

const (
	PatternService = "svc#%s#%s#%s"
	CacheSuffix    = ".json"
	PatternGlob    = "svc#?*#?*#?*"
)

Functions

func ServiceEventKeyToFileName

func ServiceEventKeyToFileName(svcKey model.ServiceEventKey) string

服务名转化为文件名

Types

type CacheFileInfo

type CacheFileInfo struct {
	Msg      proto.Message
	FileInfo os.FileInfo
}

type CachePersistHandler

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

持久化工具类

func NewCachePersistHandler

func NewCachePersistHandler(persistDir string, maxWriteRetry int,
	maxReadRetry int, retryInterval time.Duration) (*CachePersistHandler, error)

创建持久化处理器

func (*CachePersistHandler) DeleteCacheFromFile

func (cph *CachePersistHandler) DeleteCacheFromFile(fileName string)

删除缓存文件

func (*CachePersistHandler) LoadMessageFromFile

func (cph *CachePersistHandler) LoadMessageFromFile(relativeFile string, message proto.Message) error

从相对文件中加载缓存

func (*CachePersistHandler) LoadPersistedServices

func (cph *CachePersistHandler) LoadPersistedServices() map[model.ServiceEventKey]CacheFileInfo

加载目录中所有的缓存文件

func (*CachePersistHandler) SaveMessageToFile

func (cph *CachePersistHandler) SaveMessageToFile(fileName string, svcResp proto.Message)

按服务来进行缓存存储