hooks

Documentation

Index

• type BlockResult
• type BlockSentListeners
  • func NewBlockSentListeners() *BlockSentListeners
  • func (bsl *BlockSentListeners) NotifyBlockSentListeners(p peer.ID, request graphsync.RequestData, block graphsync.BlockData)
  • func (bsl *BlockSentListeners) Register(listener graphsync.OnBlockSentListener) graphsync.UnregisterHookFunc
• type CompletedResponseListeners
  • func NewCompletedResponseListeners() *CompletedResponseListeners
  • func (crl *CompletedResponseListeners) NotifyCompletedListeners(p peer.ID, request graphsync.RequestData, status graphsync.ResponseStatusCode)
  • func (crl *CompletedResponseListeners) Register(listener graphsync.OnResponseCompletedListener) graphsync.UnregisterHookFunc
• type ErrPaused
  • func (e ErrPaused) Error() string
• type IncomingRequestHooks
  • func NewRequestHooks(persistenceOptions PersistenceOptions) *IncomingRequestHooks
  • func (irh *IncomingRequestHooks) ProcessRequestHooks(p peer.ID, request graphsync.RequestData) RequestResult
  • func (irh *IncomingRequestHooks) Register(hook graphsync.OnIncomingRequestHook) graphsync.UnregisterHookFunc
• type NetworkErrorListeners
  • func NewNetworkErrorListeners() *NetworkErrorListeners
  • func (nel *NetworkErrorListeners) NotifyNetworkErrorListeners(p peer.ID, request graphsync.RequestData, err error)
  • func (nel *NetworkErrorListeners) Register(listener graphsync.OnNetworkErrorListener) graphsync.UnregisterHookFunc
• type OutgoingBlockHooks
  • func NewBlockHooks() *OutgoingBlockHooks
  • func (obh *OutgoingBlockHooks) ProcessBlockHooks(p peer.ID, request graphsync.RequestData, blockData graphsync.BlockData) BlockResult
  • func (obh *OutgoingBlockHooks) Register(hook graphsync.OnOutgoingBlockHook) graphsync.UnregisterHookFunc
• type PersistenceOptions
• type RequestResult
• type RequestUpdatedHooks
  • func NewUpdateHooks() *RequestUpdatedHooks
  • func (ruh *RequestUpdatedHooks) ProcessUpdateHooks(p peer.ID, request graphsync.RequestData, update graphsync.RequestData) UpdateResult
  • func (ruh *RequestUpdatedHooks) Register(hook graphsync.OnRequestUpdatedHook) graphsync.UnregisterHookFunc
• type RequestorCancelledListeners
  • func NewRequestorCancelledListeners() *RequestorCancelledListeners
  • func (rcl *RequestorCancelledListeners) NotifyCancelledListeners(p peer.ID, request graphsync.RequestData)
  • func (rcl *RequestorCancelledListeners) Register(listener graphsync.OnRequestorCancelledListener) graphsync.UnregisterHookFunc
• type UpdateResult

Types

type BlockResult

type BlockResult struct {
	Err        error
	Extensions []graphsync.ExtensionData
}

BlockResult is the result of processing block hooks

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 ErrPaused

type ErrPaused struct{}

ErrPaused indicates a request should stop processing, but only cause it's paused

func (ErrPaused) Error

func (e ErrPaused) Error() string

type IncomingRequestHooks

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

IncomingRequestHooks is a set of incoming request hooks that can be processed

func NewRequestHooks

func NewRequestHooks(persistenceOptions PersistenceOptions) *IncomingRequestHooks

NewRequestHooks returns a new list of incoming request hooks

func (*IncomingRequestHooks) ProcessRequestHooks

func (irh *IncomingRequestHooks) ProcessRequestHooks(p peer.ID, request graphsync.RequestData) RequestResult

ProcessRequestHooks runs request hooks against an incoming request

func (*IncomingRequestHooks) Register

func (irh *IncomingRequestHooks) Register(hook graphsync.OnIncomingRequestHook) graphsync.UnregisterHookFunc

Register registers an extension to process new incoming requests

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 OutgoingBlockHooks

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

OutgoingBlockHooks is a set of outgoing block hooks that can be processed

func NewBlockHooks

func NewBlockHooks() *OutgoingBlockHooks

NewBlockHooks returns a new list of outgoing block hooks

func (*OutgoingBlockHooks) ProcessBlockHooks

func (obh *OutgoingBlockHooks) ProcessBlockHooks(p peer.ID, request graphsync.RequestData, blockData graphsync.BlockData) BlockResult

ProcessBlockHooks runs block hooks against a request and block data

func (*OutgoingBlockHooks) Register

func (obh *OutgoingBlockHooks) Register(hook graphsync.OnOutgoingBlockHook) graphsync.UnregisterHookFunc

Register registers an hook to process outgoing blocks in a response

type PersistenceOptions

type PersistenceOptions interface {
	GetLoader(name string) (ipld.Loader, bool)
}

PersistenceOptions is an interface for getting loaders by name

type RequestResult

type RequestResult struct {
	IsValidated   bool
	IsPaused      bool
	CustomLoader  ipld.Loader
	CustomChooser traversal.LinkTargetNodePrototypeChooser
	Err           error
	Extensions    []graphsync.ExtensionData
}

RequestResult is the outcome of running requesthooks

type RequestUpdatedHooks

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

RequestUpdatedHooks manages and runs hooks for request updates

func NewUpdateHooks

func NewUpdateHooks() *RequestUpdatedHooks

NewUpdateHooks returns a new list of request updated hooks

func (*RequestUpdatedHooks) ProcessUpdateHooks

func (ruh *RequestUpdatedHooks) ProcessUpdateHooks(p peer.ID, request graphsync.RequestData, update graphsync.RequestData) UpdateResult

ProcessUpdateHooks runs request hooks against an incoming request

func (*RequestUpdatedHooks) Register

func (ruh *RequestUpdatedHooks) Register(hook graphsync.OnRequestUpdatedHook) graphsync.UnregisterHookFunc

Register registers an hook to process updates to requests

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

type UpdateResult

type UpdateResult struct {
	Err        error
	Unpause    bool
	Extensions []graphsync.ExtensionData
}

UpdateResult is the result of running update hooks