zap

package

Go to main page

Versions in this module

v1

v1.0.10

May 6, 2026

Changes in this version

type Listener

+ func NewListener(raw net.Listener, config *Config) *Listener

v1.0.9

May 6, 2026

v1.0.8

May 6, 2026

v1.0.7

May 6, 2026

v1.0.6

May 6, 2026

Changes in this version

type MessageType

+ const MsgErrorFlag

v1.0.5

May 5, 2026

v1.0.4

Mar 11, 2026

Changes in this version

+ const DefaultBufferSize

+ const HeaderSize

+ const MaxMessageSize

+ var BufferPool = sync.Pool

+ var ErrClosed = errors.New("zap: connection closed")

+ var ErrInvalidMessage = errors.New("zap: invalid message format")

+ var ErrMessageTooLarge = errors.New("zap: message exceeds maximum size")

+ var ErrResponseFailed = errors.New("zap: response failed")

+ var ErrTimeout = errors.New("zap: request timeout")

+ var ErrUnknownType = errors.New("zap: unknown message type")

+ func PutBuffer(buf *Buffer)

+ func WriteMessage(w io.Writer, msgType MessageType, payload []byte) error

+ type BatchedParseBlockRequest struct

+ Requests [][]byte

+ func (m *BatchedParseBlockRequest) Decode(r *Reader) error

+ func (m *BatchedParseBlockRequest) Encode(buf *Buffer)

+ type BatchedParseBlockResponse struct

+ Responses []BlockResponse

+ func (m *BatchedParseBlockResponse) Decode(r *Reader) error

+ func (m *BatchedParseBlockResponse) Encode(buf *Buffer)

+ type BlockAcceptRequest struct

+ ID []byte

+ func (m *BlockAcceptRequest) Decode(r *Reader) error

+ func (m *BlockAcceptRequest) Encode(buf *Buffer)

+ type BlockRejectRequest struct

+ ID []byte

+ func (m *BlockRejectRequest) Decode(r *Reader) error

+ func (m *BlockRejectRequest) Encode(buf *Buffer)

+ type BlockResponse struct

+ Bytes []byte

+ Err Error

+ Height uint64

+ ID []byte

+ ParentID []byte

+ Timestamp int64

+ VerifyWithContext bool

+ func (m *BlockResponse) Decode(r *Reader) error

+ func (m *BlockResponse) Encode(buf *Buffer)

+ type BlockVerifyRequest struct

+ Bytes []byte

+ HasPChainHeight bool

+ PChainHeight uint64

+ func (m *BlockVerifyRequest) Decode(r *Reader) error

+ func (m *BlockVerifyRequest) Encode(buf *Buffer)

+ type BlockVerifyResponse struct

+ Timestamp int64

+ func (m *BlockVerifyResponse) Decode(r *Reader) error

+ func (m *BlockVerifyResponse) Encode(buf *Buffer)

+ type Buffer struct

+ Data []byte

+ func GetBuffer() *Buffer

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

+ func (b *Buffer) Grow(n int)

+ func (b *Buffer) Len() int

+ func (b *Buffer) Reset()

+ func (b *Buffer) WriteBool(v bool)

+ func (b *Buffer) WriteBytes(data []byte)

+ func (b *Buffer) WriteInt32(v int32)

+ func (b *Buffer) WriteInt64(v int64)

+ func (b *Buffer) WriteString(s string)

+ func (b *Buffer) WriteUint16(v uint16)

+ func (b *Buffer) WriteUint32(v uint32)

+ func (b *Buffer) WriteUint64(v uint64)

+ func (b *Buffer) WriteUint8(v uint8)

+ type BuildBlockRequest struct

+ HasPChainHeight bool

+ PChainHeight uint64

+ func (m *BuildBlockRequest) Decode(r *Reader) error

+ func (m *BuildBlockRequest) Encode(buf *Buffer)

+ type Config struct

+ BufferSize int

+ MaxConcurrent int

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ func DefaultConfig() *Config

+ type Conn struct

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

+ func NewConn(conn net.Conn, config *Config) *Conn

+ func (c *Conn) Call(ctx context.Context, msgType MessageType, payload []byte) (MessageType, []byte, error)

+ func (c *Conn) Close() error

