allocator

Documentation

Index

• type Allocator
  • func NewAllocator(maxAllowedAllocatedTotal uint64, maxAllowedAllocatedPerPeer uint64) *Allocator
  • func (a *Allocator) AllocateBlockMemory(p peer.ID, amount uint64) <-chan error
  • func (a *Allocator) AllocatedForPeer(p peer.ID) uint64
  • func (a *Allocator) ReleaseBlockMemory(p peer.ID, amount uint64) error
  • func (a *Allocator) ReleasePeerMemory(p peer.ID) error
  • func (a *Allocator) Stats() graphsync.ResponseStats

Types

type Allocator

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

func NewAllocator

func NewAllocator(maxAllowedAllocatedTotal uint64, maxAllowedAllocatedPerPeer uint64) *Allocator

func (*Allocator) AllocateBlockMemory

func (a *Allocator) AllocateBlockMemory(p peer.ID, amount uint64) <-chan error

func (*Allocator) AllocatedForPeer

func (a *Allocator) AllocatedForPeer(p peer.ID) uint64

func (*Allocator) ReleaseBlockMemory

func (a *Allocator) ReleaseBlockMemory(p peer.ID, amount uint64) error

func (*Allocator) ReleasePeerMemory

func (a *Allocator) ReleasePeerMemory(p peer.ID) error

func (*Allocator) Stats

func (a *Allocator) Stats() graphsync.ResponseStats