log

Documentation

Index

• type Publisher
  • func New() Publisher
  • func (p Publisher) Close() error
  • func (p Publisher) Name() string
  • func (p Publisher) ProduceBulk(events []*pb.Event, connGroup string) error

Types

type Publisher

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

Publisher publishes message to the standard logger This is intended for development use.

func New

func New() Publisher

func (Publisher) Close

func (p Publisher) Close() error

func (Publisher) Name

func (p Publisher) Name() string

func (Publisher) ProduceBulk

func (p Publisher) ProduceBulk(events []*pb.Event, connGroup string) error