request

package

v0.2.9 Latest Latest Go to latest Published: Oct 13, 2020 License: ISC Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Futuremine-chain/future

Links

Open Source Insights

Documentation ¶

Index ¶

type Code
type Message
type Method
type ReqStream
- func NewReqStream(r *Request, stream network.Stream) *ReqStream
- func (r *ReqStream) Close()
type Request
- func NewRequest(method Method, body Message) *Request
type RequestHandler
- func NewRequestHandler(chain blockchain.IChain) *RequestHandler
type Response
- func NewResponse(code Code, message string, body []byte) *Response

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Code ¶

type Code int

const (
	Success Code = iota
	Failed
)

type Message ¶

type Message []byte

type Method ¶

type Method string

type ReqStream ¶

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

func NewReqStream ¶

func NewReqStream(r *Request, stream network.Stream) *ReqStream

func (*ReqStream) Close ¶

func (r *ReqStream) Close()

type Request ¶

type Request struct {
	Method Method  `json:"method"`
	Body   Message `json:"body"`
}

Peer communication request body

func NewRequest ¶

func NewRequest(method Method, body Message) *Request

type RequestHandler ¶

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

func NewRequestHandler ¶

func NewRequestHandler(chain blockchain.IChain) *RequestHandler

func (*RequestHandler) GetBlock ¶

func (r *RequestHandler) GetBlock(conn *types.Conn, height uint64) (types.IBlock, error)

func (*RequestHandler) GetBlocks ¶

func (r *RequestHandler) GetBlocks(conn *types.Conn, height, count uint64) ([]types.IBlock, error)

func (*RequestHandler) Info ¶

func (r *RequestHandler) Info() map[string]interface{}

func (*RequestHandler) IsEqual ¶

func (r *RequestHandler) IsEqual(conn *types.Conn, header types.IHeader) (bool, error)

func (*RequestHandler) LastHeight ¶

func (r *RequestHandler) LastHeight(conn *types.Conn) (uint64, error)

func (*RequestHandler) LocalInfo ¶

func (r *RequestHandler) LocalInfo(conn *types.Conn) (*types.Local, error)

func (*RequestHandler) Name ¶

func (r *RequestHandler) Name() string

func (*RequestHandler) RegisterLocalInfo ¶

func (r *RequestHandler) RegisterLocalInfo(f func() *types.Local)

func (*RequestHandler) RegisterReceiveBlock ¶

func (r *RequestHandler) RegisterReceiveBlock(f func(types.IBlock) error)

func (*RequestHandler) RegisterReceiveMessage ¶

func (r *RequestHandler) RegisterReceiveMessage(f func(types.IMessage) error)

func (*RequestHandler) SendBlock ¶

func (r *RequestHandler) SendBlock(conn *types.Conn, block types.IBlock) error

func (*RequestHandler) SendMsg ¶

func (r *RequestHandler) SendMsg(conn *types.Conn, msg types.IMessage) error

func (*RequestHandler) SendToReady ¶

func (r *RequestHandler) SendToReady(stream network.Stream)

func (*RequestHandler) Start ¶

func (r *RequestHandler) Start() error

Listen for message requests

func (*RequestHandler) Stop ¶

func (r *RequestHandler) Stop() error

func (*RequestHandler) UnmarshalRequest ¶

func (r *RequestHandler) UnmarshalRequest(stream network.Stream) (*Request, error)

Read from request

func (*RequestHandler) UnmarshalResponse ¶

func (r *RequestHandler) UnmarshalResponse(stream network.Stream) (*Response, error)

Read from response

type Response ¶

type Response struct {
	Code    Code    `json:"code"`
	Message string  `json:"message"`
	Body    Message `json:"body"`
}

Peer node communication response message

func NewResponse ¶

func NewResponse(code Code, message string, body []byte) *Response

Source Files ¶

View all Source files

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