groupreq

Documentation

Index

• func NewSubRequest(ctx context.Context, forceNew bool) *pargraphsync.SubRequest
• type GroupRequest
  • func NewGroupRequest(ctx context.Context) *GroupRequest
  • func (gr *GroupRequest) Add(subReq *pargraphsync.SubRequest)
  • func (gr *GroupRequest) Delete(subReqId graphsync.RequestID)
  • func (gr *GroupRequest) Get(subReqId graphsync.RequestID) *pargraphsync.SubRequest
  • func (gr *GroupRequest) GetContext() context.Context
  • func (gr *GroupRequest) GetGroupRequestID() graphsync.RequestID
  • func (gr *GroupRequest) Has(subReqId graphsync.RequestID) bool
  • func (gr *GroupRequest) RangeSubRequests(f func(subReqId graphsync.RequestID, subReq *pargraphsync.SubRequest) bool)
• type GroupRequestManager
  • func NewGroupRequestManager() *GroupRequestManager
  • func (grm *GroupRequestManager) Add(groupReq *GroupRequest)
  • func (grm *GroupRequestManager) Delete(groupReqId graphsync.RequestID) *GroupRequest
  • func (grm *GroupRequestManager) Get(groupReqId graphsync.RequestID) *GroupRequest
  • func (grm *GroupRequestManager) GetBySubRequestId(subReqId graphsync.RequestID) *GroupRequest
  • func (grm *GroupRequestManager) GetOrAdd(groupReq *GroupRequest) (gr *GroupRequest, loaded bool)
  • func (grm *GroupRequestManager) Has(groupReqId graphsync.RequestID) bool

Functions

func NewSubRequest

func NewSubRequest(ctx context.Context, forceNew bool) *pargraphsync.SubRequest

Types

type GroupRequest

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

func NewGroupRequest

func NewGroupRequest(ctx context.Context) *GroupRequest

func (*GroupRequest) Add

func (gr *GroupRequest) Add(subReq *pargraphsync.SubRequest)

func (*GroupRequest) Delete

func (gr *GroupRequest) Delete(subReqId graphsync.RequestID)

func (*GroupRequest) Get

func (gr *GroupRequest) Get(subReqId graphsync.RequestID) *pargraphsync.SubRequest

func (*GroupRequest) GetContext

func (gr *GroupRequest) GetContext() context.Context

func (*GroupRequest) GetGroupRequestID

func (gr *GroupRequest) GetGroupRequestID() graphsync.RequestID

func (*GroupRequest) Has

func (gr *GroupRequest) Has(subReqId graphsync.RequestID) bool

func (*GroupRequest) RangeSubRequests

func (gr *GroupRequest) RangeSubRequests(f func(subReqId graphsync.RequestID, subReq *pargraphsync.SubRequest) bool)

type GroupRequestManager

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

func NewGroupRequestManager

func NewGroupRequestManager() *GroupRequestManager

func (*GroupRequestManager) Add

func (grm *GroupRequestManager) Add(groupReq *GroupRequest)

func (*GroupRequestManager) Delete

func (grm *GroupRequestManager) Delete(groupReqId graphsync.RequestID) *GroupRequest

func (*GroupRequestManager) Get

func (grm *GroupRequestManager) Get(groupReqId graphsync.RequestID) *GroupRequest

func (*GroupRequestManager) GetBySubRequestId

func (grm *GroupRequestManager) GetBySubRequestId(subReqId graphsync.RequestID) *GroupRequest

func (*GroupRequestManager) GetOrAdd

func (grm *GroupRequestManager) GetOrAdd(groupReq *GroupRequest) (gr *GroupRequest, loaded bool)

func (*GroupRequestManager) Has

func (grm *GroupRequestManager) Has(groupReqId graphsync.RequestID) bool