Documentation
¶
Index ¶
- type ClosedSetsFinder
- func (f *ClosedSetsFinder) CommitsToSend() (commits []*objects.Commit, err error)
- func (f *ClosedSetsFinder) CommonCommmits() [][]byte
- func (f *ClosedSetsFinder) Process(wants, haves [][]byte, done bool) (acks [][]byte, err error)
- func (f *ClosedSetsFinder) TablesToSend() (tableSums map[string]struct{}, err error)
- type ObjectReceiveOption
- type ObjectReceiver
- type ObjectSender
- type UnrecognizedWantsError
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClosedSetsFinder ¶
type ClosedSetsFinder struct {
Wants map[string]struct{}
// contains filtered or unexported fields
}
ClosedSetsFinder finds closed sets of commits to send. A set of commits is closed if all ancestors already exist in destination repository.
func NewClosedSetsFinder ¶
func (*ClosedSetsFinder) CommitsToSend ¶
func (f *ClosedSetsFinder) CommitsToSend() (commits []*objects.Commit, err error)
func (*ClosedSetsFinder) CommonCommmits ¶
func (f *ClosedSetsFinder) CommonCommmits() [][]byte
func (*ClosedSetsFinder) Process ¶
func (f *ClosedSetsFinder) Process(wants, haves [][]byte, done bool) (acks [][]byte, err error)
func (*ClosedSetsFinder) TablesToSend ¶ added in v0.8.4
func (f *ClosedSetsFinder) TablesToSend() (tableSums map[string]struct{}, err error)
type ObjectReceiveOption ¶ added in v0.11.0
type ObjectReceiveOption func(r *ObjectReceiver)
func WithReceiverSaveObjectHook ¶ added in v0.11.0
func WithReceiverSaveObjectHook(hook func(objType int, sum []byte)) ObjectReceiveOption
WithReceiverSaveObjectHook registers a hook that run right after an object is persisted successfully
type ObjectReceiver ¶
type ObjectReceiver struct {
ReceivedCommits [][]byte
// contains filtered or unexported fields
}
func NewObjectReceiver ¶
func NewObjectReceiver(db objects.Store, expectedCommits [][]byte, logger logr.Logger, opts ...ObjectReceiveOption) *ObjectReceiver
func (*ObjectReceiver) Receive ¶
func (r *ObjectReceiver) Receive(pr *packfile.PackfileReader, bar pbar.Bar) (done bool, err error)
type ObjectSender ¶
type ObjectSender struct {
// contains filtered or unexported fields
}
func NewObjectSender ¶
func (*ObjectSender) WriteObjects ¶
func (s *ObjectSender) WriteObjects(w io.Writer, pb pbar.Bar) (done bool, info *packfile.PackfileInfo, err error)
type UnrecognizedWantsError ¶
type UnrecognizedWantsError struct {
// contains filtered or unexported fields
}
func (*UnrecognizedWantsError) Error ¶
func (err *UnrecognizedWantsError) Error() string
Source Files
Click to show internal directories.
Click to hide internal directories.