storagerequesters

Documentation

Index

• func NewHeaderRequester(arg ArgHeaderRequester) (*headerRequester, error)
• func NewSliceRequester(arg ArgSliceRequester) (*sliceRequester, error)
• func NewTrieNodeRequester(arg ArgTrieRequester) (*trieNodeRequester, error)
• type ArgHeaderRequester
• type ArgSliceRequester
• type ArgTrieRequester

Functions

func NewHeaderRequester

func NewHeaderRequester(arg ArgHeaderRequester) (*headerRequester, error)

NewHeaderRequester creates a new storage header resolver

func NewSliceRequester

func NewSliceRequester(arg ArgSliceRequester) (*sliceRequester, error)

NewSliceRequester is a wrapper over Requester that is specialized in sending requests

func NewTrieNodeRequester

func NewTrieNodeRequester(arg ArgTrieRequester) (*trieNodeRequester, error)

NewTrieNodeRequester returns a new trie node Requester instance. It uses trie snapshots in order to get older data

Types

type ArgHeaderRequester

type ArgHeaderRequester struct {
	Messenger                dataRetriever.MessageHandler
	ResponseTopicName        string
	NonceConverter           typeConverters.Uint64ByteSliceConverter
	HdrStorage               storage.Storer
	HeadersNoncesStorage     storage.Storer
	ManualEpochStartNotifier dataRetriever.ManualEpochStartNotifier
	ChanGracefullyClose      chan endProcess.ArgEndProcess
	DelayBeforeGracefulClose time.Duration
}

ArgHeaderRequester is the argument structure used to create new headerRequester instance

type ArgSliceRequester

type ArgSliceRequester struct {
	Messenger                dataRetriever.MessageHandler
	ResponseTopicName        string
	Storage                  storage.Storer
	DataPacker               dataRetriever.DataPacker
	Marshalizer              marshal.Marshalizer
	ManualEpochStartNotifier dataRetriever.ManualEpochStartNotifier
	ChanGracefullyClose      chan endProcess.ArgEndProcess
	DelayBeforeGracefulClose time.Duration
}

ArgSliceRequester is the argument structure used to create a new sliceRequester instance

type ArgTrieRequester

type ArgTrieRequester struct {
	Messenger                dataRetriever.MessageHandler
	ResponseTopicName        string
	Marshalizer              marshal.Marshalizer
	TrieDataGetter           dataRetriever.TrieDataGetter
	TrieStorageManager       common.StorageManager
	ManualEpochStartNotifier dataRetriever.ManualEpochStartNotifier
	ChanGracefullyClose      chan endProcess.ArgEndProcess
	DelayBeforeGracefulClose time.Duration
}

ArgTrieRequester is the argument structure used to create new TrieRequester instance