dcrm

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

const (
	ProtocolName = "dcrm"

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

)

TODO

Variables

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

Functions

func Broatcast

func Broatcast(msg string)

func BroatcastToGroup

func BroatcastToGroup(msg string)

func GetEnodes

func GetEnodes() (int, string)

func GetGroup

func GetGroup() (int, string)

func GetSelfID

func GetSelfID() discover.NodeID

func HandlePeer

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

func RegisterCallback

func RegisterCallback(recvDcrmFunc func(interface{}))

func RegisterDcrmCallback

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

func RegisterDcrmRetCallback

func RegisterDcrmRetCallback(dcrmcallback func(interface{}))

func RegisterRecvCallback

func RegisterRecvCallback(recvPrivkeyFunc func(interface{}))

func SendMsg

func SendMsg(msg string)

func SendMsgToPeer

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

func SendToDcrmGroup

func SendToDcrmGroup(msg string) string

func SendToPeer

func SendToPeer(enode string, msg string)

func StartTest

func StartTest()

Types

type Config

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

type Dcrm

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

func New

func New(cfg *Config) *Dcrm

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

func (*Dcrm) APIs

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

APIs returns the RPC descriptors the Whisper implementation offers

func (*Dcrm) Protocols

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

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

func (*Dcrm) Start

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

func (dcrm *Dcrm) Stop() error

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

type DcrmAPI

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

func (*DcrmAPI) Peers

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

func (*DcrmAPI) Version

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

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

func NewDcrmGroup

func NewDcrmGroup() *Group

type Peer

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

peer represents a whisper protocol peer connection.

type Transaction

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