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) 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) SetEpochCounter ¶
SetEpochCounter is a setter for contract processors to update global epoch counter.