planning

type Board struct {
	Possible []*TransportRequest
	Pending  []*TransportRequest
	Failed   []*TransportRequest
	Complete []*TransportRequest
	// contains filtered or unexported fields
}

type FilecoinV1RecordInterpreter struct {
}

type Policy interface {
	Name() PolicyName
}

type PolicyName string

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

type PolicyResults interface {
	// must be in range from zero to 1, will get dropped otherwise
	// should return zero for policies that are unrecognized
	Score(PolicyName) PolicyScore
}

type PolicyScore float64

type PolicyWeight float64

type PotentialRequest struct {
	PolicyScore
	contentrouting.RoutingRecord
}

type RoutingRecordInterpreter interface {
	Interpret(record contentrouting.RoutingRecord, policies []Policy) (PolicyResults, error)
}

type Scheduler interface {
	// plan the fetch of a root+selector of data given a set of learned routing records.
	Schedule(ctx context.Context, root cid.Cid, selector ipld.Node, potentialTransports <-chan contentrouting.RoutingRecord) <-chan TransportPlan
	// Indicate that a transfer in the schedule has started
	Begin(r *TransportRequest)
	// Indicate that a transfer in the schedule has completed
	Reconcile(r *TransportRequest, success bool)
}

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

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

type SinglePlanner interface {
	GeneratePlan(ctx context.Context, targetRoot cid.Cid, targetSelector ipld.Node, potentialRequests <-chan PotentialRequest) <-chan TransportPlan
}

type TransportPlan struct {
	TransportRequests []*TransportRequest
	Error             error
}

type TransportRequest struct {
	Codec           multicodec.Code
	Root            ipld.Link
	Selector        ipld.Node
	RoutingProvider interface{}
	RoutingPayload  interface{}
}