byterange

Documentation

Index

• type JobQueue
  • func (q *JobQueue) Len() int
  • func (q *JobQueue) Less(i, j int) bool
  • func (q *JobQueue) Pop() (*job, bool)
  • func (q *JobQueue) Push(item *job)
  • func (q *JobQueue) PushFront(item *job)
  • func (q *JobQueue) Swap(i, j int)
• type Range
  • func New(service *titan.Service, size int64) *Range
  • func (r *Range) GetFile(ctx context.Context, cid cid.Cid) (int64, io.ReadCloser, error)

Types

type JobQueue

type JobQueue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*JobQueue) Len

func (q *JobQueue) Len() int

func (*JobQueue) Less

func (q *JobQueue) Less(i, j int) bool

func (*JobQueue) Pop

func (q *JobQueue) Pop() (*job, bool)

func (*JobQueue) Push

func (q *JobQueue) Push(item *job)

func (*JobQueue) PushFront

func (q *JobQueue) PushFront(item *job)

func (*JobQueue) Swap

func (q *JobQueue) Swap(i, j int)

type Range

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

func New

func New(service *titan.Service, size int64) *Range

func (*Range) GetFile

func (r *Range) GetFile(ctx context.Context, cid cid.Cid) (int64, io.ReadCloser, error)