Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlockSentListeners ¶
type BlockSentListeners struct {
// contains filtered or unexported fields
}
BlockSentListeners is a set of listeners for when requestors cancel
func NewBlockSentListeners ¶
func NewBlockSentListeners() *BlockSentListeners
NewBlockSentListeners returns a new list of listeners for when requestors cancel
func (*BlockSentListeners) NotifyBlockSentListeners ¶
func (bsl *BlockSentListeners) NotifyBlockSentListeners(p peer.ID, request graphsync.RequestData, block graphsync.BlockData)
NotifyBlockSentListeners notifies all listeners that a requestor cancelled a response
func (*BlockSentListeners) Register ¶
func (bsl *BlockSentListeners) Register(listener graphsync.OnBlockSentListener) graphsync.UnregisterHookFunc
Register registers an listener for completed responses
type CompletedResponseListeners ¶
type CompletedResponseListeners struct {
// contains filtered or unexported fields
}
CompletedResponseListeners is a set of listeners for completed responses
func NewCompletedResponseListeners ¶
func NewCompletedResponseListeners() *CompletedResponseListeners
NewCompletedResponseListeners returns a new list of completed response listeners
func (*CompletedResponseListeners) NotifyCompletedListeners ¶
func (crl *CompletedResponseListeners) NotifyCompletedListeners(p peer.ID, request graphsync.RequestData, status graphsync.ResponseStatusCode)
NotifyCompletedListeners runs notifies all completed listeners that a response has completed
func (*CompletedResponseListeners) Register ¶
func (crl *CompletedResponseListeners) Register(listener graphsync.OnResponseCompletedListener) graphsync.UnregisterHookFunc
Register registers an listener for completed responses
type NetworkErrorListeners ¶
type NetworkErrorListeners struct {
// contains filtered or unexported fields
}
NetworkErrorListeners is a set of listeners for when requestors cancel
func NewNetworkErrorListeners ¶
func NewNetworkErrorListeners() *NetworkErrorListeners
NewNetworkErrorListeners returns a new list of listeners for when requestors cancel
func (*NetworkErrorListeners) NotifyNetworkErrorListeners ¶
func (nel *NetworkErrorListeners) NotifyNetworkErrorListeners(p peer.ID, request graphsync.RequestData, err error)
NotifyNetworkErrorListeners notifies all listeners that a requestor cancelled a response
func (*NetworkErrorListeners) Register ¶
func (nel *NetworkErrorListeners) Register(listener graphsync.OnNetworkErrorListener) graphsync.UnregisterHookFunc
Register registers an listener for completed responses
type NetworkReceiverErrorListeners ¶
type NetworkReceiverErrorListeners struct {
// contains filtered or unexported fields
}
NetworkReceiverErrorListeners is a set of listeners for network errors on the receiving side
func NewReceiverNetworkErrorListeners ¶
func NewReceiverNetworkErrorListeners() *NetworkReceiverErrorListeners
NewReceiverNetworkErrorListeners returns a new list of listeners for receiving errors
func (*NetworkReceiverErrorListeners) NotifyNetworkErrorListeners ¶
func (nel *NetworkReceiverErrorListeners) NotifyNetworkErrorListeners(p peer.ID, err error)
NotifyReceiverNetworkErrorListeners notifies all listeners that a receive connection failed
func (*NetworkReceiverErrorListeners) Register ¶
func (nel *NetworkReceiverErrorListeners) Register(listener graphsync.OnReceiverNetworkErrorListener) graphsync.UnregisterHookFunc
Register registers an listener for completed responses
type OutgoingRequestProcessingListeners ¶
type OutgoingRequestProcessingListeners struct {
// contains filtered or unexported fields
}
OutgoingRequestProcessingListeners is a set of listeners for when requests begin processing
func NewOutgoingRequestProcessingListeners ¶
func NewOutgoingRequestProcessingListeners() *OutgoingRequestProcessingListeners
NewOutgoingRequestProcessingListeners returns a new list of listeners for when requestors cancel
func (*OutgoingRequestProcessingListeners) NotifyOutgoingRequestProcessingListeners ¶
func (bsl *OutgoingRequestProcessingListeners) NotifyOutgoingRequestProcessingListeners(p peer.ID, request graphsync.RequestData, inProgressRequestCount int)
NotifyOutgoingRequestProcessingListeners notifies all listeners that a requestor cancelled a response
func (*OutgoingRequestProcessingListeners) Register ¶
func (bsl *OutgoingRequestProcessingListeners) Register(listener graphsync.OnOutgoingRequestProcessingListener) graphsync.UnregisterHookFunc
Register registers an listener for completed responses
type RequestorCancelledListeners ¶
type RequestorCancelledListeners struct {
// contains filtered or unexported fields
}
RequestorCancelledListeners is a set of listeners for when requestors cancel
func NewRequestorCancelledListeners ¶
func NewRequestorCancelledListeners() *RequestorCancelledListeners
NewRequestorCancelledListeners returns a new list of listeners for when requestors cancel
func (*RequestorCancelledListeners) NotifyCancelledListeners ¶
func (rcl *RequestorCancelledListeners) NotifyCancelledListeners(p peer.ID, request graphsync.RequestData)
NotifyCancelledListeners notifies all listeners that a requestor cancelled a response
func (*RequestorCancelledListeners) Register ¶
func (rcl *RequestorCancelledListeners) Register(listener graphsync.OnRequestorCancelledListener) graphsync.UnregisterHookFunc
Register registers an listener for completed responses
Source Files