producer

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Feb 15, 2016 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source
const (
	RegisterType = "register"
	BlockType    = "block"
)

----Event Types -----

Variables

This section is empty.

Functions

func AddEventType

func AddEventType(eventType string) error

AddEventType supported event

func CreateBlockEvent

func CreateBlockEvent(te *ehpb.Block) *ehpb.OpenchainEvent

CreateBlockEvent creates a OpenchainEvent from a Block

func Send

func Send(e *pb.OpenchainEvent) error

Send sends the event to interested consumers

Types

type OpenchainEventsServer

type OpenchainEventsServer struct {
}

OpenchainEventsServer implementation of the Peer service

func NewOpenchainEventsServer

func NewOpenchainEventsServer(bufferSize uint, timeout int) *OpenchainEventsServer

NewOpenchainEventsServer returns a OpenchainEventsServer

func (*OpenchainEventsServer) Chat

Chat implementation of the the Chat bidi streaming RPC function

Jump to

Keyboard shortcuts

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