producer

Documentation

Index

• Constants
• func AddEventType(eventType string) error
• func CreateBlockEvent(te *ehpb.Block) *ehpb.OpenchainEvent
• func Send(e *pb.OpenchainEvent) error
• type OpenchainEventsServer
  • func NewOpenchainEventsServer(bufferSize uint, timeout int) *OpenchainEventsServer
  • func (p *OpenchainEventsServer) Chat(stream pb.OpenchainEvents_ChatServer) error

Constants

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

----Event Types -----

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

func (p *OpenchainEventsServer) Chat(stream pb.OpenchainEvents_ChatServer) error

Chat implementation of the the Chat bidi streaming RPC function