+ func (c *Conn) Send(msgType MessageType, payload []byte) error

+ type ConnectedRequest struct

+ Major uint32

+ Minor uint32

+ Name string

+ NodeID []byte

+ Patch uint32

+ func (m *ConnectedRequest) Decode(r *Reader) error

+ func (m *ConnectedRequest) Encode(buf *Buffer)

+ type CreateHandlersResponse struct

+ Handlers []HTTPHandler

+ func (m *CreateHandlersResponse) Decode(r *Reader) error

+ func (m *CreateHandlersResponse) Encode(buf *Buffer)

+ type DisconnectedRequest struct

+ NodeID []byte

+ func (m *DisconnectedRequest) Decode(r *Reader) error

+ func (m *DisconnectedRequest) Encode(buf *Buffer)

+ type Error uint8

+ const ErrorClosed

+ const ErrorNotFound

+ const ErrorStateSyncNotImplemented

+ const ErrorUnspecified

+ type GetAncestorsRequest struct

+ BlkID []byte

+ MaxBlocksNum int32

+ MaxBlocksRetrivalTime int64

+ MaxBlocksSize int32

+ func (m *GetAncestorsRequest) Decode(r *Reader) error

+ func (m *GetAncestorsRequest) Encode(buf *Buffer)

+ type GetAncestorsResponse struct

+ BlksBytes [][]byte

+ func (m *GetAncestorsResponse) Decode(r *Reader) error

+ func (m *GetAncestorsResponse) Encode(buf *Buffer)

+ type GetBlockIDAtHeightRequest struct

+ Height uint64

+ func (m *GetBlockIDAtHeightRequest) Decode(r *Reader) error

+ func (m *GetBlockIDAtHeightRequest) Encode(buf *Buffer)

+ type GetBlockIDAtHeightResponse struct

+ BlkID []byte

+ Err Error

+ func (m *GetBlockIDAtHeightResponse) Decode(r *Reader) error

+ func (m *GetBlockIDAtHeightResponse) Encode(buf *Buffer)

+ type GetBlockRequest struct

+ ID []byte

+ func (m *GetBlockRequest) Decode(r *Reader) error

+ func (m *GetBlockRequest) Encode(buf *Buffer)

+ type GossipMsg struct

+ Msg []byte

+ NodeID []byte

+ func (m *GossipMsg) Decode(r *Reader) error

+ func (m *GossipMsg) Encode(buf *Buffer)

+ type HTTPHandler struct

+ Prefix string

+ ServerAddr string

+ func (m *HTTPHandler) Decode(r *Reader) error

+ func (m *HTTPHandler) Encode(buf *Buffer)

+ type Handler interface

+ Handle func(ctx context.Context, msgType MessageType, payload []byte) (MessageType, []byte, error)

+ type HandlerFunc func(ctx context.Context, msgType MessageType, payload []byte) (MessageType, []byte, error)

+ func (f HandlerFunc) Handle(ctx context.Context, msgType MessageType, payload []byte) (MessageType, []byte, error)

+ type HealthResponse struct

+ Details []byte

+ func (m *HealthResponse) Decode(r *Reader) error

+ func (m *HealthResponse) Encode(buf *Buffer)

+ type InitializeRequest struct

+ CChainID []byte

+ ChainDataDir string

+ ChainID []byte

+ ConfigBytes []byte

+ DBServerAddr string

+ GenesisBytes []byte

+ LuxAssetID []byte

+ NetworkID uint32

+ NetworkUpgrades NetworkUpgrades

+ NodeID []byte

+ PublicKey []byte

+ ServerAddr string

+ UpgradeBytes []byte

+ XChainID []byte

+ func (m *InitializeRequest) Decode(r *Reader) error

+ func (m *InitializeRequest) Encode(buf *Buffer)

+ type InitializeResponse struct

+ Bytes []byte

+ Height uint64

+ LastAcceptedID []byte

+ LastAcceptedParentID []byte

+ Timestamp int64

+ func (m *InitializeResponse) Decode(r *Reader) error

+ func (m *InitializeResponse) Encode(buf *Buffer)

+ type Listener struct

+ func Listen(addr string, config *Config) (*Listener, error)

+ func (l *Listener) Accept() (*ServerConn, error)

