rpcchainvm

package
v1.2.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 4, 2022 License: BSD-3-Clause Imports: 52 Imported by: 1

Documentation

Overview

Package rpcchainvm is a generated GoMock package.

Package rpcchainvm is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var (
	// Handshake is a common handshake that is shared by plugin and host.
	Handshake = plugin.HandshakeConfig{
		ProtocolVersion:  11,
		MagicCookieKey:   "VM_PLUGIN",
		MagicCookieValue: "dynamic",
	}

	// PluginMap is the map of plugins we can dispense.
	PluginMap = map[string]plugin.Plugin{
		"vm": &vmPlugin{},
	}
)

Functions

func New 

func New(vm block.ChainVM) plugin.Plugin

New will be called by the server side of the plugin to pass into the server side PluginMap for dispatching.

Types

type BlockClient 

type BlockClient struct {
	// contains filtered or unexported fields
}

BlockClient is an implementation of Block that talks over RPC.

func (*BlockClient) Accept 

func (b *BlockClient) Accept() error

func (*BlockClient) Bytes 

func (b *BlockClient) Bytes() []byte

func (*BlockClient) Height 

func (b *BlockClient) Height() uint64

func (*BlockClient) ID 

func (b *BlockClient) ID() ids.ID

func (*BlockClient) Parent 

func (b *BlockClient) Parent() ids.ID

func (*BlockClient) Reject 

func (b *BlockClient) Reject() error

func (*BlockClient) Status 

func (b *BlockClient) Status() choices.Status

func (*BlockClient) Timestamp 

func (b *BlockClient) Timestamp() time.Time

func (*BlockClient) Verify 

func (b *BlockClient) Verify() error

type Factory 

type Factory interface {
	// New returns an instance of a virtual machine.
	New(*snow.Context) (interface{}, error)
}

func NewFactory 

func NewFactory(path string) Factory

type MockFactory 

type MockFactory struct {
	// contains filtered or unexported fields
}

MockFactory is a mock of Factory interface.

func NewMockFactory 

func NewMockFactory(ctrl *gomock.Controller) *MockFactory

NewMockFactory creates a new mock instance.

func (*MockFactory) EXPECT 

func (m *MockFactory) EXPECT() *MockFactoryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockFactory) New 

func (m *MockFactory) New(arg0 *snow.Context) (interface{}, error)

New mocks base method.

type MockFactoryMockRecorder 

type MockFactoryMockRecorder struct {
	// contains filtered or unexported fields
}

MockFactoryMockRecorder is the mock recorder for MockFactory.

func (*MockFactoryMockRecorder) New 

func (mr *MockFactoryMockRecorder) New(arg0 interface{}) *gomock.Call

New indicates an expected call of New.

type MockPluginDirectory 

type MockPluginDirectory struct {
	// contains filtered or unexported fields
}

MockPluginDirectory is a mock of PluginDirectory interface.

func NewMockPluginDirectory 

func NewMockPluginDirectory(ctrl *gomock.Controller) *MockPluginDirectory

NewMockPluginDirectory creates a new mock instance.

func (*MockPluginDirectory) EXPECT 

func (m *MockPluginDirectory) EXPECT() *MockPluginDirectoryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPluginDirectory) GetVMs 

func (m *MockPluginDirectory) GetVMs(manager vms.Manager) (map[ids.ID]vms.Factory, map[ids.ID]vms.Factory, error)

GetVMs mocks base method.

type MockPluginDirectoryMockRecorder 

type MockPluginDirectoryMockRecorder struct {
	// contains filtered or unexported fields
}

MockPluginDirectoryMockRecorder is the mock recorder for MockPluginDirectory.

func (*MockPluginDirectoryMockRecorder) GetVMs 

func (mr *MockPluginDirectoryMockRecorder) GetVMs(manager interface{}) *gomock.Call

GetVMs indicates an expected call of GetVMs.

type VMClient 

type VMClient struct {
	*chain.State
	// contains filtered or unexported fields
}

