storageResolvers

Documentation

Index

• func NewHeaderResolver(arg ArgHeaderResolver) (*headerResolver, error)
• func NewSliceResolver(arg ArgSliceResolver) (*sliceResolver, error)
• func NewTrieNodeResolver() *trieNodeResolver
• type ArgHeaderResolver
• type ArgSliceResolver

Functions

func NewHeaderResolver

func NewHeaderResolver(arg ArgHeaderResolver) (*headerResolver, error)

NewHeaderResolver creates a new storage header resolver

func NewSliceResolver

func NewSliceResolver(arg ArgSliceResolver) (*sliceResolver, error)

NewSliceResolver is a wrapper over Resolver that is specialized in resolving single and multiple requests

func NewTrieNodeResolver

func NewTrieNodeResolver() *trieNodeResolver

NewTrieNodeResolver returns a new trie node resolver instance. This instance is mocked as it is not supported when trying to request from storage.

Types

type ArgHeaderResolver

type ArgHeaderResolver 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
}

ArgHeaderResolver is the argument structure used to create new HeaderResolver instance

type ArgSliceResolver

type ArgSliceResolver 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
}

ArgSliceResolver is the argument structure used to create a new sliceResolver instance