+ func (l *Listener) Addr() net.Addr

+ func (l *Listener) Close() error

+ type MessageType uint8

+ const MsgBatchedParseBlock

+ const MsgBlockAccept

+ const MsgBlockReject

+ const MsgBlockVerify

+ const MsgBuildBlock

+ const MsgConnected

+ const MsgCreateHandlers

+ const MsgDisconnected

+ const MsgGather

+ const MsgGetAncestors

+ const MsgGetBlock

+ const MsgGetBlockIDAtHeight

+ const MsgGetLastStateSummary

+ const MsgGetOngoingSyncStateSummary

+ const MsgGetStateSummary

+ const MsgGossip

+ const MsgHealth

+ const MsgInitialize

+ const MsgNewHTTPHandler

+ const MsgParseBlock

+ const MsgParseStateSummary

+ const MsgRequest

+ const MsgRequestFailed

+ const MsgResponse

+ const MsgResponseFlag

+ const MsgSendError

+ const MsgSendGossip

+ const MsgSendRequest

+ const MsgSendResponse

+ const MsgSetPreference

+ const MsgSetState

+ const MsgShutdown

+ const MsgStateSummaryAccept

+ const MsgStateSyncEnabled

+ const MsgVersion

+ const MsgWaitForEvent

+ const MsgWarpBatchSign

+ const MsgWarpGetPublicKey

+ const MsgWarpSign

+ func ReadMessage(r io.Reader) (MessageType, []byte, error)

+ type NetworkUpgrades struct

+ ApricotPhase1Time int64

+ ApricotPhase2Time int64

+ ApricotPhase3Time int64

+ ApricotPhase4MinPChainHeight uint64

+ ApricotPhase4Time int64

+ ApricotPhase5Time int64

+ ApricotPhase6Time int64

+ ApricotPhasePost6Time int64

+ ApricotPhasePre6Time int64

+ BanffTime int64

+ CortinaTime int64

+ CortinaXChainStopVertexID []byte

+ DurangoTime int64

+ EtnaTime int64

+ FortunaTime int64

+ GraniteTime int64

+ func (n *NetworkUpgrades) Decode(r *Reader) error

+ func (n *NetworkUpgrades) Encode(buf *Buffer)

+ type NewHTTPHandlerResponse struct

+ ServerAddr string

+ func (m *NewHTTPHandlerResponse) Decode(r *Reader) error

+ func (m *NewHTTPHandlerResponse) Encode(buf *Buffer)

+ type ParseBlockRequest struct

+ Bytes []byte

+ func (m *ParseBlockRequest) Decode(r *Reader) error

+ func (m *ParseBlockRequest) Encode(buf *Buffer)

+ type Reader struct

+ func NewReader(data []byte) *Reader

+ func (r *Reader) ReadBool() (bool, error)

+ func (r *Reader) ReadBytes() ([]byte, error)

+ func (r *Reader) ReadInt32() (int32, error)

+ func (r *Reader) ReadInt64() (int64, error)

+ func (r *Reader) ReadString() (string, error)

+ func (r *Reader) ReadUint16() (uint16, error)

+ func (r *Reader) ReadUint32() (uint32, error)

+ func (r *Reader) ReadUint64() (uint64, error)

+ func (r *Reader) ReadUint8() (uint8, error)

+ func (r *Reader) Remaining() int

+ type RequestFailedMsg struct

+ ErrorCode int32

+ ErrorMessage string

+ NodeID []byte

+ RequestID uint32

+ func (m *RequestFailedMsg) Decode(r *Reader) error

+ func (m *RequestFailedMsg) Encode(buf *Buffer)

+ type RequestMsg struct

+ Deadline int64

+ NodeID []byte

+ Request []byte

+ RequestID uint32

+ func (m *RequestMsg) Decode(r *Reader) error

+ func (m *RequestMsg) Encode(buf *Buffer)

+ type ResponseMsg struct

+ NodeID []byte

+ RequestID uint32

+ Response []byte

+ func (m *ResponseMsg) Decode(r *Reader) error

+ func (m *ResponseMsg) Encode(buf *Buffer)

+ type SendErrorMsg struct

+ ErrorCode int32

+ ErrorMessage string

+ NodeID []byte

+ RequestID uint32

