Versions in this module Expand all Collapse all v0 v0.1.0 Feb 15, 2016 Changes in this version + func GetLocalAddress() (peerAddress string, err error) + func GetLocalIP() string + func GetPeerEndpoint() (*pb.PeerEndpoint, error) + func NewPeerClientConnection() (*grpc.ClientConn, error) + func NewPeerClientConnectionWithAddress(peerAddress string) (*grpc.ClientConn, error) + type BlockChainAccessor interface + GetBlockByNumber func(blockNumber uint64) (*pb.Block, error) + type BlocksRetriever interface + RequestBlocks func(*pb.SyncBlockRange) (<-chan *pb.SyncBlocks, error) + type ChatStream interface + Recv func() (*pb.OpenchainMessage, error) + Send func(*pb.OpenchainMessage) error + type DuplicateHandlerError struct + To pb.PeerEndpoint + func (d *DuplicateHandlerError) Error() string + type Handler struct + ChatStream ChatStream + Coordinator MessageHandlerCoordinator + FSM *fsm.FSM + ToPeerEndpoint *pb.PeerEndpoint + func (d *Handler) HandleMessage(msg *pb.OpenchainMessage) error + func (d *Handler) RequestBlocks(syncBlockRange *pb.SyncBlockRange) (<-chan *pb.SyncBlocks, error) + func (d *Handler) RequestStateDeltas(syncBlockRange *pb.SyncBlockRange) (<-chan *pb.SyncStateDeltas, error) + func (d *Handler) RequestStateSnapshot() (<-chan *pb.SyncStateSnapshot, error) + func (d *Handler) SendMessage(msg *pb.OpenchainMessage) error + func (d *Handler) Stop() error + func (d *Handler) To() (pb.PeerEndpoint, error) + type HandlerFactory func(MessageHandlerCoordinator, ChatStream, bool, MessageHandler) (MessageHandler, error) + type MessageHandler interface + HandleMessage func(msg *pb.OpenchainMessage) error + SendMessage func(msg *pb.OpenchainMessage) error + Stop func() error + To func() (pb.PeerEndpoint, error) + func NewPeerHandler(coord MessageHandlerCoordinator, stream ChatStream, initiatedStream bool, ...) (MessageHandler, error) + type MessageHandlerCoordinator interface + Broadcast func(*pb.OpenchainMessage, pb.PeerEndpoint_Type) []error + DeregisterHandler func(messageHandler MessageHandler) error + ExecuteTransaction func(transaction *pb.Transaction) *pb.Response + GetPeers func() (*pb.PeersMessage, error) + GetRemoteLedger func(receiver *pb.PeerID) (RemoteLedger, error) + PeersDiscovered func(*pb.PeersMessage) error + RegisterHandler func(messageHandler MessageHandler) error + Unicast func(*pb.OpenchainMessage, *pb.PeerID) error + type Peer interface + GetPeerEndpoint func() (*pb.PeerEndpoint, error) + NewOpenchainDiscoveryHello func() (*pb.OpenchainMessage, error) + type PeerImpl struct + func NewPeerWithHandler(handlerFact HandlerFactory) (*PeerImpl, error) + func (p *PeerImpl) Broadcast(msg *pb.OpenchainMessage, typ pb.PeerEndpoint_Type) []error + func (p *PeerImpl) Chat(stream pb.Peer_ChatServer) error + func (p *PeerImpl) DeregisterHandler(messageHandler MessageHandler) error + func (p *PeerImpl) ExecuteTransaction(transaction *pb.Transaction) *pb.Response + func (p *PeerImpl) GetBlockByNumber(blockNumber uint64) (*pb.Block, error) + func (p *PeerImpl) GetPeerEndpoint() (*pb.PeerEndpoint, error) + func (p *PeerImpl) GetPeers() (*pb.PeersMessage, error) + func (p *PeerImpl) GetRemoteLedger(receiverHandle *pb.PeerID) (RemoteLedger, error) + func (p *PeerImpl) GetSecHelper() crypto.Peer + func (p *PeerImpl) GetStateDelta(blockNumber uint64) (*statemgmt.StateDelta, error) + func (p *PeerImpl) GetStateSnapshot() (*state.StateSnapshot, error) + func (p *PeerImpl) NewOpenchainDiscoveryHello() (*pb.OpenchainMessage, error) + func (p *PeerImpl) PeersDiscovered(peersMessage *pb.PeersMessage) error + func (p *PeerImpl) RegisterHandler(messageHandler MessageHandler) error + func (p *PeerImpl) SendTransactionsToPeer(peerAddress string, transaction *pb.Transaction) *pb.Response + func (p *PeerImpl) Unicast(msg *pb.OpenchainMessage, receiverHandle *pb.PeerID) error + type RemoteLedger interface + type SecurityAccessor interface + GetSecHelper func() crypto.Peer + type StateAccessor interface + GetStateDelta func(blockNumber uint64) (*statemgmt.StateDelta, error) + GetStateSnapshot func() (*state.StateSnapshot, error) + type StateRetriever interface + RequestStateDeltas func(syncBlockRange *pb.SyncBlockRange) (<-chan *pb.SyncStateDeltas, error) + RequestStateSnapshot func() (<-chan *pb.SyncStateSnapshot, error)
Go to main page