werf/trdl

package repo

import (
    "github.com/werf/lockgate"
    "github.com/werf/trdl/client/pkg/trdl"
)

func (c Client) GetChannelReleaseDir(group, channel string) (dir string, err error) {
    err = lockgate.WithAcquire(c.locker, c.channelLockName(group, channel), lockgate.AcquireOptions{Shared: true, Timeout: trdl.DefaultLockerTimeout}, func(_ bool) error {
        dir, _, err = c.findChannelReleaseDir(group, channel)
        return err
    })

    return
}