mirror

Documentation

Index

• func AddPullMirrorToQueue(repoID int64)
• func AddPushMirrorRemote(ctx context.Context, m *repo_model.PushMirror, addr string) error
• func AddPushMirrorToQueue(mirrorID int64)
• func InitSyncMirrors()
• func PushToQueue(mirrorType SyncType, referenceID int64) error
• func RemovePushMirrorRemote(ctx context.Context, m *repo_model.PushMirror) error
• func StartSyncMirrors(queueHandle func(data ...*SyncRequest) []*SyncRequest)
• func SyncPullMirror(ctx context.Context, repoID int64) bool
• func SyncPushMirror(ctx context.Context, mirrorID int64) bool
• func Update(ctx context.Context, pullLimit, pushLimit int) error
• func UpdateAddress(ctx context.Context, m *repo_model.Mirror, addr string) error
• type SyncRequest
• type SyncType

Functions

func AddPullMirrorToQueue

func AddPullMirrorToQueue(repoID int64)

AddPullMirrorToQueue adds repoID to mirror queue

func AddPushMirrorRemote

func AddPushMirrorRemote(ctx context.Context, m *repo_model.PushMirror, addr string) error

AddPushMirrorRemote registers the push mirror remote.

func AddPushMirrorToQueue

func AddPushMirrorToQueue(mirrorID int64)

AddPushMirrorToQueue adds the push mirror to the queue

func InitSyncMirrors

func InitSyncMirrors()

InitSyncMirrors initializes a go routine to sync the mirrors

func PushToQueue

func PushToQueue(mirrorType SyncType, referenceID int64) error

PushToQueue adds the sync request to the queue

func RemovePushMirrorRemote

func RemovePushMirrorRemote(ctx context.Context, m *repo_model.PushMirror) error

RemovePushMirrorRemote removes the push mirror remote.

func StartSyncMirrors

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

StartSyncMirrors starts a go routine to sync the mirrors

func SyncPullMirror

func SyncPullMirror(ctx context.Context, repoID int64) bool

SyncPullMirror starts the sync of the pull mirror and schedules the next run.

func SyncPushMirror

func SyncPushMirror(ctx context.Context, mirrorID int64) bool

SyncPushMirror starts the sync of the push mirror and schedules the next run.

func Update

func Update(ctx context.Context, pullLimit, pushLimit int) error

Update checks and updates mirror repositories.

func UpdateAddress

func UpdateAddress(ctx context.Context, m *repo_model.Mirror, addr string) error

UpdateAddress writes new address to Git repository and database

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
)