Documentation
¶
Index ¶
- func GetProducer(url string) (streamer.Producer, error)
- func HandleFunc(scheme string, handler Handler)
- func HasProducer(url string) bool
- func Init()
- type Consumer
- type Handler
- type Producer
- type Stream
- func (s *Stream) AddConsumer(cons streamer.Consumer) (err error)
- func (s *Stream) AddProducer(prod streamer.Producer)
- func (s *Stream) MarshalJSON() ([]byte, error)
- func (s *Stream) RemoveConsumer(cons streamer.Consumer)
- func (s *Stream) RemoveProducer(prod streamer.Producer)
- func (s *Stream) SetSource(source string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func HandleFunc ¶
func HasProducer ¶
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
func (*Consumer) MarshalJSON ¶
type Stream ¶
type Stream struct {
// contains filtered or unexported fields
}
func (*Stream) AddProducer ¶
func (*Stream) MarshalJSON ¶
func (*Stream) RemoveConsumer ¶
func (*Stream) RemoveProducer ¶
Click to show internal directories.
Click to hide internal directories.