The highest tagged major version is v2.

zap

package

v1.23.2 Latest Latest Go to latest Published: Jan 26, 2026 License: BSD-3-Clause Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/luxfi/node

Links

Open Source Insights

Documentation ¶

Overview ¶

Package zap provides ZAP transport implementation for VM RPC.

Index ¶

Variables
func Dial(ctx context.Context, addr string, config *zapwire.Config) (*zapwire.Conn, error)
func NewListener() (net.Listener, error)
type Client
- func NewClient(conn *zapwire.Conn, logger log.Logger) *Client
type Sender
- func NewSender(conn *zapwire.Conn) *Sender
type Server
- func NewServer(v vm.VM, logger log.Logger) *Server

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrNotConnected    = errors.New("zap: not connected")
	ErrInvalidResponse = errors.New("zap: invalid response")
)

Functions ¶

func Dial ¶

func Dial(ctx context.Context, addr string, config *zapwire.Config) (*zapwire.Conn, error)

Dial connects to a ZAP VM server

func NewListener ¶

func NewListener() (net.Listener, error)

NewListener creates a new TCP listener on an available port. This is used for the ZAP handshake during VM subprocess bootstrap.

Types ¶

type Client ¶

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

Client implements vm.VM over ZAP transport

func NewClient ¶

func NewClient(conn *zapwire.Conn, logger log.Logger) *Client

NewClient creates a new ZAP-based VM client

func (*Client) Close ¶

func (c *Client) Close() error

Close closes the connection

func (*Client) GetBlock ¶

func (c *Client) GetBlock(ctx context.Context, blkID ids.ID) (vm.Block, error)

GetBlock implements vm.VM

func (*Client) Initialize ¶

func (c *Client) Initialize(ctx context.Context, init vm.Init) error

Initialize implements vm.VM

func (*Client) LastAccepted ¶

func (c *Client) LastAccepted(ctx context.Context) (ids.ID, error)

LastAccepted implements vm.VM

func (*Client) ParseBlock ¶

func (c *Client) ParseBlock(ctx context.Context, blockBytes []byte) (vm.Block, error)

ParseBlock implements vm.VM

func (*Client) SetPreference ¶

func (c *Client) SetPreference(ctx context.Context, blkID ids.ID) error

SetPreference implements vm.VM

func (*Client) Shutdown ¶

func (c *Client) Shutdown(ctx context.Context) error

Shutdown implements vm.VM

type Sender ¶

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

Sender implements p2p.Sender over ZAP transport

func NewSender ¶

func NewSender(conn *zapwire.Conn) *Sender

NewSender creates a new ZAP-based p2p.Sender

func (*Sender) SendError ¶

func (s *Sender) SendError(ctx context.Context, nodeID ids.NodeID, requestID uint32, errorCode int32, errorMessage string) error

SendError sends an error response to a previous request

func (*Sender) SendGossip ¶

func (s *Sender) SendGossip(ctx context.Context, config p2p.SendConfig, msg []byte) error

SendGossip sends a gossip message

func (*Sender) SendRequest ¶

func (s *Sender) SendRequest(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, request []byte) error

SendRequest sends a request to the specified nodes

func (*Sender) SendResponse ¶

func (s *Sender) SendResponse(ctx context.Context, nodeID ids.NodeID, requestID uint32, response []byte) error

SendResponse sends a response to a previous request

type Server ¶

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

Server wraps a VM and serves it over ZAP transport

func NewServer ¶

func NewServer(v vm.VM, logger log.Logger) *Server

NewServer creates a new ZAP server for a VM

func (*Server) Addr ¶

func (s *Server) Addr() net.Addr

Addr returns the listener's address

func (*Server) Close ¶

func (s *Server) Close() error

Close closes the server

func (*Server) Listen ¶

func (s *Server) Listen(addr string, config *zapwire.Config) error

Listen starts listening on the specified address

func (*Server) Serve ¶

func (s *Server) Serve(ctx context.Context) error

Serve starts serving requests

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL