cluster

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

type MutexConfig struct {
	// TTL is the interval after which a locked mutex will expire unless
	// refreshed.
	TTL time.Duration
	// RefreshInterval is the interval on which the mutex will be refreshed when
	// locked.
	RefreshInterval time.Duration
	// PollInterval is the interval to wait between locking attempts.
	PollInterval time.Duration
	// MetricsGroup is an optional group name to use for mutex related metrics.
	MetricsGroup string
}

type MutexMetricsAPI interface {
	ObserveClusterMutexGrabTime(key string, elapsed float64)
	ObserveClusterMutexLockedTime(key string, elapsed float64)
	IncClusterMutexLockRetries(group string)
}

type MutexPluginAPI interface {
	KVSetWithOptions(key string, value []byte, options model.PluginKVSetOptions) (bool, *model.AppError)
	KVDelete(key string) *model.AppError
	LogError(msg string, keyValuePairs ...interface{})
	LogWarn(msg string, keyValuePairs ...interface{})
	LogDebug(msg string, keyValuePairs ...interface{})
}