VMClient is an implementation of VM that talks over RPC.

func NewClient 

func NewClient(client vmproto.VMClient, broker *plugin.GRPCBroker) *VMClient

NewClient returns a VM connected to a remote VM

func (*VMClient) AppGossip 

func (vm *VMClient) AppGossip(nodeID ids.ShortID, msg []byte) error

func (*VMClient) AppRequest 

func (vm *VMClient) AppRequest(nodeID ids.ShortID, requestID uint32, deadline time.Time, request []byte) error

func (*VMClient) AppRequestFailed 

func (vm *VMClient) AppRequestFailed(nodeID ids.ShortID, requestID uint32) error

func (*VMClient) AppResponse 

func (vm *VMClient) AppResponse(nodeID ids.ShortID, requestID uint32, response []byte) error

func (*VMClient) BatchedParseBlock 

func (vm *VMClient) BatchedParseBlock(blksBytes [][]byte) ([]snowman.Block, error)

func (*VMClient) Connected 

func (vm *VMClient) Connected(nodeID ids.ShortID, nodeVersion version.Application) error

func (*VMClient) CreateHandlers 

func (vm *VMClient) CreateHandlers() (map[string]*common.HTTPHandler, error)

func (*VMClient) CreateStaticHandlers 

func (vm *VMClient) CreateStaticHandlers() (map[string]*common.HTTPHandler, error)

func (*VMClient) Disconnected 

func (vm *VMClient) Disconnected(nodeID ids.ShortID) error

func (*VMClient) Gather 

func (vm *VMClient) Gather() ([]*dto.MetricFamily, error)

func (*VMClient) GetAncestors 

func (vm *VMClient) GetAncestors(
	blkID ids.ID,
	maxBlocksNum int,
	maxBlocksSize int,
	maxBlocksRetrivalTime time.Duration,
) ([][]byte, error)

func (*VMClient) GetBlockIDAtHeight 

func (vm *VMClient) GetBlockIDAtHeight(height uint64) (ids.ID, error)

func (*VMClient) HealthCheck 

func (vm *VMClient) HealthCheck() (interface{}, error)

func (*VMClient) Initialize 

func (vm *VMClient) Initialize(
	ctx *snow.Context,
	dbManager manager.Manager,
	genesisBytes []byte,
	upgradeBytes []byte,
	configBytes []byte,
	toEngine chan<- common.Message,
	fxs []*common.Fx,
	appSender common.AppSender,
) error

func (*VMClient) SetPreference 

func (vm *VMClient) SetPreference(id ids.ID) error

func (*VMClient) SetProcess 

func (vm *VMClient) SetProcess(proc *plugin.Client)

SetProcess gives ownership of the server process to the client.

func (*VMClient) SetState 

func (vm *VMClient) SetState(state snow.State) error

func (*VMClient) Shutdown 

func (vm *VMClient) Shutdown() error

func (*VMClient) VerifyHeightIndex 

func (vm *VMClient) VerifyHeightIndex() error

func (*VMClient) Version 

func (vm *VMClient) Version() (string, error)

type VMServer 

type VMServer struct {
	vmproto.UnimplementedVMServer
	// contains filtered or unexported fields
}

VMServer is a VM that is managed over RPC.

func NewServer 

func NewServer(vm block.ChainVM, broker *plugin.GRPCBroker) *VMServer

NewServer returns a vm instance connected to a remote vm instance

func (*VMServer) AppGossip 

func (vm *VMServer) AppGossip(_ context.Context, req *vmproto.AppGossipMsg) (*emptypb.Empty, error)

func (*VMServer) AppRequest 

func (vm *VMServer) AppRequest(_ context.Context, req *vmproto.AppRequestMsg) (*emptypb.Empty, error)

func (*VMServer) AppRequestFailed 

func (vm *VMServer) AppRequestFailed(_ context.Context, req *vmproto.AppRequestFailedMsg) (*emptypb.Empty, error)

func (*VMServer) AppResponse 

