zap

package

Go to main page

Versions in this module

v1

v1.1.14

Aug 30, 2026

v1.1.13

Aug 30, 2026

v1.1.12

Aug 29, 2026

v1.1.11

Aug 29, 2026

v1.1.10

Aug 28, 2026

v1.1.9

Aug 21, 2026

Changes in this version

type MessageType

+ const MsgValidatorState

v1.1.8

Aug 21, 2026

Changes in this version

type MessageType

+ const MsgCurrentHeight

+ const MsgCurrentValidators

+ const MsgMinimumHeight

+ const MsgValidatorChainID

+ const MsgValidatorNetworkID

+ const MsgValidatorSet

+ const MsgWarpValidatorSet

+ const MsgWarpValidatorSetsAll

v1.1.7

Aug 21, 2026

Changes in this version

type InitializeRequest

+ ValidatorServerAddr string

v1.1.6

Aug 16, 2026

Changes in this version

+ const CapStateSync

v1.1.5

Aug 16, 2026

Changes in this version

+ type GetStateSummaryRequest struct

+ Height uint64

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

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

+ type ParseStateSummaryRequest struct

+ Bytes []byte

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

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

+ type StateSummaryAcceptRequest struct

+ ID []byte

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

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

+ type StateSummaryAcceptResponse struct

+ Err Error

+ Mode uint8

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

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

+ type StateSyncEnabledResponse struct

+ Enabled bool

+ Err Error

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

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

+ type SummaryResponse struct

+ Bytes []byte

+ Err Error

+ Height uint64

+ ID []byte

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

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

v1.1.4

Aug 16, 2026

Changes in this version

type Error

+ const ErrorInternal

v1.1.3

Aug 6, 2026

Changes in this version

+ type AtomicApplyRequest struct

+ Requests []*AtomicChainRequests

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

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

+ type AtomicChainRequests struct

+ PeerChainID []byte

+ PutRequests []*AtomicElement

+ RemoveRequests [][]byte

+ type AtomicElement struct

+ Key []byte

+ Traits [][]byte

+ Value []byte

+ type AtomicGetRequest struct

+ Keys [][]byte

+ PeerChainID []byte

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

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

+ type AtomicGetResponse struct

+ Values [][]byte

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

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

+ type AtomicIndexedRequest struct

+ Limit uint32

+ PeerChainID []byte

+ StartKey []byte

+ StartTrait []byte

+ Traits [][]byte

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

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

+ type AtomicIndexedResponse struct

+ LastKey []byte

+ LastTrait []byte

+ Values [][]byte

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

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

type InitializeRequest

+ AtomicServerAddr string

+ DChainID []byte

type MessageType

+ const MsgAtomicApply

+ const MsgAtomicGet

+ const MsgAtomicIndexed

v1.1.2

Jul 16, 2026

v1.1.1

Jul 15, 2026

v1.1.0

Jun 30, 2026

v1.0.16

Jul 10, 2026

Changes in this version

+ const CapQuasarExport

type InitializeResponse

+ Capabilities uint64

type MessageType

+ const MsgQuasarHeight

+ const MsgSetQuasarFinalized

+ type QuasarHeightResponse struct

+ Height uint64

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

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

+ type SetQuasarFinalizedRequest struct

+ Height uint64

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

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

v1.0.15

Jun 7, 2026

v1.0.14

Jun 7, 2026

Changes in this version

type InitializeRequest

+ UTXOAssetID []byte

type Reader

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

v1.0.13

Jun 7, 2026

v1.0.12

May 19, 2026

v1.0.11

May 16, 2026

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