Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type CalculateID ¶
type CalculateID struct {
Result struct {
ID insolar.ID
}
// contains filtered or unexported fields
}
func NewCalculateID ¶
func NewCalculateID(payload []byte, pulse insolar.PulseNumber) *CalculateID
func (*CalculateID) Dep ¶
func (p *CalculateID) Dep(pcs insolar.PlatformCryptographyScheme)
type Dependencies ¶
type Dependencies struct {
FetchJet func(*FetchJet)
WaitHot func(*WaitHot)
EnsureIndex func(*EnsureIndex)
SendObject func(*SendObject)
GetCode func(*GetCode)
GetRequest func(*GetRequest)
GetRequestInfo func(*SendRequestInfo)
SetRequest func(*SetRequest)
SetResult func(*SetResult)
GetPendings func(*GetPendings)
GetJet func(*GetJet)
HotObjects func(*HotObjects)
PassState func(*PassState)
CalculateID func(*CalculateID)
SetCode func(*SetCode)
SendFilament func(*SendFilament)
HasPendings func(*HasPendings)
Config func() configuration.Ledger
}
func NewDependencies ¶
func NewDependencies( pcs insolar.PlatformCryptographyScheme, jetCoordinator jet.Coordinator, jetStorage jet.Storage, pulseCalculator pulse.Calculator, sender bus.Sender, dropModifier drop.Modifier, indexLocker object.IndexLocker, recordStorage object.AtomicRecordStorage, indexStorage object.MemoryIndexStorage, jetReleaser executor.JetReleaser, hotWaiter executor.JetWaiter, writeAccessor executor.WriteAccessor, jetFetcher executor.JetFetcher, filaments executor.FilamentCalculator, requestChecker executor.RequestChecker, detachedNotifier executor.DetachedNotifier, config configuration.Ledger, registry executor.MetricsRegistry, ) *Dependencies
func NewDependenciesMock ¶
func NewDependenciesMock() *Dependencies
NewDependenciesMock returns all dependencies for handlers. It's all empty. Use it ONLY for tests.
type EnsureIndex ¶
type EnsureIndex struct {
// contains filtered or unexported fields
}
func NewEnsureIndex ¶
func NewEnsureIndex(obj insolar.ID, jetID insolar.JetID, msg payload.Meta, pulse insolar.PulseNumber) *EnsureIndex
func (*EnsureIndex) Dep ¶
func (p *EnsureIndex) Dep( il object.IndexLocker, idxs object.MemoryIndexStorage, c jet.Coordinator, s bus.Sender, wc executor.WriteAccessor, )
type FetchJet ¶
type FetchJet struct {
Result struct {
Jet insolar.JetID
}
// contains filtered or unexported fields
}
func NewFetchJet ¶
type GetCode ¶
type GetCode struct {
// contains filtered or unexported fields
}
func (*GetCode) Dep ¶
func (p *GetCode) Dep( r object.RecordAccessor, c jet.Coordinator, f executor.JetFetcher, s bus.Sender, )
type GetPendings ¶
type GetPendings struct {
// contains filtered or unexported fields
}
func NewGetPendings ¶
func (*GetPendings) Dep ¶
func (p *GetPendings) Dep( f executor.FilamentCalculator, s bus.Sender, )
type GetRequest ¶
type GetRequest struct {
// contains filtered or unexported fields
}
func NewGetRequest ¶
func (*GetRequest) Dep ¶
func (p *GetRequest) Dep( records object.RecordAccessor, sender bus.Sender, coordinator jet.Coordinator, fetcher executor.JetFetcher, )
type HasPendings ¶
type HasPendings struct {
// contains filtered or unexported fields
}
func NewHasPendings ¶
func NewHasPendings(msg payload.Meta, objectID insolar.ID) *HasPendings
func (*HasPendings) Dep ¶
func (hp *HasPendings) Dep( index object.IndexAccessor, sender bus.Sender, )
type HotObjects ¶
type HotObjects struct {
// contains filtered or unexported fields
}
func NewHotObjects ¶
func (*HotObjects) Dep ¶
func (p *HotObjects) Dep( drops drop.Modifier, indexes object.MemoryIndexModifier, jStore jet.Storage, jFetcher executor.JetFetcher, jReleaser executor.JetReleaser, coordinator jet.Coordinator, pCalc pulse.Calculator, sender bus.Sender, registry executor.MetricsRegistry, )
type PassState ¶
type PassState struct {
// contains filtered or unexported fields
}
func NewPassState ¶
type SendFilament ¶
type SendFilament struct {
// contains filtered or unexported fields
}
func NewSendFilament ¶
func NewSendFilament(msg payload.Meta, objID insolar.ID, startFrom insolar.ID, readUntil insolar.PulseNumber) *SendFilament
func (*SendFilament) Dep ¶
func (p *SendFilament) Dep(sender bus.Sender, filaments executor.FilamentCalculator)
type SendObject ¶
type SendObject struct {
// contains filtered or unexported fields
}
func NewSendObject ¶
func (*SendObject) Dep ¶
func (p *SendObject) Dep( coordinator jet.Coordinator, jets jet.Storage, jetFetcher executor.JetFetcher, records object.RecordAccessor, indexes object.IndexAccessor, sender bus.Sender, filament executor.FilamentCalculator, )
type SendRequestInfo ¶
type SendRequestInfo struct {
// contains filtered or unexported fields
}
func NewSendRequestInfo ¶
func NewSendRequestInfo( msg payload.Meta, objectID insolar.ID, requestID insolar.ID, pulse insolar.PulseNumber, ) *SendRequestInfo
func (*SendRequestInfo) Dep ¶
func (p *SendRequestInfo) Dep( filament executor.FilamentCalculator, sender bus.Sender, locker object.IndexLocker, )
type SetCode ¶
type SetCode struct {
// contains filtered or unexported fields
}
func NewSetCode ¶
func (*SetCode) Dep ¶
func (p *SetCode) Dep( w executor.WriteAccessor, r object.AtomicRecordModifier, pcs insolar.PlatformCryptographyScheme, s bus.Sender, )
type SetRequest ¶
type SetRequest struct {
// contains filtered or unexported fields
}
func NewSetRequest ¶
func (*SetRequest) Dep ¶
func (p *SetRequest) Dep( w executor.WriteAccessor, f executor.FilamentCalculator, s bus.Sender, l object.IndexLocker, i object.MemoryIndexStorage, r object.AtomicRecordModifier, pcs insolar.PlatformCryptographyScheme, rc executor.RequestChecker, c jet.Coordinator, )
type SetResult ¶
type SetResult struct {
// contains filtered or unexported fields
}
func NewSetResult ¶
func (*SetResult) Dep ¶
func (p *SetResult) Dep( w executor.WriteAccessor, s bus.Sender, l object.IndexLocker, f executor.FilamentCalculator, r object.AtomicRecordModifier, i object.MemoryIndexStorage, pcs insolar.PlatformCryptographyScheme, dn executor.DetachedNotifier, )
Source Files
Click to show internal directories.
Click to hide internal directories.