stream

Documentation

Index

• Constants
• Variables
• func NewConsumer(configMap *kafka.ConfigMap) (*kafka.Consumer, error)
• func NewProducer(configMap *kafka.ConfigMap) (*kafka.Producer, error)
• func PublishToAll(event *serversv1.Event)
• func Shutdown()
• type Stream
  • func New() *Stream
  • func (stream *Stream) Close()
  • func (stream *Stream) IsClosed() bool

Constants

const Resource = "SERVER"

Variables

var (
	RequestTopic = serversv1.Event_REQUEST.String() + "_" + Resource
	EventTopic   = serversv1.Event_EVENT.String() + "_" + Resource
)

Functions

func NewConsumer

func NewConsumer(configMap *kafka.ConfigMap) (*kafka.Consumer, error)

func NewProducer

func NewProducer(configMap *kafka.ConfigMap) (*kafka.Producer, error)

func PublishToAll

func PublishToAll(event *serversv1.Event)

func Shutdown

func Shutdown()

Shutdown tries to close every managed channel and delete it from managed channels slice

Types

type Stream

type Stream struct {
	ID      string                `json:"id"`
	Channel chan *serversv1.Event `json:"channel"`
}

Stream represents a stream for events

func New

func New() *Stream

New is a constructor for new Stream

func (*Stream) Close

func (stream *Stream) Close()

Close tries to close a managed stream channel

func (*Stream) IsClosed

func (stream *Stream) IsClosed() bool

IsClosed returns if the stream is closed or not