func (o LogsOptions) RunLogs() error {
	requests, err := o.LogsForObject(o.RESTClientGetter, o.Object, o.Options, o.GetPodTimeout, o.AllContainers)
	if err != nil {
		return err
	}

	if o.Follow && len(requests) > 1 {
		if len(requests) > o.MaxFollowConcurrency {
			return fmt.Errorf(
				"you are attempting to follow %d log streams, but maximum allowed concurrency is %d, use --max-log-requests to increase the limit",
				len(requests), o.MaxFollowConcurrency,
			)
		}

		return o.parallelConsumeRequest(requests)
	}

	return o.sequentialConsumeRequest(requests)
}
// RunLogs retrieves a pod log
RunLogs retrieves a pod log
// RunLogs retrieves a pod log
func (o LogsOptions) RunLogs() error {
	requests, err := o.LogsForObject(o.RESTClientGetter, o.Object, o.Options, o.GetPodTimeout, o.AllContainers)
	if err != nil {
		return err
	}
	if o.Follow && len(requests) > 1 {
		if len(requests) > o.MaxFollowConcurrency {
			return fmt.Errorf(
				"you are attempting to follow %d log streams, but maximum allowed concurrency is %d, use --max-log-requests to increase the limit",
				len(requests), o.MaxFollowConcurrency,
			)
		}
		return o.parallelConsumeRequest(requests)
	}
	return o.sequentialConsumeRequest(requests)
}
func ( o LogsOptions ) RunLogs ( ) error { requests , err := o . LogsForObject ( o . RESTClientGetter , o . Object , o . Options , o . GetPodTimeout , o . AllContainers ) if err != nil { return err } if o . Follow && len ( requests ) > 1 { if len ( requests ) > o . MaxFollowConcurrency { return fmt . Errorf ( " " , len ( requests ) , o . MaxFollowConcurrency , ) } return o . parallelConsumeRequest ( requests ) } return o . sequentialConsumeRequest ( requests ) }
RunLogs retrieves a pod log
RunLogs retrieves a pod log