Documentation
¶
Index ¶
- func ParsePublicKeysFromStrings(pubKeys []string) (keys.PublicKeys, error)
- type ClientCache
- func (c *ClientCache) Get(info clientcore.NodeInfo) (clientcore.Client, error)
- func (c *ClientCache) GetHeader(task *audit.Task, node *netmap.Node, id *oidSDK.ID, relay bool) (*object.Object, error)
- func (c *ClientCache) GetRangeHash(task *audit.Task, node *netmap.Node, id *oidSDK.ID, rng *object.Range) ([]byte, error)
- func (c *ClientCache) GetSG(task *audit.Task, id *oidSDK.ID) (*storagegroup.StorageGroup, error)
- func (c ClientCache) ListSG(dst *auditproc.SearchSGDst, prm auditproc.SearchSGPrm) error
- type ContractProcessor
- type GlagoliticLetter
- type IrFetcherWithNotary
- type IrFetcherWithoutNotary
- type Server
- func (s *Server) AlphabetIndex() int
- func (s *Server) EpochCounter() uint64
- func (s *Server) EpochDuration() uint64
- func (s *Server) HealthStatus() control.HealthStatus
- func (s *Server) InnerRingIndex() int
- func (s *Server) InnerRingSize() int
- func (s *Server) IsActive() bool
- func (s *Server) IsAlphabet() bool
- func (s *Server) ResetEpochTimer() error
- func (s *Server) SetEpochCounter(val uint64)
- func (s *Server) SetEpochDuration(val uint64)
- func (s *Server) Start(ctx context.Context, intError chan<- error) (err error)
- func (s *Server) Stop()
- func (s *Server) VoteForSidechainValidator(prm governance.VoteValidatorPrm) error
- func (s *Server) WriteReport(r *audit.Report) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ParsePublicKeysFromStrings ¶ added in v0.13.0
func ParsePublicKeysFromStrings(pubKeys []string) (keys.PublicKeys, error)
ParsePublicKeysFromStrings returns slice of neo public keys from slice of hex encoded strings.
Types ¶
type ClientCache ¶ added in v0.14.0
type ClientCache struct {
// contains filtered or unexported fields
}
func (*ClientCache) Get ¶ added in v0.14.0
func (c *ClientCache) Get(info clientcore.NodeInfo) (clientcore.Client, error)
func (*ClientCache) GetHeader ¶ added in v0.14.0
func (c *ClientCache) GetHeader(task *audit.Task, node *netmap.Node, id *oidSDK.ID, relay bool) (*object.Object, error)
GetHeader requests node from the container under audit to return object header by id.
func (*ClientCache) GetRangeHash ¶ added in v0.14.0
func (c *ClientCache) GetRangeHash(task *audit.Task, node *netmap.Node, id *oidSDK.ID, rng *object.Range) ([]byte, error)
GetRangeHash requests node from the container under audit to return Tillich-Zemor hash of the payload range of the object with specified identifier.
func (*ClientCache) GetSG ¶ added in v0.14.0
func (c *ClientCache) GetSG(task *audit.Task, id *oidSDK.ID) (*storagegroup.StorageGroup, error)
GetSG polls the container from audit task to get the object by id. Returns storage groups structure from received object.
Returns an error of type apistatus.ObjectNotFound if storage group is missing.
func (ClientCache) ListSG ¶ added in v0.26.1
func (c ClientCache) ListSG(dst *auditproc.SearchSGDst, prm auditproc.SearchSGPrm) error
type ContractProcessor ¶
type ContractProcessor interface { ListenerNotificationParsers() []event.NotificationParserInfo ListenerNotificationHandlers() []event.NotificationHandlerInfo ListenerNotaryParsers() []event.NotaryParserInfo ListenerNotaryHandlers() []event.NotaryHandlerInfo TimersHandlers() []event.NotificationHandlerInfo }
ContractProcessor interface defines functions for binding event producers such as event.Listener and Timers with contract processor.
type GlagoliticLetter ¶ added in v0.22.3
type GlagoliticLetter int8
func (GlagoliticLetter) String ¶ added in v0.22.3
func (l GlagoliticLetter) String() string
returns string in config-compatible format
type IrFetcherWithNotary ¶ added in v0.23.0
type IrFetcherWithNotary struct {
// contains filtered or unexported fields
}
IrFetcherWithNotary fetches keys using notary contract. Must be created with NewIRFetcherWithNotary.
func NewIRFetcherWithNotary ¶ added in v0.23.0
func NewIRFetcherWithNotary(cli *client.Client) *IrFetcherWithNotary
NewIRFetcherWithNotary creates IrFetcherWithNotary.
IrFetcherWithNotary can be used to obtain innerring key list if network that client is connected to supports notary contract.
Passed client is required. Panics if nil.
func (IrFetcherWithNotary) InnerRingKeys ¶ added in v0.23.0
func (fN IrFetcherWithNotary) InnerRingKeys() (keys.PublicKeys, error)
InnerRingKeys fetches list of innerring keys from NeoFSAlphabet role in side chain.
type IrFetcherWithoutNotary ¶ added in v0.23.0
type IrFetcherWithoutNotary struct {
// contains filtered or unexported fields
}
IrFetcherWithoutNotary fetches keys using netmap contract. Must be created with NewIRFetcherWithoutNotary.
func NewIRFetcherWithoutNotary ¶ added in v0.23.0
func NewIRFetcherWithoutNotary(nm *nmClient.Client) *IrFetcherWithoutNotary
NewIRFetcherWithoutNotary creates IrFetcherWithoutNotary.
IrFetcherWithoutNotary must be used to obtain innerring key list if network that netmap wrapper is connected to does not support notary contract.
Passed netmap wrapper is required. Panics if nil.
func (IrFetcherWithoutNotary) InnerRingKeys ¶ added in v0.23.0
func (f IrFetcherWithoutNotary) InnerRingKeys() (keys.PublicKeys, error)
InnerRingKeys fetches list of innerring keys from netmap contract in side chain.
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server is the inner ring application structure, that contains all event processors, shared variables and event handlers.
func (*Server) AlphabetIndex ¶ added in v0.18.0
AlphabetIndex is a getter for a global index of node in alphabet list. Negative index means that node is not in the alphabet list.
func (*Server) EpochCounter ¶
EpochCounter is a getter for a global epoch counter.
func (*Server) EpochDuration ¶ added in v0.26.0
EpochDuration is a getter for a global epoch duration.
func (*Server) HealthStatus ¶ added in v0.22.0
func (s *Server) HealthStatus() control.HealthStatus
HealthStatus returns current health status of IR application.
func (*Server) InnerRingIndex ¶ added in v0.18.0
InnerRingIndex is a getter for a global index of node in inner ring list. Negative index means that node is not in the inner ring list.
func (*Server) InnerRingSize ¶ added in v0.14.0
InnerRingSize is a getter for a global size of inner ring list. This value paired with inner ring index.
func (*Server) IsAlphabet ¶ added in v0.18.0
IsAlphabet is a getter for a global alphabet flag state.
func (*Server) ResetEpochTimer ¶ added in v0.15.0
ResetEpochTimer resets block timer that produces events to update epoch counter in netmap contract. Used to synchronize this even production based on block with notification of last epoch.
func (*Server) SetEpochCounter ¶
SetEpochCounter is a setter for contract processors to update global epoch counter.
func (*Server) SetEpochDuration ¶ added in v0.26.0
SetEpochDuration is a setter for the Netmap processor to update global epoch duration.
func (*Server) VoteForSidechainValidator ¶ added in v0.18.0
func (s *Server) VoteForSidechainValidator(prm governance.VoteValidatorPrm) error
VoteForSidechainValidator calls vote method on alphabet contracts with provided list of keys.