producer

Documentation

Index

• func CreateBlockEvent(te *common.Block) *pb.Event
• func CreateBlockEvents(block *common.Block) (bevent *pb.Event, fbevent *pb.Event, channelID string, err error)
• func CreateFilteredBlockEvent(te *pb.FilteredBlock) *pb.Event
• func Send(e *pb.Event) error
• type EventsServer
  • func NewEventsServer(config *EventsServerConfig) *EventsServer
  • func (e *EventsServer) Chat(stream pb.Events_ChatServer) error
• type EventsServerConfig
• type Set

Functions

func CreateBlockEvent

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

func CreateBlockEvents

func CreateBlockEvents(block *common.Block) (bevent *pb.Event, fbevent *pb.Event, channelID string, err error)

func CreateFilteredBlockEvent

func CreateFilteredBlockEvent(te *pb.FilteredBlock) *pb.Event

func Send

func Send(e *pb.Event) error

Types

type EventsServer

type EventsServer struct {
	// contains filtered or unexported fields
}

func NewEventsServer

func NewEventsServer(config *EventsServerConfig) *EventsServer

func (*EventsServer) Chat

func (e *EventsServer) Chat(stream pb.Events_ChatServer) error

type EventsServerConfig

type EventsServerConfig struct {
	BufferSize       uint
	Timeout          time.Duration
	SendTimeout      time.Duration
	TimeWindow       time.Duration
	BindingInspector comm.BindingInspector
}

type Set

type Set map[*handler]struct{}