Versions in this module Expand all Collapse all v0 v0.0.15 Sep 23, 2022 v0.0.14 Sep 23, 2022 Changes in this version + var Handshake = plugin.HandshakeConfig + var PluginMap = map[string]plugin.Plugin + func New(vm block.ChainVM) plugin.Plugin + func NewFactory(path string, processTracker resource.ProcessTracker) vms.Factory + func Serve(vm block.ChainVM) + type MockFactory struct + func NewMockFactory(ctrl *gomock.Controller) *MockFactory + func (m *MockFactory) EXPECT() *MockFactoryMockRecorder + func (m *MockFactory) New(arg0 *snow.Context) (interface{}, error) + type MockFactoryMockRecorder struct + func (mr *MockFactoryMockRecorder) New(arg0 interface{}) *gomock.Call + type MockPluginDirectory struct + func NewMockPluginDirectory(ctrl *gomock.Controller) *MockPluginDirectory + func (m *MockPluginDirectory) EXPECT() *MockPluginDirectoryMockRecorder + func (m *MockPluginDirectory) GetVMs(manager vms.Manager) (map[ids.ID]vms.Factory, map[ids.ID]vms.Factory, error) + type MockPluginDirectoryMockRecorder struct + func (mr *MockPluginDirectoryMockRecorder) GetVMs(manager interface{}) *gomock.Call + type VMClient struct + func NewClient(client vmpb.VMClient) *VMClient + func (vm *VMClient) AppGossip(nodeID ids.NodeID, msg []byte) error + func (vm *VMClient) AppRequest(nodeID ids.NodeID, requestID uint32, deadline time.Time, request []byte) error + func (vm *VMClient) AppRequestFailed(nodeID ids.NodeID, requestID uint32) error + func (vm *VMClient) AppResponse(nodeID ids.NodeID, requestID uint32, response []byte) error + func (vm *VMClient) BatchedParseBlock(blksBytes [][]byte) ([]snowman.Block, error) + func (vm *VMClient) Connected(nodeID ids.NodeID, nodeVersion *version.Application) error + func (vm *VMClient) CreateHandlers() (map[string]*common.HTTPHandler, error) + func (vm *VMClient) CreateStaticHandlers() (map[string]*common.HTTPHandler, error) + func (vm *VMClient) Disconnected(nodeID ids.NodeID) error + func (vm *VMClient) Gather() ([]*dto.MetricFamily, error) + func (vm *VMClient) GetAncestors(blkID ids.ID, maxBlocksNum int, maxBlocksSize int, ...) ([][]byte, error) + func (vm *VMClient) GetBlockIDAtHeight(height uint64) (ids.ID, error) + func (vm *VMClient) GetLastStateSummary() (block.StateSummary, error) + func (vm *VMClient) GetOngoingSyncStateSummary() (block.StateSummary, error) + func (vm *VMClient) GetStateSummary(summaryHeight uint64) (block.StateSummary, error) + func (vm *VMClient) HealthCheck() (interface{}, error) + func (vm *VMClient) Initialize(ctx *snow.Context, dbManager manager.Manager, genesisBytes []byte, ...) error + func (vm *VMClient) ParseStateSummary(summaryBytes []byte) (block.StateSummary, error) + func (vm *VMClient) SetPreference(id ids.ID) error + func (vm *VMClient) SetProcess(ctx *snow.Context, proc *plugin.Client, processTracker resource.ProcessTracker) + func (vm *VMClient) SetState(state snow.State) error + func (vm *VMClient) Shutdown() error + func (vm *VMClient) StateSyncEnabled() (bool, error) + func (vm *VMClient) VerifyHeightIndex() error + func (vm *VMClient) Version() (string, error) + type VMServer struct + func NewServer(vm block.ChainVM) *VMServer + func (vm *VMServer) AppGossip(_ context.Context, req *vmpb.AppGossipMsg) (*emptypb.Empty, error) + func (vm *VMServer) AppRequest(_ context.Context, req *vmpb.AppRequestMsg) (*emptypb.Empty, error) + func (vm *VMServer) AppRequestFailed(_ context.Context, req *vmpb.AppRequestFailedMsg) (*emptypb.Empty, error) + func (vm *VMServer) AppResponse(_ context.Context, req *vmpb.AppResponseMsg) (*emptypb.Empty, error) + func (vm *VMServer) BatchedParseBlock(ctx context.Context, req *vmpb.BatchedParseBlockRequest) (*vmpb.BatchedParseBlockResponse, error) + func (vm *VMServer) BlockAccept(_ context.Context, req *vmpb.BlockAcceptRequest) (*emptypb.Empty, error) + func (vm *VMServer) BlockReject(_ context.Context, req *vmpb.BlockRejectRequest) (*emptypb.Empty, error) + func (vm *VMServer) BlockVerify(_ context.Context, req *vmpb.BlockVerifyRequest) (*vmpb.BlockVerifyResponse, error) + func (vm *VMServer) BuildBlock(context.Context, *emptypb.Empty) (*vmpb.BuildBlockResponse, error) + func (vm *VMServer) Connected(_ context.Context, req *vmpb.ConnectedRequest) (*emptypb.Empty, error) + func (vm *VMServer) CreateHandlers(context.Context, *emptypb.Empty) (*vmpb.CreateHandlersResponse, error) + func (vm *VMServer) CreateStaticHandlers(context.Context, *emptypb.Empty) (*vmpb.CreateStaticHandlersResponse, error) + func (vm *VMServer) Disconnected(_ context.Context, req *vmpb.DisconnectedRequest) (*emptypb.Empty, error) + func (vm *VMServer) Gather(context.Context, *emptypb.Empty) (*vmpb.GatherResponse, error) + func (vm *VMServer) GetAncestors(_ context.Context, req *vmpb.GetAncestorsRequest) (*vmpb.GetAncestorsResponse, error) + func (vm *VMServer) GetBlock(_ context.Context, req *vmpb.GetBlockRequest) (*vmpb.GetBlockResponse, error) + func (vm *VMServer) GetBlockIDAtHeight(ctx context.Context, req *vmpb.GetBlockIDAtHeightRequest) (*vmpb.GetBlockIDAtHeightResponse, error) + func (vm *VMServer) GetLastStateSummary(ctx context.Context, empty *emptypb.Empty) (*vmpb.GetLastStateSummaryResponse, error) + func (vm *VMServer) GetOngoingSyncStateSummary(context.Context, *emptypb.Empty) (*vmpb.GetOngoingSyncStateSummaryResponse, error) + func (vm *VMServer) GetStateSummary(ctx context.Context, req *vmpb.GetStateSummaryRequest) (*vmpb.GetStateSummaryResponse, error) + func (vm *VMServer) Health(ctx context.Context, req *emptypb.Empty) (*vmpb.HealthResponse, error) + func (vm *VMServer) Initialize(_ context.Context, req *vmpb.InitializeRequest) (*vmpb.InitializeResponse, error) + func (vm *VMServer) ParseBlock(_ context.Context, req *vmpb.ParseBlockRequest) (*vmpb.ParseBlockResponse, error) + func (vm *VMServer) ParseStateSummary(ctx context.Context, req *vmpb.ParseStateSummaryRequest) (*vmpb.ParseStateSummaryResponse, error) + func (vm *VMServer) SetPreference(_ context.Context, req *vmpb.SetPreferenceRequest) (*emptypb.Empty, error) + func (vm *VMServer) SetState(_ context.Context, stateReq *vmpb.SetStateRequest) (*vmpb.SetStateResponse, error) + func (vm *VMServer) Shutdown(context.Context, *emptypb.Empty) (*emptypb.Empty, error) + func (vm *VMServer) StateSummaryAccept(_ context.Context, req *vmpb.StateSummaryAcceptRequest) (*vmpb.StateSummaryAcceptResponse, error) + func (vm *VMServer) StateSyncEnabled(context.Context, *emptypb.Empty) (*vmpb.StateSyncEnabledResponse, error) + func (vm *VMServer) VerifyHeightIndex(context.Context, *emptypb.Empty) (*vmpb.VerifyHeightIndexResponse, error) + func (vm *VMServer) Version(context.Context, *emptypb.Empty) (*vmpb.VersionResponse, error)
Go to main page