producer

package
v0.0.0-...-73452e5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 13, 2020 License: GPL-2.0, Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddEventType

func AddEventType(eventType pb.EventType) error

AddEventType supported event

func CreateBlockEvent

func CreateBlockEvent(te *common.Block) *pb.Event

CreateBlockEvent creates a Event from a Block

func CreateChaincodeEvent

func CreateChaincodeEvent(te *pb.ChaincodeEvent) *pb.Event

CreateChaincodeEvent creates a Event from a ChaincodeEvent

func CreateRejectionEvent

func CreateRejectionEvent(tx *pb.Transaction, errorMsg string) *pb.Event

CreateRejectionEvent creates an Event from TxResults

func Send

func Send(e *pb.Event) error

Send sends the event to interested consumers

func SendProducerBlockEvent

func SendProducerBlockEvent(block *common.Block) error

SendProducerBlockEvent sends block event to clients

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 Chat bidi streaming RPC function

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL