mirror

Documentation

Index

• func AddPushMirrorRemote(m *repo_model.PushMirror, addr string) error
• func AddPushMirrorToQueue(mirrorID int64)
• func InitSyncMirrors()
• func RemovePushMirrorRemote(m *repo_model.PushMirror) error
• func StartToMirror(repoID int64)
• 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(m *repo_model.Mirror, addr string) error
• type SyncRequest
• type SyncType

Functions

func AddPushMirrorRemote

func AddPushMirrorRemote(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 RemovePushMirrorRemote

func RemovePushMirrorRemote(m *repo_model.PushMirror) error

RemovePushMirrorRemote removes the push mirror remote.

func StartToMirror

func StartToMirror(repoID int64)

StartToMirror adds repoID to mirror queue

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(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 fro 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
)