Versions in this module Expand all Collapse all v0 v0.1.0 Feb 24, 2018 Changes in this version + var Transaction_Status_name = map[int32]string + var Transaction_Status_value = map[string]int32 + var TxData_TxDataType_name = map[int32]string + var TxData_TxDataType_value = map[string]int32 + func RegisterPeerServiceServer(s *grpc.Server, srv PeerServiceServer) + func RegisterStreamServiceServer(s *grpc.Server, srv StreamServiceServer) + func RegisterTransactionServiceServer(s *grpc.Server, srv TransactionServiceServer) + type Block struct + Data []byte + func (*Block) Descriptor() ([]byte, []int) + func (*Block) ProtoMessage() + func (m *Block) GetData() []byte + func (m *Block) Reset() + func (m *Block) String() string + type ConnectionEstablish struct + func (*ConnectionEstablish) Descriptor() ([]byte, []int) + func (*ConnectionEstablish) ProtoMessage() + func (m *ConnectionEstablish) Reset() + func (m *ConnectionEstablish) String() string + type ConsensusMessage struct + Block *Block + ConsensusID string + MsgType int32 + SenderID string + SequenceID int64 + View *View + func (*ConsensusMessage) Descriptor() ([]byte, []int) + func (*ConsensusMessage) ProtoMessage() + func (m *ConsensusMessage) GetBlock() *Block + func (m *ConsensusMessage) GetConsensusID() string + func (m *ConsensusMessage) GetMsgType() int32 + func (m *ConsensusMessage) GetSenderID() string + func (m *ConsensusMessage) GetSequenceID() int64 + func (m *ConsensusMessage) GetView() *View + func (m *ConsensusMessage) Reset() + func (m *ConsensusMessage) String() string + type ElectionMessage struct + LastBlockHash string + MsgType int32 + PeerIDs []string + SenderID string + Term int64 + func (*ElectionMessage) Descriptor() ([]byte, []int) + func (*ElectionMessage) ProtoMessage() + func (m *ElectionMessage) GetLastBlockHash() string + func (m *ElectionMessage) GetMsgType() int32 + func (m *ElectionMessage) GetPeerIDs() []string + func (m *ElectionMessage) GetSenderID() string + func (m *ElectionMessage) GetTerm() int64 + func (m *ElectionMessage) Reset() + func (m *ElectionMessage) String() string + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (m *Empty) Reset() + func (m *Empty) String() string + type Envelope struct + Payload []byte + Pubkey []byte + Signature []byte + func (*Envelope) Descriptor() ([]byte, []int) + func (*Envelope) ProtoMessage() + func (envelope *Envelope) GetMessage() (*StreamMessage, error) + func (m *Envelope) GetPayload() []byte + func (m *Envelope) GetPubkey() []byte + func (m *Envelope) GetSignature() []byte + func (m *Envelope) Reset() + func (m *Envelope) String() string + type Params struct + Args []string + Function string + ParamsType int32 + func (*Params) Descriptor() ([]byte, []int) + func (*Params) ProtoMessage() + func (m *Params) GetArgs() []string + func (m *Params) GetFunction() string + func (m *Params) GetParamsType() int32 + func (m *Params) Reset() + func (m *Params) String() string + type Peer struct + HeartBeat int32 + IpAddress string + PeerID string + Port string + PubKey []byte + func (*Peer) Descriptor() ([]byte, []int) + func (*Peer) ProtoMessage() + func (m *Peer) GetHeartBeat() int32 + func (m *Peer) GetIpAddress() string + func (m *Peer) GetPeerID() string + func (m *Peer) GetPort() string + func (m *Peer) GetPubKey() []byte + func (m *Peer) Reset() + func (m *Peer) String() string + type PeerServiceClient interface + GetPeer func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Peer, error) + func NewPeerServiceClient(cc *grpc.ClientConn) PeerServiceClient + type PeerServiceServer interface + GetPeer func(context.Context, *Empty) (*Peer, error) + type PeerTable struct + MyID string + PeerMap map[string]*Peer + func (*PeerTable) Descriptor() ([]byte, []int) + func (*PeerTable) ProtoMessage() + func (m *PeerTable) GetMyID() string + func (m *PeerTable) GetPeerMap() map[string]*Peer + func (m *PeerTable) Reset() + func (m *PeerTable) String() string + type StreamMessage struct + Channel []byte + Content isStreamMessage_Content + func (*StreamMessage) Descriptor() ([]byte, []int) + func (*StreamMessage) ProtoMessage() + func (*StreamMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (m *StreamMessage) GetBlock() *Block + func (m *StreamMessage) GetChannel() []byte + func (m *StreamMessage) GetConnectionEstablish() *ConnectionEstablish + func (m *StreamMessage) GetConsensusMessage() *ConsensusMessage + func (m *StreamMessage) GetContent() isStreamMessage_Content + func (m *StreamMessage) GetElectionMessage() *ElectionMessage + func (m *StreamMessage) GetPeer() *Peer + func (m *StreamMessage) GetPeerTable() *PeerTable + func (m *StreamMessage) GetTransaction() *Transaction + func (m *StreamMessage) Reset() + func (m *StreamMessage) String() string + type StreamMessage_Block struct + Block *Block + type StreamMessage_ConnectionEstablish struct + ConnectionEstablish *ConnectionEstablish + type StreamMessage_ConsensusMessage struct + ConsensusMessage *ConsensusMessage + type StreamMessage_ElectionMessage struct + ElectionMessage *ElectionMessage + type StreamMessage_Peer struct + Peer *Peer + type StreamMessage_PeerTable struct + PeerTable *PeerTable + type StreamMessage_Transaction struct + Transaction *Transaction + type StreamServiceClient interface + Stream func(ctx context.Context, opts ...grpc.CallOption) (StreamService_StreamClient, error) + func NewStreamServiceClient(cc *grpc.ClientConn) StreamServiceClient + type StreamServiceServer interface + Stream func(StreamService_StreamServer) error + type StreamService_StreamClient interface + Recv func() (*Envelope, error) + Send func(*Envelope) error + type StreamService_StreamServer interface + Recv func() (*Envelope, error) + Send func(*Envelope) error + type Transaction struct + InvokePeerID string + TimeStamp int64 + TransactionHash string + TransactionID string + TransactionStatus Transaction_Status + TransactionType int32 + TxData *TxData + func (*Transaction) Descriptor() ([]byte, []int) + func (*Transaction) ProtoMessage() + func (m *Transaction) GetInvokePeerID() string + func (m *Transaction) GetTimeStamp() int64 + func (m *Transaction) GetTransactionHash() string + func (m *Transaction) GetTransactionID() string + func (m *Transaction) GetTransactionStatus() Transaction_Status + func (m *Transaction) GetTransactionType() int32 + func (m *Transaction) GetTxData() *TxData + func (m *Transaction) Reset() + func (m *Transaction) String() string + type TransactionServiceClient interface + PostTransaction func(ctx context.Context, in *TxData, opts ...grpc.CallOption) (*Transaction, error) + func NewTransactionServiceClient(cc *grpc.ClientConn) TransactionServiceClient + type TransactionServiceServer interface + PostTransaction func(context.Context, *TxData) (*Transaction, error) + type Transaction_Status int32 + const Transaction_CONFIRMED + const Transaction_UNCONFIRMED + const Transaction_UNKNOWN + func (Transaction_Status) EnumDescriptor() ([]byte, []int) + func (x Transaction_Status) String() string + type TxData struct + ContractID string + Jsonrpc string + Method TxData_TxDataType + Params *Params + func (*TxData) Descriptor() ([]byte, []int) + func (*TxData) ProtoMessage() + func (m *TxData) GetContractID() string + func (m *TxData) GetJsonrpc() string + func (m *TxData) GetMethod() TxData_TxDataType + func (m *TxData) GetParams() *Params + func (m *TxData) Reset() + func (m *TxData) String() string + type TxData_TxDataType int32 + const TxData_Invoke + const TxData_Query + func (TxData_TxDataType) EnumDescriptor() ([]byte, []int) + func (x TxData_TxDataType) String() string + type View struct + LeaderID string + PeerID []string + ViewID string + func (*View) Descriptor() ([]byte, []int) + func (*View) ProtoMessage() + func (m *View) GetLeaderID() string + func (m *View) GetPeerID() []string + func (m *View) GetViewID() string + func (m *View) Reset() + func (m *View) String() string
Go to main page