dcrm

package

v0.4.1 Latest Latest Go to latest Published: Dec 28, 2018 License: GPL-3.0, LGPL-3.0 Imports: 17 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/zhaojun-sh/dcrm4

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func Broatcast(msg string)
func BroatcastToGroup(msg string)
func GetEnodes() (int, string)
func GetGroup() (int, string)
func GetSelfID() discover.NodeID
func HandlePeer(peer *p2p.Peer, rw p2p.MsgReadWriter) error
func RegisterCallback(recvDcrmFunc func(interface{}))
func RegisterDcrmCallback(dcrmcallback func(interface{}) <-chan string)
func RegisterDcrmRetCallback(dcrmcallback func(interface{}))
func RegisterRecvCallback(recvPrivkeyFunc func(interface{}))
func SendMsg(msg string)
func SendMsgToPeer(toid discover.NodeID, toaddr *net.UDPAddr, msg string) error
func SendToDcrmGroup(msg string) string
func SendToPeer(enode string, msg string)
func StartTest()
type Config
type Dcrm
- func New(cfg *Config) *Dcrm
- func (dcrm *Dcrm) APIs() []rpc.API
- func (dcrm *Dcrm) Protocols() []p2p.Protocol
- func (dcrm *Dcrm) Start(server *p2p.Server) error
- func (dcrm *Dcrm) Stop() error
type DcrmAPI
- func (dcrm *DcrmAPI) Peers(ctx context.Context) []*p2p.PeerInfo
- func (dcrm *DcrmAPI) Version(ctx context.Context) (v string)
type Emitter
- func NewEmitter() *Emitter
type Group
- func NewDcrmGroup() *Group
type Peer
type Transaction

Constants ¶

View Source

const (
	ProtocolName = "dcrm"

	ProtocolVersion      = 1
	ProtocolVersionStr   = "1"
	NumberOfMessageCodes = 8 + iota // msgLength

)

TODO

Variables ¶

View Source

var DefaultConfig = Config{
	DcrmNodes: make([]*discover.Node, 0),
}

Functions ¶

func Broatcast ¶ added in v0.4.1

func Broatcast(msg string)

func BroatcastToGroup ¶ added in v0.4.1

func BroatcastToGroup(msg string)

func GetEnodes ¶

func GetEnodes() (int, string)

func GetGroup ¶

func GetGroup() (int, string)

func GetSelfID ¶ added in v0.4.1

func GetSelfID() discover.NodeID

func HandlePeer ¶ added in v0.4.1

func HandlePeer(peer *p2p.Peer, rw p2p.MsgReadWriter) error

func RegisterCallback ¶

func RegisterCallback(recvDcrmFunc func(interface{}))

func RegisterDcrmCallback ¶ added in v0.4.1

func RegisterDcrmCallback(dcrmcallback func(interface{}) <-chan string)

func RegisterDcrmRetCallback ¶ added in v0.4.1

func RegisterDcrmRetCallback(dcrmcallback func(interface{}))

func RegisterRecvCallback ¶ added in v0.4.1

func RegisterRecvCallback(recvPrivkeyFunc func(interface{}))

func SendMsg ¶

func SendMsg(msg string)

func SendMsgToPeer ¶ added in v0.4.1

func SendMsgToPeer(toid discover.NodeID, toaddr *net.UDPAddr, msg string) error

func SendToDcrmGroup ¶ added in v0.4.1

func SendToDcrmGroup(msg string) string

func SendToPeer ¶ added in v0.4.1

func SendToPeer(enode string, msg string)

func StartTest ¶

func StartTest()

Types ¶

type Config ¶ added in v0.4.1

type Config struct {
	DcrmNodes []*discover.Node
	DataPath  string
}

type Dcrm ¶ added in v0.4.1

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

func New ¶ added in v0.4.1

func New(cfg *Config) *Dcrm

New creates a Whisper client ready to communicate through the Ethereum P2P network.

func (*Dcrm) APIs ¶ added in v0.4.1

func (dcrm *Dcrm) APIs() []rpc.API

APIs returns the RPC descriptors the Whisper implementation offers

func (*Dcrm) Protocols ¶ added in v0.4.1

func (dcrm *Dcrm) Protocols() []p2p.Protocol

Protocols returns the whisper sub-protocols ran by this particular client.

func (*Dcrm) Start ¶ added in v0.4.1

func (dcrm *Dcrm) Start(server *p2p.Server) error

Start implements node.Service, starting the background data propagation thread of the Whisper protocol.

func (*Dcrm) Stop ¶ added in v0.4.1

func (dcrm *Dcrm) Stop() error

Stop implements node.Service, stopping the background data propagation thread of the Whisper protocol.

type DcrmAPI ¶ added in v0.4.1

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

func (*DcrmAPI) Peers ¶ added in v0.4.1

func (dcrm *DcrmAPI) Peers(ctx context.Context) []*p2p.PeerInfo

func (*DcrmAPI) Version ¶ added in v0.4.1

func (dcrm *DcrmAPI) Version(ctx context.Context) (v string)

type Emitter ¶

type Emitter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewEmitter ¶

func NewEmitter() *Emitter

type Group ¶ added in v0.4.1

type Group struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewDcrmGroup ¶ added in v0.4.1

func NewDcrmGroup() *Group

type Peer ¶ added in v0.4.1

type Peer struct {
	Peer *p2p.Peer
	// contains filtered or unexported fields
}

peer represents a whisper protocol peer connection.

type Transaction ¶ added in v0.4.1

type Transaction struct {
	Payload []byte
	Hash    atomic.Value
}

Source Files ¶

View all Source files

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