Versions in this module Expand all Collapse all v0 v0.6.3 May 13, 2026 v0.6.2 May 12, 2026 v0.6.1 May 12, 2026 v0.6.0 May 5, 2026 v0.5.0 May 4, 2026 v0.4.6-rc3 Apr 30, 2026 v0.4.6-rc1 Apr 30, 2026 v0.4.5 Apr 30, 2026 v0.4.4 Apr 27, 2026 v0.4.3 Apr 26, 2026 v0.4.2 Apr 26, 2026 v0.4.1 Apr 26, 2026 v0.4.0 Apr 25, 2026 v0.3.0 Apr 21, 2026 v0.2.0 Apr 21, 2026 v0.1.0 Apr 19, 2026 Changes in this version + const DefaultCkinLockTimeout + const DefaultCloneBatchSize + const DefaultMaxSend + const MaxGimmeBase + const MaxRounds + var ErrDeltaSourceMissing = errors.New("delta source not found") + func HandleSync(ctx context.Context, r *repo.Repo, req *xfer.Message) (*xfer.Message, error) + func HandleSyncWithOpts(ctx context.Context, r *repo.Repo, req *xfer.Message, opts HandleOpts) (*xfer.Message, error) + func ServeHTTP(ctx context.Context, addr string, r *repo.Repo, h HandleFunc) error + func XferHandler(r *repo.Repo, h HandleFunc) http.HandlerFunc + type BuggifyChecker interface + Check func(site string, probability float64) bool + type CkinLockFail struct + HeldBy string + Since time.Time + type CkinLockReq struct + ClientID string + ParentUUID string + type CloneOpts struct + Buggify BuggifyChecker + Env *simio.Env + Observer Observer + Password string + User string + Version int + type CloneResult struct + ArtifactsLinked int + BlobsRecvd int + Messages []string + ProjectCode string + Rounds int + ServerCode string + func Clone(ctx context.Context, path string, t Transport, opts CloneOpts) (r *repo.Repo, result *CloneResult, err error) + type HTTPTransport struct + URL string + func (t *HTTPTransport) Exchange(ctx context.Context, req *xfer.Message) (*xfer.Message, error) + type HandleEnd struct + CardsProcessed int + Err error + FilesReceived int + FilesSent int + type HandleFunc func(ctx context.Context, r *repo.Repo, req *xfer.Message) (*xfer.Message, error) + type HandleOpts struct + Buggify BuggifyChecker + ContentCache *content.Cache + Observer Observer + type HandleStart struct + Operation string + ProjectCode string + RemoteAddr string + type MockTransport struct + Handler func(req *xfer.Message) *xfer.Message + func (t *MockTransport) Exchange(ctx context.Context, req *xfer.Message) (*xfer.Message, error) + type Observer interface + Completed func(ctx context.Context, info SessionEnd, err error) + Error func(ctx context.Context, err error) + HandleCompleted func(ctx context.Context, info HandleEnd) + HandleStarted func(ctx context.Context, info HandleStart) context.Context + RoundCompleted func(ctx context.Context, round int, stats RoundStats) + RoundStarted func(ctx context.Context, round int) context.Context + Started func(ctx context.Context, info SessionStart) context.Context + TableSyncCompleted func(ctx context.Context, info TableSyncEnd) + TableSyncStarted func(ctx context.Context, info TableSyncStart) + type RoundStats struct + BytesReceived int64 + BytesSent int64 + FilesReceived int + FilesSent int + GimmesSent int + IgotsSent int + type SessionEnd struct + BytesRecvd int64 + BytesSent int64 + Errors []string + FilesRecvd int + FilesSent int + Operation string + ProjectCode string + Rounds int + UVFilesRecvd int + UVFilesSent int + UVGimmesSent int + type SessionStart struct + Operation string + PeerID string + ProjectCode string + Pull bool + Push bool + UV bool + type SyncOpts struct + Buggify BuggifyChecker + CkinLock *CkinLockReq + ContentCache *content.Cache + Env *simio.Env + MaxSend int + Observer Observer + Password string + PeerID string + Private bool + ProjectCode string + Pull bool + Push bool + ServerCode string + UV bool + User string + XTableSync bool + type SyncResult struct + ArtifactsLinked int + BytesRecvd int64 + BytesSent int64 + CkinLockFail *CkinLockFail + Errors []string + FilesRecvd int + FilesSent int + Rounds int + UVFilesRecvd int + UVFilesSent int + UVGimmesSent int + func Sync(ctx context.Context, r *repo.Repo, t Transport, opts SyncOpts) (result *SyncResult, err error) + type SyncedTable struct + Def repo.TableDef + Info repo.TableInfo + type TableSyncEnd struct + Received int + Sent int + Table string + type TableSyncStart struct + LocalRows int + Table string + type Transport interface + Exchange func(ctx context.Context, request *xfer.Message) (*xfer.Message, error)
Go to main page