Documentation
¶
Index ¶
- func ParsePublicKeysFromStrings(pubKeys []string) ([]keys.PublicKey, error)
- type ClientCache
- func (c *ClientCache) Get(address string, opts ...client.Option) (*client.Client, error)
- func (c *ClientCache) GetHeader(task *audit.Task, node *netmap.Node, id *object.ID, relay bool) (*object.Object, error)
- func (c *ClientCache) GetRangeHash(task *audit.Task, node *netmap.Node, id *object.ID, rng *object.Range) ([]byte, error)
- func (c *ClientCache) GetSG(task *audit.Task, id *object.ID) (*storagegroup.StorageGroup, error)
- type ContractProcessor
- type Server
- func (s *Server) EpochCounter() uint64
- func (s *Server) Index() int32
- func (s *Server) InitAndVoteForSidechainValidator(validators []keys.PublicKey) error
- func (s *Server) InnerRingSize() int32
- func (s *Server) IsActive() bool
- func (s *Server) ResetEpochTimer() error
- func (s *Server) SetEpochCounter(val uint64)
- func (s *Server) Start(ctx context.Context, intError chan<- error) error
- func (s *Server) Stop()
- func (s *Server) WriteReport(r *audit.Report) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ClientCache ¶ added in v0.14.0
type ClientCache struct {
// contains filtered or unexported fields
}
func (*ClientCache) GetHeader ¶ added in v0.14.0
func (c *ClientCache) GetHeader(task *audit.Task, node *netmap.Node, id *object.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 *object.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 *object.ID) (*storagegroup.StorageGroup, error)
GetSG polls the container from audit task to get the object by id. Returns storage groups structure from received object.
type ContractProcessor ¶
type ContractProcessor interface { ListenerParsers() []event.ParserInfo ListenerHandlers() []event.HandlerInfo TimersHandlers() []event.HandlerInfo }
ContractProcessor interface defines functions for binding event producers such as event.Listener and Timers with contract processor.
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) EpochCounter ¶
EpochCounter is a getter for a global epoch counter.
func (*Server) Index ¶ added in v0.12.0
Index 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) InitAndVoteForSidechainValidator ¶ added in v0.13.0
InitAndVoteForSidechainValidator is a public function to use outside of inner ring daemon execution. It initialize inner ring structure with data from blockchain and then calls vote method on corresponding alphabet contract.
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) 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.