stream

Documentation

Overview

Package stream has api stream utility methods that components can use for directing output to a stream receiver

Index

• func GetStreamFunc(messageReceiverFunc func() MessageReceiver, streamType, agentType string) func(w http.ResponseWriter, r *http.Request)
• type MessageReceiver

Functions

func GetStreamFunc

func GetStreamFunc(messageReceiverFunc func() MessageReceiver, streamType, agentType string) func(w http.ResponseWriter, r *http.Request)

GetStreamFunc returns a handlerfunc that handles request to stream output to the desired receiver

Types

type MessageReceiver

type MessageReceiver interface {
	SetEnabled(e bool) bool
	Filter(filters *diagnostic.Filters, done <-chan struct{}) <-chan string
}

MessageReceiver is an exported interface for a valid receiver of streamed output