+ func (m *SendErrorMsg) Decode(r *Reader) error

+ func (m *SendErrorMsg) Encode(buf *Buffer)

+ type SendGossipMsg struct

+ Msg []byte

+ NodeIDs [][]byte

+ NonValidators uint64

+ Peers uint64

+ Validators uint64

+ func (m *SendGossipMsg) Decode(r *Reader) error

+ func (m *SendGossipMsg) Encode(buf *Buffer)

+ type SendRequestMsg struct

+ NodeIDs [][]byte

+ Request []byte

+ RequestID uint32

+ func (m *SendRequestMsg) Decode(r *Reader) error

+ func (m *SendRequestMsg) Encode(buf *Buffer)

+ type SendResponseMsg struct

+ NodeID []byte

+ RequestID uint32

+ Response []byte

+ func (m *SendResponseMsg) Decode(r *Reader) error

+ func (m *SendResponseMsg) Encode(buf *Buffer)

+ type Server struct

+ func NewServer(listener *Listener, handler Handler) *Server

+ func (s *Server) Close() error

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

+ type ServerConn struct

+ func (c *ServerConn) Close() error

+ func (c *ServerConn) Read() (uint32, MessageType, []byte, error)

+ func (c *ServerConn) RemoteAddr() net.Addr

+ func (c *ServerConn) Write(reqID uint32, msgType MessageType, payload []byte) error

+ type SetPreferenceRequest struct

+ ID []byte

+ func (m *SetPreferenceRequest) Decode(r *Reader) error

+ func (m *SetPreferenceRequest) Encode(buf *Buffer)

+ type SetStateRequest struct

+ State State

+ func (m *SetStateRequest) Decode(r *Reader) error

+ func (m *SetStateRequest) Encode(buf *Buffer)

+ type SetStateResponse struct

+ Bytes []byte

+ Height uint64

+ LastAcceptedID []byte

+ LastAcceptedParentID []byte

+ Timestamp int64

+ func (m *SetStateResponse) Decode(r *Reader) error

+ func (m *SetStateResponse) Encode(buf *Buffer)

+ type State uint8

+ const StateBootstrapping

+ const StateDegraded

+ const StateReady

+ const StateStarting

+ const StateStopped

+ const StateStopping

+ const StateSyncing

+ const StateUnknown

+ type VersionResponse struct

+ Version string

+ func (m *VersionResponse) Decode(r *Reader) error

+ func (m *VersionResponse) Encode(buf *Buffer)

+ type WaitForEventResponse struct

+ Message uint8

+ func (m *WaitForEventResponse) Decode(r *Reader) error

+ func (m *WaitForEventResponse) Encode(buf *Buffer)

+ type WarpBatchSignRequest struct

+ Messages []WarpSignRequest

+ func (r *WarpBatchSignRequest) Decode(rd *Reader) error

+ func (r *WarpBatchSignRequest) Encode(buf *Buffer)

+ type WarpBatchSignResponse struct

+ Errors []string

+ Signatures [][]byte

+ func (r *WarpBatchSignResponse) Decode(rd *Reader) error

+ func (r *WarpBatchSignResponse) Encode(buf *Buffer)

+ type WarpGetPublicKeyRequest struct

+ func (r *WarpGetPublicKeyRequest) Decode(rd *Reader) error

+ func (r *WarpGetPublicKeyRequest) Encode(buf *Buffer)

+ type WarpGetPublicKeyResponse struct

+ Error string

+ PublicKey []byte

+ func (r *WarpGetPublicKeyResponse) Decode(rd *Reader) error

+ func (r *WarpGetPublicKeyResponse) Encode(buf *Buffer)

+ type WarpSignRequest struct

+ NetworkID uint32

+ Payload []byte

+ SourceChainID []byte

+ func (r *WarpSignRequest) Decode(rd *Reader) error

+ func (r *WarpSignRequest) Encode(buf *Buffer)

+ type WarpSignResponse struct

+ Error string

+ Signature []byte

+ func (r *WarpSignResponse) Decode(rd *Reader) error

+ func (r *WarpSignResponse) Encode(buf *Buffer)

v1.0.3

Feb 11, 2026

v1.0.2

Feb 11, 2026

v1.0.1

Jan 24, 2026

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