apiutils

Documentation

Index

• type ClosedSetsFinder
  • func NewClosedSetsFinder(db objects.Store, rs ref.Store, depth int) *ClosedSetsFinder
  • func (f *ClosedSetsFinder) CommitsToSend() (commits []*objects.Commit)
  • 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{})
• type ObjectReceiver
  • func NewObjectReceiver(db objects.Store, expectedCommits [][]byte, debugOut io.Writer) *ObjectReceiver
  • func (r *ObjectReceiver) Receive(pr *packfile.PackfileReader, pbar *progressbar.ProgressBar) (done bool, err error)
• type ObjectSender
  • func NewObjectSender(db objects.Store, toSend []*objects.Commit, tablesToSend map[string]struct{}, ...) (s *ObjectSender, err error)
  • func (s *ObjectSender) WriteObjects(w io.Writer, pbar *progressbar.ProgressBar) (done bool, err error)
• type UnrecognizedWantsError
  • func (err *UnrecognizedWantsError) Error() string

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 NewClosedSetsFinder(db objects.Store, rs ref.Store, depth int) *ClosedSetsFinder

func (*ClosedSetsFinder) CommitsToSend

func (f *ClosedSetsFinder) CommitsToSend() (commits []*objects.Commit)

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

func (f *ClosedSetsFinder) TablesToSend() (tableSums map[string]struct{})

type ObjectReceiver

type ObjectReceiver struct {
	ReceivedCommits [][]byte
	// contains filtered or unexported fields
}

func NewObjectReceiver

func NewObjectReceiver(db objects.Store, expectedCommits [][]byte, debugOut io.Writer) *ObjectReceiver

func (*ObjectReceiver) Receive

func (r *ObjectReceiver) Receive(pr *packfile.PackfileReader, pbar *progressbar.ProgressBar) (done bool, err error)

type ObjectSender

type ObjectSender struct {
	// contains filtered or unexported fields
}

func NewObjectSender

func NewObjectSender(db objects.Store, toSend []*objects.Commit, tablesToSend map[string]struct{}, commonCommits [][]byte, maxPackfileSize uint64) (s *ObjectSender, err error)

func (*ObjectSender) WriteObjects

func (s *ObjectSender) WriteObjects(w io.Writer, pbar *progressbar.ProgressBar) (done bool, err error)

type UnrecognizedWantsError

type UnrecognizedWantsError struct {
	// contains filtered or unexported fields
}

func (*UnrecognizedWantsError) Error

func (err *UnrecognizedWantsError) Error() string