Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rpcchainvm

package

Go to main page

Versions in this module

v1

v1.9.8

Jun 28, 2023

Changes in this version

+ func NewFactory(path string, processTracker resource.ProcessTracker) vms.Factory

+ func Serve(vm block.ChainVM)

type VMClient

+ func (vm *VMClient) AppGossip(ctx context.Context, nodeID ids.NodeID, msg []byte) error

+ func (vm *VMClient) AppRequest(ctx context.Context, nodeID ids.NodeID, requestID uint32, deadline time.Time, ...) error

+ func (vm *VMClient) AppRequestFailed(ctx context.Context, nodeID ids.NodeID, requestID uint32) error

+ func (vm *VMClient) AppResponse(ctx context.Context, nodeID ids.NodeID, requestID uint32, response []byte) error

+ func (vm *VMClient) Connected(ctx context.Context, nodeID ids.NodeID, nodeVersion *version.Application) error

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

+ func (vm *VMClient) CrossChainAppRequest(ctx context.Context, chainID ids.ID, requestID uint32, deadline time.Time, ...) error

+ func (vm *VMClient) CrossChainAppRequestFailed(ctx context.Context, chainID ids.ID, requestID uint32) error

+ func (vm *VMClient) CrossChainAppResponse(ctx context.Context, chainID ids.ID, requestID uint32, response []byte) error

+ func (vm *VMClient) Disconnected(ctx context.Context, nodeID ids.NodeID) error

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

+ func (vm *VMClient) GetAncestors(ctx context.Context, blkID ids.ID, maxBlocksNum int, maxBlocksSize int, ...) ([][]byte, error)

+ func (vm *VMClient) GetBlockIDAtHeight(ctx context.Context, height uint64) (ids.ID, error)

+ func (vm *VMClient) GetLastStateSummary(ctx context.Context) (block.StateSummary, error)

+ func (vm *VMClient) GetOngoingSyncStateSummary(ctx context.Context) (block.StateSummary, error)

+ func (vm *VMClient) GetStateSummary(ctx context.Context, summaryHeight uint64) (block.StateSummary, error)

+ func (vm *VMClient) HealthCheck(ctx context.Context) (interface{}, error)

+ func (vm *VMClient) ParseStateSummary(ctx context.Context, summaryBytes []byte) (block.StateSummary, error)

+ func (vm *VMClient) SetState(ctx context.Context, state snow.State) error

+ func (vm *VMClient) StateSyncEnabled(ctx context.Context) (bool, error)

+ func (vm *VMClient) VerifyHeightIndex(ctx context.Context) error

+ func (vm *VMClient) Version(ctx context.Context) (string, error)

type VMServer

+ func (vm *VMServer) AppGossip(ctx context.Context, req *vmpb.AppGossipMsg) (*emptypb.Empty, error)

+ func (vm *VMServer) AppRequest(ctx context.Context, req *vmpb.AppRequestMsg) (*emptypb.Empty, error)

+ func (vm *VMServer) AppRequestFailed(ctx context.Context, req *vmpb.AppRequestFailedMsg) (*emptypb.Empty, error)

+ func (vm *VMServer) AppResponse(ctx context.Context, req *vmpb.AppResponseMsg) (*emptypb.Empty, error)

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

+ func (vm *VMServer) Connected(ctx context.Context, req *vmpb.ConnectedRequest) (*emptypb.Empty, error)

+ func (vm *VMServer) CreateStaticHandlers(ctx context.Context, _ *emptypb.Empty) (*vmpb.CreateStaticHandlersResponse, error)

+ func (vm *VMServer) CrossChainAppRequest(ctx context.Context, msg *vmpb.CrossChainAppRequestMsg) (*emptypb.Empty, error)

+ func (vm *VMServer) CrossChainAppRequestFailed(ctx context.Context, msg *vmpb.CrossChainAppRequestFailedMsg) (*emptypb.Empty, error)

+ func (vm *VMServer) CrossChainAppResponse(ctx context.Context, msg *vmpb.CrossChainAppResponseMsg) (*emptypb.Empty, error)

+ func (vm *VMServer) Disconnected(ctx context.Context, req *vmpb.DisconnectedRequest) (*emptypb.Empty, error)

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

+ func (vm *VMServer) GetAncestors(ctx context.Context, req *vmpb.GetAncestorsRequest) (*vmpb.GetAncestorsResponse, error)

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

+ func (vm *VMServer) GetLastStateSummary(ctx context.Context, _ *emptypb.Empty) (*vmpb.GetLastStateSummaryResponse, error)

+ func (vm *VMServer) GetOngoingSyncStateSummary(ctx 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, _ *emptypb.Empty) (*vmpb.HealthResponse, error)

+ func (vm *VMServer) ParseStateSummary(ctx context.Context, req *vmpb.ParseStateSummaryRequest) (*vmpb.ParseStateSummaryResponse, error)

+ func (vm *VMServer) SetState(ctx context.Context, stateReq *vmpb.SetStateRequest) (*vmpb.SetStateResponse, error)

+ func (vm *VMServer) StateSummaryAccept(ctx context.Context, req *vmpb.StateSummaryAcceptRequest) (*vmpb.StateSummaryAcceptResponse, error)

+ func (vm *VMServer) StateSyncEnabled(ctx context.Context, _ *emptypb.Empty) (*vmpb.StateSyncEnabledResponse, error)

+ func (vm *VMServer) VerifyHeightIndex(ctx context.Context, _ *emptypb.Empty) (*vmpb.VerifyHeightIndexResponse, error)

+ func (vm *VMServer) Version(ctx context.Context, _ *emptypb.Empty) (*vmpb.VersionResponse, error)

v1.9.8-rc.9

Jun 28, 2023

v0

v0.1.0

Apr 19, 2020

Changes in this version

+ var Handshake = plugin.HandshakeConfig

+ var PluginMap = map[string]plugin.Plugin

+ type BlockClient struct

+ func (b *BlockClient) Accept()

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

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

+ func (b *BlockClient) Parent() snowman.Block

+ func (b *BlockClient) Reject()

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

+ func (b *BlockClient) Verify() error

+ type Factory struct

+ Path string

+ func (f *Factory) New() (interface{}, error)

+ type Plugin struct

+ func New(vm snowman.ChainVM) *Plugin

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

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

+ type VMClient struct

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

+ func (vm *VMClient) BuildBlock() (snowman.Block, error)

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

+ func (vm *VMClient) GetBlock(id ids.ID) (snowman.Block, error)

+ func (vm *VMClient) Initialize(ctx *snow.Context, db database.Database, genesisBytes []byte, ...) error

+ func (vm *VMClient) LastAccepted() ids.ID

+ func (vm *VMClient) ParseBlock(bytes []byte) (snowman.Block, error)

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

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

+ func (vm *VMClient) Shutdown()

+ type VMServer struct

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

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

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

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

+ func (vm *VMServer) BuildBlock(_ context.Context, _ *vmproto.BuildBlockRequest) (*vmproto.BuildBlockResponse, error)

+ func (vm *VMServer) CreateHandlers(_ context.Context, req *vmproto.CreateHandlersRequest) (*vmproto.CreateHandlersResponse, error)

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

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

+ func (vm *VMServer) LastAccepted(_ context.Context, _ *vmproto.LastAcceptedRequest) (*vmproto.LastAcceptedResponse, error)

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

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

+ func (vm *VMServer) Shutdown(_ context.Context, _ *vmproto.ShutdownRequest) (*vmproto.ShutdownResponse, error)