logs

Documentation

Index

• func Logs(client *kubernetes.Clientset, dynamicClient *dynamic.DynamicClient, ...)
• type RunningLogStreams
  • func NewRunningLogStreams() *RunningLogStreams
  • func (l *RunningLogStreams) Stop(namespace string, deploymentName string)
  • func (l *RunningLogStreams) StopAll()

Functions

func Logs

func Logs(
	client *kubernetes.Clientset,
	dynamicClient *dynamic.DynamicClient,
	namespace string,
	deploymentName string,
	clientHub *streaming.ClientHub,
	runningLogStreams *RunningLogStreams,
)

Types

type RunningLogStreams

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

func NewRunningLogStreams

func NewRunningLogStreams() *RunningLogStreams

func (*RunningLogStreams) Stop

func (l *RunningLogStreams) Stop(namespace string, deploymentName string)

func (*RunningLogStreams) StopAll

func (l *RunningLogStreams) StopAll()