reader

package

v0.1.2 Latest Latest Go to latest Published: Nov 17, 2020 License: Apache-2.0 Imports: 7 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

func NewRedisReader(pubsub *redis.PubSub) EventReader

func NewTopologyReader(t *topology.Topology) EventReader

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.

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

RedisReader reads events from a redis client PubSub, And outputs as a event.Trace record into its backlog.

func (r RedisReader) Read() chan interface{}

func (r *RedisReader) Run(ctx context.Context) error

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

func (t *TopologyReader) Read() chan interface{}

func (t *TopologyReader) Run(ctx context.Context) error