Documentation ¶
Index ¶
- Variables
- func DecodeHex(hexString string) (data []byte)
- type Client
- func (c *Client) Connect() (err error)
- func (c *Client) RegisterHandler(h Handler)
- func (c *Client) RegisterHandlerFunc(f func(Message)) Handler
- func (c *Client) SendHandshake(info *HandshakeInfo) (err error)
- func (c *Client) SendSyncRequest(startBlockNum uint32, endBlockNumber uint32) (err error)
- func (c *Client) UnregisterHandler(h Handler)
- type Handler
- type HandlerFunc
- type HandshakeInfo
- type Message
- type Proxy
- type Route
Constants ¶
This section is empty.
Variables ¶
View Source
var LoggerHandler = HandlerFunc(func(msg Message) { data, error := json.Marshal(msg) if error != nil { fmt.Println("logger plugin err: ", error) return } fmt.Println("logger - message : ", string(data)) })
LoggerHandler logs the messages back and forth.
View Source
var StringLoggerHandler = HandlerFunc(func(msg Message) { fmt.Printf("Received message %T\n", msg.Envelope.P2PMessage) })
StringLoggerHandler simply prints the messages as they go through the client.
Functions ¶
Types ¶
type Client ¶
type Client struct { ChainID eos.SHA256Bytes NetworkVersion uint16 Conn net.Conn NodeID eos.SHA256Bytes SigningKey *ecc.PrivateKey AgentName string ShowEmptyChain bool LastHandshakeReceived *eos.HandshakeMessage // contains filtered or unexported fields }
func (*Client) RegisterHandler ¶
func (*Client) RegisterHandlerFunc ¶
func (*Client) SendHandshake ¶
func (c *Client) SendHandshake(info *HandshakeInfo) (err error)
func (*Client) SendSyncRequest ¶
func (*Client) UnregisterHandler ¶
type HandlerFunc ¶
type HandlerFunc func(msg Message)
func (HandlerFunc) Handle ¶
func (f HandlerFunc) Handle(msg Message)
type HandshakeInfo ¶
type Message ¶
type Message struct { Route *Route `json:"route"` Envelope *eos.P2PMessageEnvelope `json:"envelope"` }
Click to show internal directories.
Click to hide internal directories.