mirror

Documentation

Index

• func AddPullMirrorToQueue(repoID int64)
• func AddPushMirrorToQueue(mirrorID int64)
• func PushToQueue(mirrorType SyncType, referenceID int64) error
• func StartSyncMirrors(queueHandle func(data ...*SyncRequest) []*SyncRequest)
• type SyncRequest
• type SyncType

Functions

func AddPullMirrorToQueue

func AddPullMirrorToQueue(repoID int64)

AddPullMirrorToQueue adds repoID to mirror queue

func AddPushMirrorToQueue

func AddPushMirrorToQueue(mirrorID int64)

AddPushMirrorToQueue adds the push mirror to the queue

func PushToQueue

func PushToQueue(mirrorType SyncType, referenceID int64) error

PushToQueue adds the sync request to the queue

func StartSyncMirrors

func StartSyncMirrors(queueHandle func(data ...*SyncRequest) []*SyncRequest)

StartSyncMirrors starts a go routine to sync the mirrors

Types

type SyncRequest

type SyncRequest struct {
	Type        SyncType
	ReferenceID int64 // RepoID for pull mirror, MirrorID for push mirror
}

SyncRequest for the mirror queue

type SyncType

type SyncType int

SyncType type of sync request

const (
	// PullMirrorType for pull mirrors
	PullMirrorType SyncType = iota
	// PushMirrorType for push mirrors
	PushMirrorType
)