apiutils

Documentation

Index

• type ClosedSetsFinder
  • func NewClosedSetsFinder(db objects.Store, rs ref.Store, depth int) *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
  • func WithReceiverSaveObjectHook(hook func(objType int, sum []byte)) ObjectReceiveOption
• type ObjectReceiver
  • func NewObjectReceiver(db objects.Store, expectedCommits [][]byte, logger logr.Logger, ...) *ObjectReceiver
  • func (r *ObjectReceiver) Receive(pr *packfile.PackfileReader, bar pbar.Bar) (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, pb pbar.Bar) (done bool, info *packfile.PackfileInfo, 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, 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

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

type ObjectReceiveOption

type ObjectReceiveOption func(r *ObjectReceiver)

func WithReceiverSaveObjectHook

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 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, 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