logs

Documentation

Index

• Variables
• type Pipe
• type PodLogPrinter
  • func NewPodLogPrinter(podNames []string, logArgs *podlogs.OuterRequestArgs) (*PodLogPrinter, error)
  • func (slp *PodLogPrinter) AcceptLogs(writeCloser io.WriteCloser) (int, error)
  • func (slp *PodLogPrinter) CheckPodIsInJob() error
  • func (slp *PodLogPrinter) Print() (int, error)
  • func (slp *PodLogPrinter) PrintMultiPodsHelp()

Variables

var (
	ErrPodNotFound      = errors.New(`no logs return,because not found instance`)
	ErrTooManyPodsFound = errors.New(`too many pods found in the job,`)
)

Types

type Pipe

type Pipe struct {
	Reader io.ReadCloser
	Writer io.WriteCloser
}

type PodLogPrinter

type PodLogPrinter struct {
	PodNames []string
	PodLog   *podlogs.PodLog
	Pipe
}

func NewPodLogPrinter

func NewPodLogPrinter(podNames []string, logArgs *podlogs.OuterRequestArgs) (*PodLogPrinter, error)

func (*PodLogPrinter) AcceptLogs

func (slp *PodLogPrinter) AcceptLogs(writeCloser io.WriteCloser) (int, error)

func (*PodLogPrinter) CheckPodIsInJob

func (slp *PodLogPrinter) CheckPodIsInJob() error

func (*PodLogPrinter) Print

func (slp *PodLogPrinter) Print() (int, error)

func (*PodLogPrinter) PrintMultiPodsHelp

func (slp *PodLogPrinter) PrintMultiPodsHelp()