Documentation ¶
Index ¶
- func CheckLocalFileExistence(fileLocation string) bool
- func GetAllKeysFromCategory(cacheConn *redis.Client, category string) (keys []string, err error)
- func GetDataFromCache(cacheConn *redis.Client, key string) (value []byte, err error)
- func GetPackageDataFromCache(cacheConn *redis.Client, poolPrefix string) (string, []byte, error)
- func JoinData(chunks [][]byte) []byte
- func Md5sum(data []byte) string
- func NewCacheConnection(addr string, username string, password string, db int) *redis.Client
- func PutDataOnCache(cacheConn *redis.Client, key string, value []byte, expiration time.Duration) (err error)
- func PutPackageDataOnCache(cacheConn *redis.Client, fileName string, data []byte, splitLimit int, ...) (err error)
- func ReadFileFromDisk(fileLocation string) (data []byte, fileName string, err error)
- func RegisterNode(cacheConn *redis.Client, category string, nodeID string, value string, ...) (err error)
- func RemoveNode(cacheConn *redis.Client, category string, nodeID string) (err error)
- func SendKeepAlive(cacheConn *redis.Client, category string, nodeID string, value string, ttl int)
- func SplitData(data []byte, limit int) [][]byte
- func UnzipPackageBytesToDisk(data []byte, dest string) ([]string, error)
- func WriteFileToDisk(fileLocation string, data []byte) (err error)
- type PackageMetaData
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckLocalFileExistence ¶
func GetAllKeysFromCategory ¶
func GetDataFromCache ¶
func GetPackageDataFromCache ¶
func NewCacheConnection ¶
func PutDataOnCache ¶
func PutPackageDataOnCache ¶
func ReadFileFromDisk ¶
func RegisterNode ¶
func RemoveNode ¶
func SendKeepAlive ¶
func UnzipPackageBytesToDisk ¶
func WriteFileToDisk ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.