Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DynamicSource ¶
type DynamicSource struct {
// contains filtered or unexported fields
}
func NewDynamicSource ¶
func NewDynamicSource() *DynamicSource
func (*DynamicSource) Close ¶
func (o *DynamicSource) Close() error
func (*DynamicSource) Events ¶
func (o *DynamicSource) Events() <-chan *proto.Event
func (*DynamicSource) SendEvent ¶
func (o *DynamicSource) SendEvent(event *proto.Event)
type EventReader ¶
type EventReader struct {
// contains filtered or unexported fields
}
func NewEventReader ¶
func NewEventReader(reader io.Reader) *EventReader
type EventWriter ¶
type EventWriter struct {
// contains filtered or unexported fields
}
func NewEventWriter ¶
func NewEventWriter(writer io.WriteCloser) *EventWriter
func (*EventWriter) Close ¶
func (writer *EventWriter) Close() error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.