pb

package
v0.3.27 Latest Latest
Warning

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

Go to latest
Published: Jul 13, 2025 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

Functions

func DRPCRegisterSync

func DRPCRegisterSync(mux drpc.Mux, impl DRPCSyncServer) error

Types

type DRPCSyncClient

func NewDRPCSyncClient

func NewDRPCSyncClient(cc drpc.Conn) DRPCSyncClient

type DRPCSyncDescription

type DRPCSyncDescription struct{}

func (DRPCSyncDescription) Method

func (DRPCSyncDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCSyncDescription) NumMethods

func (DRPCSyncDescription) NumMethods() int

type DRPCSyncUnimplementedServer

type DRPCSyncUnimplementedServer struct{}

func (*DRPCSyncUnimplementedServer) GetBlockByID

func (*DRPCSyncUnimplementedServer) GetBlockIDByNumber

func (*DRPCSyncUnimplementedServer) GetBlocksFromNumber

func (*DRPCSyncUnimplementedServer) GetStatus

func (*DRPCSyncUnimplementedServer) NotifyBlock

func (*DRPCSyncUnimplementedServer) NotifyBlockID

func (*DRPCSyncUnimplementedServer) NotifyTx

type DRPCSync_GetBlockByIDStream

type DRPCSync_GetBlockByIDStream interface {
	drpc.Stream
	SendAndClose(*GetBlockByIDResponse) error
}

type DRPCSync_GetBlockIDByNumberStream

type DRPCSync_GetBlockIDByNumberStream interface {
	drpc.Stream
	SendAndClose(*GetBlockIDByNumberResponse) error
}

type DRPCSync_GetBlocksFromNumberStream

type DRPCSync_GetBlocksFromNumberStream interface {
	drpc.Stream
	SendAndClose(*GetBlocksFromNumberResponse) error
}

type DRPCSync_GetStatusStream

type DRPCSync_GetStatusStream interface {
	drpc.Stream
	SendAndClose(*GetStatusResponse) error
}

type DRPCSync_NotifyBlockIDStream

type DRPCSync_NotifyBlockIDStream interface {
	drpc.Stream
	SendAndClose(*NotifyBlockIDResponse) error
}

type DRPCSync_NotifyBlockStream

type DRPCSync_NotifyBlockStream interface {
	drpc.Stream
	SendAndClose(*NotifyBlockResponse) error
}

type DRPCSync_NotifyTxStream

type DRPCSync_NotifyTxStream interface {
	drpc.Stream
	SendAndClose(*NotifyTxResponse) error
}

type GetBlockByIDRequest

type GetBlockByIDRequest struct {
	TxBytes []byte `protobuf:"bytes,1,opt,name=tx_bytes,json=txBytes,proto3" json:"tx_bytes,omitempty"`
	// contains filtered or unexported fields
}

GetBlockByID

func (*GetBlockByIDRequest) Descriptor deprecated

