Documentation
¶
Index ¶
- type Averager
- type Config
- type Engine
- func (e *Engine) Chits(ctx context.Context, nodeID ids.NodeID, requestID uint32, preferredID ids.ID, ...) error
- func (e *Engine) Context() *consensus.Context
- func (e *Engine) GetFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32) error
- func (e *Engine) Gossip(ctx context.Context) error
- func (e *Engine) HealthCheck(ctx context.Context) (interface{}, error)
- func (e *Engine) Notify(ctx context.Context, msg core.Message) error
- func (e *Engine) PullQuery(ctx context.Context, nodeID ids.NodeID, requestID uint32, blkID ids.ID, ...) error
- func (e *Engine) PushQuery(ctx context.Context, nodeID ids.NodeID, requestID uint32, blkBytes []byte, ...) error
- func (e *Engine) Put(ctx context.Context, nodeID ids.NodeID, requestID uint32, blkBytes []byte) error
- func (e *Engine) QueryFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32) error
- func (e *Engine) Shutdown(ctx context.Context) error
- func (e *Engine) Start(ctx context.Context, startReqID uint32) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Averager ¶ added in v1.1.11
type Averager interface {
Observe(float64)
}
Averager tracks average values using count and sum
type Config ¶ added in v0.15.6
type Config struct {
core.AllGetsServer
Ctx *consensus.Context
VM block.ChainVM
Sender core.Sender
Validators validators.Manager
ConnectedValidators tracker.Peers
Params sampling.Parameters
Consensus chain.Consensus
PartialSync bool
}
Config wraps all the parameters needed for a linear engine
type Engine ¶
type Engine struct {
Config
// list of NoOpsHandler for messages dropped by engine
core.StateSummaryFrontierHandler
core.AcceptedStateSummaryHandler
core.AcceptedFrontierHandler
core.AcceptedHandler
core.AncestorsHandler
core.AppHandler
validators.Connector
// contains filtered or unexported fields
}
Engine implements the Engine interface by attempting to fetch all Engine dependencies.
func (*Engine) HealthCheck ¶ added in v0.15.6
func (*Engine) QueryFailed ¶ added in v0.15.6
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
Package block is a generated GoMock package.
|
Package block is a generated GoMock package. |
|
blockmock
Package blockmock is a generated GoMock package.
|
Package blockmock is a generated GoMock package. |
|
Package job provides a Scheduler to manage and execute Jobs with dependencies.
|
Package job provides a Scheduler to manage and execute Jobs with dependencies. |
Click to show internal directories.
Click to hide internal directories.