reader

package

v0.1.5 Latest Latest Go to latest Published: Feb 10, 2021 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type EmptyReader struct{}

func (e *EmptyReader) Read() chan interface{}

func (e *EmptyReader) Run(ctx context.Context) error

type EventReader interface {
	Read() chan interface{}
	Run(ctx context.Context) error
}

func NewEventReader(src interface{}) EventReader

NewEventReader attempts to create an EventReader of a known type Currently only knows: *kernel.Probe, *redis.PubSub

func NewKernelReader(probe *kernel.Probe) EventReader

NewKernelReader creates a kernel event reader from a `kernel.Probe` context

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

KernelReader handles callbacks from the kernel and implements a higher level channel-based emission to clients

func (k *KernelReader) Read() chan interface{}

Read returns the channel of processed events.

func (k *KernelReader) Run(ctx context.Context) error

Run starts up the kernel reader in its own goroutine, then simply reads the raw messages in, and pipes them to the KernelEvent channel.