func (vm *VMServer) AppResponse(_ context.Context, req *vmproto.AppResponseMsg) (*emptypb.Empty, error)

func (*VMServer) BatchedParseBlock 

func (vm *VMServer) BatchedParseBlock(
	ctx context.Context,
	req *vmproto.BatchedParseBlockRequest,
) (*vmproto.BatchedParseBlockResponse, error)

func (*VMServer) BlockAccept 

func (vm *VMServer) BlockAccept(_ context.Context, req *vmproto.BlockAcceptRequest) (*emptypb.Empty, error)

func (*VMServer) BlockReject 

func (vm *VMServer) BlockReject(_ context.Context, req *vmproto.BlockRejectRequest) (*emptypb.Empty, error)

func (*VMServer) BlockVerify 

func (vm *VMServer) BlockVerify(_ context.Context, req *vmproto.BlockVerifyRequest) (*vmproto.BlockVerifyResponse, error)

func (*VMServer) BuildBlock 

func (vm *VMServer) BuildBlock(context.Context, *emptypb.Empty) (*vmproto.BuildBlockResponse, error)

func (*VMServer) Connected 

func (vm *VMServer) Connected(_ context.Context, req *vmproto.ConnectedRequest) (*emptypb.Empty, error)

func (*VMServer) CreateHandlers 

func (vm *VMServer) CreateHandlers(context.Context, *emptypb.Empty) (*vmproto.CreateHandlersResponse, error)

func (*VMServer) CreateStaticHandlers 

func (vm *VMServer) CreateStaticHandlers(context.Context, *emptypb.Empty) (*vmproto.CreateStaticHandlersResponse, error)

func (*VMServer) Disconnected 

func (vm *VMServer) Disconnected(_ context.Context, req *vmproto.DisconnectedRequest) (*emptypb.Empty, error)

func (*VMServer) Gather 

func (vm *VMServer) Gather(context.Context, *emptypb.Empty) (*vmproto.GatherResponse, error)

func (*VMServer) GetAncestors 

func (vm *VMServer) GetAncestors(_ context.Context, req *vmproto.GetAncestorsRequest) (*vmproto.GetAncestorsResponse, error)

func (*VMServer) GetBlock 

func (vm *VMServer) GetBlock(_ context.Context, req *vmproto.GetBlockRequest) (*vmproto.GetBlockResponse, error)

func (*VMServer) GetBlockIDAtHeight 

func (vm *VMServer) GetBlockIDAtHeight(ctx context.Context, req *vmproto.GetBlockIDAtHeightRequest) (*vmproto.GetBlockIDAtHeightResponse, error)

func (*VMServer) Health 

func (vm *VMServer) Health(context.Context, *emptypb.Empty) (*vmproto.HealthResponse, error)

func (*VMServer) Initialize 

func (vm *VMServer) Initialize(_ context.Context, req *vmproto.InitializeRequest) (*vmproto.InitializeResponse, error)

func (*VMServer) ParseBlock 

func (vm *VMServer) ParseBlock(_ context.Context, req *vmproto.ParseBlockRequest) (*vmproto.ParseBlockResponse, error)

func (*VMServer) SetPreference 

func (vm *VMServer) SetPreference(_ context.Context, req *vmproto.SetPreferenceRequest) (*emptypb.Empty, error)

func (*VMServer) SetState 

func (vm *VMServer) SetState(_ context.Context, stateReq *vmproto.SetStateRequest) (*emptypb.Empty, error)

func (*VMServer) Shutdown 

func (vm *VMServer) Shutdown(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (*VMServer) VerifyHeightIndex 

func (vm *VMServer) VerifyHeightIndex(context.Context, *emptypb.Empty) (*vmproto.VerifyHeightIndexResponse, error)

func (*VMServer) Version 

func (vm *VMServer) Version(context.Context, *emptypb.Empty) (*vmproto.VersionResponse, error)

Source Files

View all Source files

Directories

Path Synopsis
gconn
greader
gresponsewriter
gwriter

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.