util

Documentation

Index

• Constants
• func Apply(ctx context.Context, k8sClient client.Client, path string, ns string, ...) error
• func TorrentChunkNumber(torrent *api.Torrent) (number int)
• func UpdateNodeTracker(ctx context.Context, k8sClient client.Client, ntName string, chunkName string, ...) error
• func UpdateReplicationsCondition(ctx context.Context, k8sClient client.Client, torrent *api.Torrent, ...)

Constants

const (
	Timeout  = 10 * time.Second
	Interval = time.Millisecond * 250
)

Functions

func Apply

func Apply(ctx context.Context, k8sClient client.Client, path string, ns string, action string) error

func TorrentChunkNumber

func TorrentChunkNumber(torrent *api.Torrent) (number int)

func UpdateNodeTracker

func UpdateNodeTracker(ctx context.Context, k8sClient client.Client, ntName string, chunkName string, size int32) error

func UpdateReplicationsCondition

func UpdateReplicationsCondition(ctx context.Context, k8sClient client.Client, torrent *api.Torrent, conditionType string)