listeners

package
v0.17.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 16, 2024 License: Apache-2.0, MIT Imports: 3 Imported by: 2

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL