events

Documentation

Index

• type DynamicSource
  • func NewDynamicSource() *DynamicSource
  • func (o *DynamicSource) Close() error
  • func (o *DynamicSource) Events() <-chan *proto.Event
  • func (o *DynamicSource) Load(log logr.Logger) error
  • func (o *DynamicSource) SendEvent(event *proto.Event)
• type EventReader
  • func NewEventReader(reader io.Reader) *EventReader
  • func (reader *EventReader) Read() (*pb.Event, error)
• type EventWriter
  • func NewEventWriter(writer io.WriteCloser) *EventWriter
  • func (writer *EventWriter) Close() error
  • func (writer *EventWriter) Write(event *pb.Event) error

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) Load

func (o *DynamicSource) Load(log logr.Logger) error

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

func (*EventReader) Read

func (reader *EventReader) Read() (*pb.Event, error)

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

func (*EventWriter) Write

func (writer *EventWriter) Write(event *pb.Event) error