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 ¶ added in v0.6.0
type NetworkReceiverErrorListeners struct {
// contains filtered or unexported fields
}
NetworkReceiverErrorListeners is a set of listeners for network errors on the receiving side
func NewReceiverNetworkErrorListeners ¶ added in v0.6.0
func NewReceiverNetworkErrorListeners() *NetworkReceiverErrorListeners
NewReceiverNetworkErrorListeners returns a new list of listeners for receiving errors
func (*NetworkReceiverErrorListeners) NotifyNetworkErrorListeners ¶ added in v0.6.0
func (nel *NetworkReceiverErrorListeners) NotifyNetworkErrorListeners(p peer.ID, err error)
NotifyReceiverNetworkErrorListeners notifies all listeners that a receive connection failed
func (*NetworkReceiverErrorListeners) Register ¶ added in v0.6.0
func (nel *NetworkReceiverErrorListeners) Register(listener graphsync.OnReceiverNetworkErrorListener) graphsync.UnregisterHookFunc
Register registers an listener for completed responses
type RequestProcessingListeners ¶ added in v0.14.0
type RequestProcessingListeners struct {
// contains filtered or unexported fields
}
RequestProcessingListeners is a set of listeners for when requests begin processing
func NewRequestProcessingListeners ¶ added in v0.14.0
func NewRequestProcessingListeners() *RequestProcessingListeners
NewRequestProcessingListeners returns a new list of listeners for when requestors cancel
func (*RequestProcessingListeners) NotifyRequestProcessingListeners ¶ added in v0.14.0
func (rpl *RequestProcessingListeners) NotifyRequestProcessingListeners(p peer.ID, request graphsync.RequestData, inProgressRequestCount int)
NotifyRequestProcessingListeners notifies all listeners that a requestor cancelled a response
func (*RequestProcessingListeners) Register ¶ added in v0.14.0
func (rpl *RequestProcessingListeners) Register(listener graphsync.OnRequestProcessingListener) graphsync.UnregisterHookFunc
Register registers an listener for responses that are processing
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