Documentation ¶
Index ¶
- func AddEventType(eventType pb.EventType) error
- func CreateBlockEvent(te *common.Block) *pb.Event
- func CreateChaincodeEvent(te *pb.ChaincodeEvent) *pb.Event
- func CreateRejectionEvent(tx *pb.Transaction, errorMsg string) *pb.Event
- func Send(e *pb.Event) error
- func SendProducerBlockEvent(block *common.Block) error
- type EventsServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateBlockEvent ¶
CreateBlockEvent creates a Event from a Block
func CreateChaincodeEvent ¶
func CreateChaincodeEvent(te *pb.ChaincodeEvent) *pb.Event
CreateChaincodeEvent creates a Event from a ChaincodeEvent
Types ¶
type EventsServer ¶
type EventsServer struct { }
EventsServer implementation of the Peer service
func NewEventsServer ¶
func NewEventsServer(bufferSize uint, timeout time.Duration) *EventsServer
NewEventsServer returns a EventsServer
func (*EventsServer) Chat ¶
func (p *EventsServer) Chat(stream pb.Events_ChatServer) error
Chat implementation of the the Chat bidi streaming RPC function
Click to show internal directories.
Click to hide internal directories.