Versions in this module Expand all Collapse all v1 v1.1.1 Dec 18, 2024 Changes in this version + type Engine struct + Bootstrapper common.BootstrapableEngine + Consensus common.Engine + StateSyncer common.StateSyncer + func (e *Engine) Get(state snow.State) (common.Engine, bool) + type EngineManager struct + Avalanche *Engine + Snowman *Engine + func (e *EngineManager) Get(engineType p2p.EngineType) *Engine + type Handler interface + Context func() *snow.ConsensusContext + GetEngineManager func() *EngineManager + Len func() int + Push func(ctx context.Context, msg Message) + SetEngineManager func(engineManager *EngineManager) + SetOnStopped func(onStopped func()) + ShouldHandle func(nodeID ids.NodeID) bool + Start func(ctx context.Context, recoverPanic bool) + Stop func(ctx context.Context) + StopWithError func(ctx context.Context, err error) + Stopped func() chan struct{} + func New(ctx *snow.ConsensusContext, validators validators.Set, ...) (Handler, error) + type Message struct + EngineType p2p.EngineType + type MessageQueue interface + Len func() int + Pop func() (context.Context, Message, bool) + Push func(context.Context, Message) + Shutdown func() + func NewMessageQueue(log logging.Logger, vdrs validators.Set, cpuTracker tracker.Tracker, ...) (MessageQueue, error) + type MockHandler struct + func NewMockHandler(ctrl *gomock.Controller) *MockHandler + func (m *MockHandler) Context() *snow.ConsensusContext + func (m *MockHandler) EXPECT() *MockHandlerMockRecorder + func (m *MockHandler) GetEngineManager() *EngineManager + func (m *MockHandler) HealthCheck(arg0 context.Context) (interface{}, error) + func (m *MockHandler) Len() int + func (m *MockHandler) Push(arg0 context.Context, arg1 Message) + func (m *MockHandler) RegisterTimeout(arg0 time.Duration) + func (m *MockHandler) SetEngineManager(arg0 *EngineManager) + func (m *MockHandler) SetOnStopped(arg0 func()) + func (m *MockHandler) ShouldHandle(arg0 ids.NodeID) bool + func (m *MockHandler) Start(arg0 context.Context, arg1 bool) + func (m *MockHandler) Stop(arg0 context.Context) + func (m *MockHandler) StopWithError(arg0 context.Context, arg1 error) + func (m *MockHandler) Stopped() chan struct{} + type MockHandlerMockRecorder struct + func (mr *MockHandlerMockRecorder) Context() *gomock.Call + func (mr *MockHandlerMockRecorder) GetEngineManager() *gomock.Call + func (mr *MockHandlerMockRecorder) HealthCheck(arg0 interface{}) *gomock.Call + func (mr *MockHandlerMockRecorder) Len() *gomock.Call + func (mr *MockHandlerMockRecorder) Push(arg0, arg1 interface{}) *gomock.Call + func (mr *MockHandlerMockRecorder) RegisterTimeout(arg0 interface{}) *gomock.Call + func (mr *MockHandlerMockRecorder) SetEngineManager(arg0 interface{}) *gomock.Call + func (mr *MockHandlerMockRecorder) SetOnStopped(arg0 interface{}) *gomock.Call + func (mr *MockHandlerMockRecorder) ShouldHandle(arg0 interface{}) *gomock.Call + func (mr *MockHandlerMockRecorder) Start(arg0, arg1 interface{}) *gomock.Call + func (mr *MockHandlerMockRecorder) Stop(arg0 interface{}) *gomock.Call + func (mr *MockHandlerMockRecorder) StopWithError(arg0, arg1 interface{}) *gomock.Call + func (mr *MockHandlerMockRecorder) Stopped() *gomock.Call
Go to main page