func (*GetBlockByIDRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetBlockByIDRequest.ProtoReflect.Descriptor instead.

func (*GetBlockByIDRequest) GetTxBytes

func (x *GetBlockByIDRequest) GetTxBytes() []byte

func (*GetBlockByIDRequest) ProtoMessage

func (*GetBlockByIDRequest) ProtoMessage()

func (*GetBlockByIDRequest) ProtoReflect

func (x *GetBlockByIDRequest) ProtoReflect() protoreflect.Message

func (*GetBlockByIDRequest) Reset

func (x *GetBlockByIDRequest) Reset()

func (*GetBlockByIDRequest) String

func (x *GetBlockByIDRequest) String() string

type GetBlockByIDResponse

type GetBlockByIDResponse struct {
	BlockBytes []byte `protobuf:"bytes,1,opt,name=block_bytes,json=blockBytes,proto3" json:"block_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlockByIDResponse) Descriptor deprecated

func (*GetBlockByIDResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetBlockByIDResponse.ProtoReflect.Descriptor instead.

func (*GetBlockByIDResponse) GetBlockBytes

func (x *GetBlockByIDResponse) GetBlockBytes() []byte

func (*GetBlockByIDResponse) ProtoMessage

func (*GetBlockByIDResponse) ProtoMessage()

func (*GetBlockByIDResponse) ProtoReflect

func (x *GetBlockByIDResponse) ProtoReflect() protoreflect.Message

func (*GetBlockByIDResponse) Reset

func (x *GetBlockByIDResponse) Reset()

func (*GetBlockByIDResponse) String

func (x *GetBlockByIDResponse) String() string

type GetBlockIDByNumberRequest

type GetBlockIDByNumberRequest struct {
	BlockNum uint64 `protobuf:"varint,1,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"`
	// contains filtered or unexported fields
}

GetBlockIDByNumber

func (*GetBlockIDByNumberRequest) Descriptor deprecated

func (*GetBlockIDByNumberRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetBlockIDByNumberRequest.ProtoReflect.Descriptor instead.

func (*GetBlockIDByNumberRequest) GetBlockNum

func (x *GetBlockIDByNumberRequest) GetBlockNum() uint64

func (*GetBlockIDByNumberRequest) ProtoMessage

func (*GetBlockIDByNumberRequest) ProtoMessage()

func (*GetBlockIDByNumberRequest) ProtoReflect

func (*GetBlockIDByNumberRequest) Reset

func (x *GetBlockIDByNumberRequest) Reset()

func (*GetBlockIDByNumberRequest) String

func (x *GetBlockIDByNumberRequest) String() string

type GetBlockIDByNumberResponse

type GetBlockIDByNumberResponse struct {
	BlockId []byte `protobuf:"bytes,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlockIDByNumberResponse) Descriptor deprecated

func (*GetBlockIDByNumberResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetBlockIDByNumberResponse.ProtoReflect.Descriptor instead.

func (*GetBlockIDByNumberResponse) GetBlockId

func (x *GetBlockIDByNumberResponse) GetBlockId() []byte

func (*GetBlockIDByNumberResponse) ProtoMessage

func (*GetBlockIDByNumberResponse) ProtoMessage()

func (*GetBlockIDByNumberResponse) ProtoReflect

func (*GetBlockIDByNumberResponse) Reset

func (x *GetBlockIDByNumberResponse) Reset()

func (*GetBlockIDByNumberResponse) String

func (x *GetBlockIDByNumberResponse) String() string

type GetBlocksFromNumberRequest

type GetBlocksFromNumberRequest struct {
	BlockNum uint64 `protobuf:"varint,1,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"`
	// contains filtered or unexported fields
}

GetBlocksFromNumber

func (*GetBlocksFromNumberRequest) Descriptor deprecated

func (*GetBlocksFromNumberRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetBlocksFromNumberRequest.ProtoReflect.Descriptor instead.

func (*GetBlocksFromNumberRequest) GetBlockNum

func (x *GetBlocksFromNumberRequest) GetBlockNum() uint64

func (*GetBlocksFromNumberRequest) ProtoMessage

func (*GetBlocksFromNumberRequest) ProtoMessage()

func (*GetBlocksFromNumberRequest) ProtoReflect

func (*GetBlocksFromNumberRequest) Reset

func (x *GetBlocksFromNumberRequest) Reset()

func (*GetBlocksFromNumberRequest) String

func (x *GetBlocksFromNumberRequest) String() string

type GetBlocksFromNumberResponse

type GetBlocksFromNumberResponse struct {
	BlockBytesList [][]byte `protobuf:"bytes,1,rep,name=block_bytes_list,json=blockBytesList,proto3" json:"block_bytes_list,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlocksFromNumberResponse) Descriptor deprecated

func (*GetBlocksFromNumberResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetBlocksFromNumberResponse.ProtoReflect.Descriptor instead.

func (*GetBlocksFromNumberResponse) GetBlockBytesList

func (x *GetBlocksFromNumberResponse) GetBlockBytesList() [][]byte

func (*GetBlocksFromNumberResponse) ProtoMessage

func (*GetBlocksFromNumberResponse) ProtoMessage()

func (*GetBlocksFromNumberResponse) ProtoReflect

func (*GetBlocksFromNumberResponse) Reset

func (x *GetBlocksFromNumberResponse) Reset()

func (*GetBlocksFromNumberResponse) String

func (x *GetBlocksFromNumberResponse) String() string

type GetStatusRequest

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

func (*GetStatusRequest) Descriptor deprecated

func (*GetStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetStatusRequest.ProtoReflect.Descriptor instead.

func (*GetStatusRequest) ProtoMessage

func (*GetStatusRequest) ProtoMessage()

func (*GetStatusRequest) ProtoReflect

func (x *GetStatusRequest) ProtoReflect() protoreflect.Message

func (*GetStatusRequest) Reset

func (x *GetStatusRequest) Reset()

func (*GetStatusRequest) String

func (x *GetStatusRequest) String() string

type GetStatusResponse

type GetStatusResponse struct {
	GenesisBlockId   []byte `protobuf:"bytes,1,opt,name=genesis_block_id,json=genesisBlockId,proto3" json:"genesis_block_id,omitempty"`
	SysNanoTimestamp uint64 `protobuf:"varint,2,opt,name=sys_nano_timestamp,json=sysNanoTimestamp,proto3" json:"sys_nano_timestamp,omitempty"`
	BestBlockId      []byte `protobuf:"bytes,3,opt,name=best_block_id,json=bestBlockId,proto3" json:"best_block_id,omitempty"`
	BestBlockNum     uint64 `protobuf:"varint,4,opt,name=best_block_num,json=bestBlockNum,proto3" json:"best_block_num,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatusResponse) Descriptor deprecated

func (*GetStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetStatusResponse.ProtoReflect.Descriptor instead.

func (*GetStatusResponse) GetBestBlockId

func (x *GetStatusResponse) GetBestBlockId() []byte

func (*GetStatusResponse) GetBestBlockNum

func (x *GetStatusResponse) GetBestBlockNum() uint64

func (*GetStatusResponse) GetGenesisBlockId

func (x *GetStatusResponse) GetGenesisBlockId() []byte

func (*GetStatusResponse) GetSysNanoTimestamp

func (x *GetStatusResponse) GetSysNanoTimestamp() uint64

func (*GetStatusResponse) ProtoMessage

func (*GetStatusResponse) ProtoMessage()

func (*GetStatusResponse) ProtoReflect

func (x *GetStatusResponse) ProtoReflect() protoreflect.Message

func (*GetStatusResponse) Reset

func (x *GetStatusResponse) Reset()

func (*GetStatusResponse) String

func (x *GetStatusResponse) String() string

type NotifyBlockIDRequest

type NotifyBlockIDRequest struct {
	BlockId []byte `protobuf:"bytes,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
	// contains filtered or unexported fields
}

NotifyBlockID

func (*NotifyBlockIDRequest) Descriptor deprecated

func (*NotifyBlockIDRequest) Descriptor() ([]byte, []int)

Deprecated: Use NotifyBlockIDRequest.ProtoReflect.Descriptor instead.

func (*NotifyBlockIDRequest) GetBlockId

func (x *NotifyBlockIDRequest) GetBlockId() []byte

func (*NotifyBlockIDRequest) ProtoMessage

func (*NotifyBlockIDRequest) ProtoMessage()

func (*NotifyBlockIDRequest) ProtoReflect

func (x *NotifyBlockIDRequest) ProtoReflect() protoreflect.Message

func (*NotifyBlockIDRequest) Reset

func (x *NotifyBlockIDRequest) Reset()

func (*NotifyBlockIDRequest) String

func (x *NotifyBlockIDRequest) String() string

type NotifyBlockIDResponse

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

func (*NotifyBlockIDResponse) Descriptor deprecated

func (*NotifyBlockIDResponse) Descriptor() ([]byte, []int)

Deprecated: Use NotifyBlockIDResponse.ProtoReflect.Descriptor instead.

func (*NotifyBlockIDResponse) ProtoMessage

func (*NotifyBlockIDResponse) ProtoMessage()

func (*NotifyBlockIDResponse) ProtoReflect

func (x *NotifyBlockIDResponse) ProtoReflect() protoreflect.Message

func (*NotifyBlockIDResponse) Reset

func (x *NotifyBlockIDResponse) Reset()

func (*NotifyBlockIDResponse) String

func (x *NotifyBlockIDResponse) String() string

type NotifyBlockRequest

type NotifyBlockRequest struct {
	BlockBytes []byte `protobuf:"bytes,1,opt,name=block_bytes,json=blockBytes,proto3" json:"block_bytes,omitempty"`
	// contains filtered or unexported fields
}

NotifyBlock

func (*NotifyBlockRequest) Descriptor deprecated

func (*NotifyBlockRequest) Descriptor() ([]byte, []int)

Deprecated: Use NotifyBlockRequest.ProtoReflect.Descriptor instead.

func (*NotifyBlockRequest) GetBlockBytes

func (x *NotifyBlockRequest) GetBlockBytes() []byte

func (*NotifyBlockRequest) ProtoMessage

func (*NotifyBlockRequest) ProtoMessage()

func (*NotifyBlockRequest) ProtoReflect

func (x *NotifyBlockRequest) ProtoReflect() protoreflect.Message

func (*NotifyBlockRequest) Reset

func (x *NotifyBlockRequest) Reset()

func (*NotifyBlockRequest) String

func (x *NotifyBlockRequest) String() string

type NotifyBlockResponse

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

func (*NotifyBlockResponse) Descriptor deprecated

func (*NotifyBlockResponse) Descriptor() ([]byte, []int)

Deprecated: Use NotifyBlockResponse.ProtoReflect.Descriptor instead.

func (*NotifyBlockResponse) ProtoMessage

func (*NotifyBlockResponse) ProtoMessage()

func (*NotifyBlockResponse) ProtoReflect

func (x *NotifyBlockResponse) ProtoReflect() protoreflect.Message

func (*NotifyBlockResponse) Reset

func (x *NotifyBlockResponse) Reset()

func (*NotifyBlockResponse) String

func (x *NotifyBlockResponse) String() string

type NotifyTxRequest

type NotifyTxRequest struct {
	TxBytes []byte `protobuf:"bytes,1,opt,name=tx_bytes,json=txBytes,proto3" json:"tx_bytes,omitempty"`
	// contains filtered or unexported fields
}

NotifyTx

func (*NotifyTxRequest) Descriptor deprecated

func (*NotifyTxRequest) Descriptor() ([]byte, []int)

Deprecated: Use NotifyTxRequest.ProtoReflect.Descriptor instead.

func (*NotifyTxRequest) GetTxBytes

func (x *NotifyTxRequest) GetTxBytes() []byte

func (*NotifyTxRequest) ProtoMessage

func (*NotifyTxRequest) ProtoMessage()

func (*NotifyTxRequest) ProtoReflect

func (x *NotifyTxRequest) ProtoReflect() protoreflect.Message

func (*NotifyTxRequest) Reset

func (x *NotifyTxRequest) Reset()

func (*NotifyTxRequest) String

func (x *NotifyTxRequest) String() string

type NotifyTxResponse

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

func (*NotifyTxResponse) Descriptor deprecated

func (*NotifyTxResponse) Descriptor() ([]byte, []int)

Deprecated: Use NotifyTxResponse.ProtoReflect.Descriptor instead.

func (*NotifyTxResponse) ProtoMessage

func (*NotifyTxResponse) ProtoMessage()

func (*NotifyTxResponse) ProtoReflect

func (x *NotifyTxResponse) ProtoReflect() protoreflect.Message

func (*NotifyTxResponse) Reset

func (x *NotifyTxResponse) Reset()

func (*NotifyTxResponse) String

func (x *NotifyTxResponse) String() string

type SyncServer

type SyncServer struct{}

func NewSyncServer

func NewSyncServer() *SyncServer

func (*SyncServer) GetStatus

func (s *SyncServer) GetStatus(ctx context.Context, req *GetStatusRequest) (*GetStatusResponse, error)

func (*SyncServer) NotifyBlock

func (s *SyncServer) NotifyBlock(ctx context.Context, req *NotifyBlockRequest) (*NotifyBlockResponse, error)

func (*SyncServer) NotifyBlockID

Jump to

Keyboard shortcuts

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