redis

Documentation

Index

• func AddSyncRecord(sha string, status string, message string)
• func GetSyncRecords(query string) (map[string]SyncData, error)
• func PublishMessage() error
• func Subscribe() (*redis.PubSub, error)
• type SyncData

Functions

func AddSyncRecord

func AddSyncRecord(sha string, status string, message string)

Save sync record to Redis

func GetSyncRecords

func GetSyncRecords(query string) (map[string]SyncData, error)

Get sync record/records

func PublishMessage

func PublishMessage() error

Redis message publishing

func Subscribe

func Subscribe() (*redis.PubSub, error)

Redis channel subscription

Types

type SyncData

type SyncData struct {
	Sha     string `json:"sha"`
	Status  string `json:"status"`
	Message string `json:"message"`
}

Struct definition to set sync parameters to save in Redis