kubernetes/staging/src/k8s.io/kubectl/pkg/cmd/logs/logs.go

const logsUsageStr …

var logsLong …

var logsExample …

var selectorTail …

var logsUsageErrStr …

const defaultPodLogsTimeout …

type LogsOptions …

func NewLogsOptions(streams genericiooptions.IOStreams) *LogsOptions { … }

// NewCmdLogs creates a new pod logs command
func NewCmdLogs(f cmdutil.Factory, streams genericiooptions.IOStreams) *cobra.Command { … }

func (o *LogsOptions) AddFlags(cmd *cobra.Command) { … }

func (o *LogsOptions) ToLogOptions() (*corev1.PodLogOptions, error) { … }

func (o *LogsOptions) Complete(f cmdutil.Factory, cmd *cobra.Command, args []string) error { … }

func (o LogsOptions) Validate() error { … }

// RunLogs retrieves a pod log
func (o LogsOptions) RunLogs() error { … }

func (o LogsOptions) parallelConsumeRequest(ctx context.Context, requests map[corev1.ObjectReference]rest.ResponseWrapper) error { … }

func (o LogsOptions) sequentialConsumeRequest(ctx context.Context, requests map[corev1.ObjectReference]rest.ResponseWrapper) error { … }

func (o LogsOptions) addPrefixIfNeeded(ref corev1.ObjectReference, writer io.Writer) io.Writer { … }

// DefaultConsumeRequest reads the data from request and writes into
// the out writer. It buffers data from requests until the newline or io.EOF
// occurs in the data, so it doesn't interleave logs sub-line
// when running concurrently.
//
// A successful read returns err == nil, not err == io.EOF.
// Because the function is defined to read from request until io.EOF, it does
// not treat an io.EOF as an error to be reported.
func DefaultConsumeRequest(ctx context.Context, request rest.ResponseWrapper, out io.Writer) error { … }

type prefixingWriter …

func (pw *prefixingWriter) Write(p []byte) (int, error) { … }