lock

type Lock interface {
	// Lock try  get a lock for given key
	Lock(ctx context.Context, key string) (observer LockResult, acquired bool)
	// Release remove lock for given key
	Release(ctx context.Context, key string)
	// NotifyAndRelease remove lock for given key and notify all clients waiting for result
	// SharedResponse allows sharing the same buffer across all waiting requests without copying
	NotifyAndRelease(ctx context.Context, key string, res *response.SharedResponse)
}

type LockResult struct {
	ResponseChan chan *response.Response // channel on which you get response
	Cancel       chan bool               // channel for notify about cancel of waiting
	Error        error                   // error when creating error
}

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

type NopLock struct {
}

type RedisLock struct {
	LockTimeout int
	// contains filtered or unexported fields
}