Documentation
¶
Index ¶
- type MockCCComm
- func (s *MockCCComm) CloseSend() error
- func (s *MockCCComm) GetRecvStream() chan *pb.ChaincodeMessage
- func (s *MockCCComm) GetSendStream() chan *pb.ChaincodeMessage
- func (s *MockCCComm) Quit()
- func (s *MockCCComm) Recv() (*pb.ChaincodeMessage, error)
- func (s *MockCCComm) Run(done <-chan struct{}) error
- func (s *MockCCComm) Send(msg *pb.ChaincodeMessage) error
- func (s *MockCCComm) SetBailOnError(b bool)
- func (s *MockCCComm) SetKeepAlive(ka *pb.ChaincodeMessage)
- func (s *MockCCComm) SetName(newname string)
- func (s *MockCCComm) SetPong(val bool)
- func (s *MockCCComm) SetResponses(respSet *MockResponseSet)
- type MockPeerCCSupport
- func (mp *MockPeerCCSupport) AddCC(name string, recv chan *pb.ChaincodeMessage, send chan *pb.ChaincodeMessage) (*MockCCComm, error)
- func (mp *MockPeerCCSupport) GetCC(name string) (*MockCCComm, error)
- func (mp *MockPeerCCSupport) GetCCMirror(name string) *MockCCComm
- func (mp *MockPeerCCSupport) RemoveAll() error
- func (mp *MockPeerCCSupport) RemoveCC(name string) error
- type MockResponse
- type MockResponseSet
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockCCComm ¶
type MockCCComm struct {
// contains filtered or unexported fields
}
mockcccomm实现了链码和对等端之间的模拟通信。
func (*MockCCComm) CloseSend ¶
func (s *MockCCComm) CloseSend() error
func (*MockCCComm) GetRecvStream ¶
func (s *MockCCComm) GetRecvStream() chan *pb.ChaincodeMessage
func (*MockCCComm) GetSendStream ¶
func (s *MockCCComm) GetSendStream() chan *pb.ChaincodeMessage
func (*MockCCComm) Quit ¶
func (s *MockCCComm) Quit()
func (*MockCCComm) Recv ¶
func (s *MockCCComm) Recv() (*pb.ChaincodeMessage, error)
func (*MockCCComm) Run ¶
func (s *MockCCComm) Run(done <-chan struct{}) error
func (*MockCCComm) Send ¶
func (s *MockCCComm) Send(msg *pb.ChaincodeMessage) error
func (*MockCCComm) SetBailOnError ¶
func (s *MockCCComm) SetBailOnError(b bool)
func (*MockCCComm) SetKeepAlive ¶
func (s *MockCCComm) SetKeepAlive(ka *pb.ChaincodeMessage)
setkeepalive设置keepalive。此mut只能在服务器上完成
func (*MockCCComm) SetName ¶
func (s *MockCCComm) SetName(newname string)
func (*MockCCComm) SetPong ¶
func (s *MockCCComm) SetPong(val bool)
func (*MockCCComm) SetResponses ¶
func (s *MockCCComm) SetResponses(respSet *MockResponseSet)
type MockPeerCCSupport ¶
type MockPeerCCSupport struct {
// contains filtered or unexported fields
}
func NewMockPeerSupport ¶
func NewMockPeerSupport() *MockPeerCCSupport
func (*MockPeerCCSupport) AddCC ¶
func (mp *MockPeerCCSupport) AddCC(name string, recv chan *pb.ChaincodeMessage, send chan *pb.ChaincodeMessage) (*MockCCComm, error)
addcc将cc添加到mockpeerccsupport
func (*MockPeerCCSupport) GetCC ¶
func (mp *MockPeerCCSupport) GetCC(name string) (*MockCCComm, error)
func (*MockPeerCCSupport) GetCCMirror ¶
func (mp *MockPeerCCSupport) GetCCMirror(name string) *MockCCComm
func (*MockPeerCCSupport) RemoveAll ¶
func (mp *MockPeerCCSupport) RemoveAll() error
func (*MockPeerCCSupport) RemoveCC ¶
func (mp *MockPeerCCSupport) RemoveCC(name string) error
type MockResponse ¶
type MockResponse struct {
RecvMsg *pb.ChaincodeMessage
RespMsg interface{}
}
和发送响应（可选）
type MockResponseSet ¶
type MockResponseSet struct {
//
//响应集
DoneFunc func(int, error)
//当输入没有被调用时，任何步骤都会调用errorfunc。
//匹配收到的消息
ErrorFunc func(int, error)
//
//和发送响应（可选）
Responses []*MockResponse
}
mockresponseset用于处理CC到对等通信 例如get/put/del state。mockResponse包含
Source Files
Click to show internal directories.
Click to hide internal directories.