data

Documentation

Index

• type Connection
  • func NewConnection(connectionString string) (*Connection, error)
• type Metadata
  • func NewMetadata(mutex Mutex, conn *Connection, database string) (Metadata, error)
• type Mutex
  • func NewMutex(client MutexClient) Mutex
• type MutexClient
  • func NewMutexClusterClient(addresses []string, password string) (MutexClient, error)
  • func NewMutexStandaloneClient(address string, password string) (MutexClient, error)

Types

type Connection

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

func NewConnection

func NewConnection(connectionString string) (*Connection, error)

type Metadata

type Metadata interface {
	Lock(folderPaths []string, folderHandler func(folders []*common.Folder) error) error
	LockTree(folderPath string, includeItself bool, reverseSort bool, folderHandler func(folders []*common.Folder) error) error
	Save(folderPaths []string, saveHandler func(folders map[string]*common.Folder) error) error
}

func NewMetadata

func NewMetadata(mutex Mutex, conn *Connection, database string) (Metadata, error)

type Mutex

type Mutex interface {
	Lock(string)
	UnLock(string)
	Wait(string)
}

func NewMutex

func NewMutex(client MutexClient) Mutex

type MutexClient

type MutexClient interface {
	Get(key string) *redis.StringCmd
	Set(key string, value interface{}, expiration time.Duration) *redis.StatusCmd
	Del(keys ...string) *redis.IntCmd
}

func NewMutexClusterClient

func NewMutexClusterClient(addresses []string, password string) (MutexClient, error)

func NewMutexStandaloneClient

func NewMutexStandaloneClient(address string, password string) (MutexClient, error)