rpcchainvm

package
v0.0.0-...-1d8d417 Latest Latest
Warning

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

 Go to latest Published: Feb 3, 2022 License: BSD-3-Clause Imports: 49 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Handshake = plugin.HandshakeConfig{
	ProtocolVersion:  9,
	MagicCookieKey:   "VM_PLUGIN",
	MagicCookieValue: "dynamic",
}

Handshake is a common handshake that is shared by plugin and host.

View Source 
var PluginMap = map[string]plugin.Plugin{
	"vm": &Plugin{},
}

PluginMap is the map of plugins we can dispense.

Functions

func RegisterPlugins 

func RegisterPlugins(pluginDir string, manager vms.Manager) error

RegisterPlugins iterates over a given plugin dir and registers rpcchain VMs for each of the discovered plugins.

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 struct {
	Path string
}

func (*Factory) New 

func (f *Factory) New(ctx *snow.Context) (interface{}, error)

type Plugin 

type Plugin struct {
	plugin.NetRPCUnsupportedPlugin
	// contains filtered or unexported fields
}

Plugin is the implementation of plugin.Plugin so we can serve/consume this. We also implement GRPCPlugin so that this plugin can be served over gRPC.

func New 

func New(vm block.ChainVM) *Plugin

New creates a new plugin from the provided VM

func (*Plugin) GRPCClient 

func (p *Plugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

GRPCClient returns a new GRPC client

func (*Plugin) GRPCServer 

func (p *Plugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

GRPCServer registers a new GRPC server.

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) Bootstrapped 

func (vm *VMClient) Bootstrapped() error

func (*VMClient) Bootstrapping 

func (vm *VMClient) Bootstrapping() 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) 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) Shutdown 

func (vm *VMClient) Shutdown() 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) Bootstrapped 

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

func (*VMServer) Bootstrapping 

func (vm *VMServer) Bootstrapping(context.Context, *emptypb.Empty) (*emptypb.Empty, 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) 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) Shutdown 

func (vm *VMServer) Shutdown(context.Context, *emptypb.Empty) (*emptypb.Empty, 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
gconn/gconnproto
ghttpproto
greadcloser
greadcloser/greadcloserproto
greader
greader/greaderproto
gresponsewriter
gresponsewriter/gresponsewriterproto
gwriter
gwriter/gwriterproto
gsubnetlookupproto
messengerproto

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.