pods

package

v0.24.0 Latest Latest Go to latest Published: Jun 6, 2022 License: Apache-2.0 Imports: 17 Imported by: 1

Details

This section is empty.

This section is empty.

func NewStream(pods typedv1.PodInterface, name string, opts *corev1.PodLogOptions) stream.Streamer

func ParsePodTemplate(httpClient http.Client, podTemplateLocation string, validate file.TypeValidator, errorMsg error) (v1beta1.PodTemplate, error)

type Container struct {
	NewStreamer stream.NewStreamerFunc
	// contains filtered or unexported fields
}

func (c *Container) LogReader(follow bool) *LogReader

func (c *Container) Status() error

type Log struct {
	PodName       string
	ContainerName string
	Log           string
}

Log represents one log message from a pod

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

func (lr *LogReader) Read() (<-chan Log, <-chan error, error)

type Pod struct {
	Name     string
	Ns       string
	Kc       k8s.Interface
	Streamer stream.NewStreamerFunc
}

func New(name, ns string, client k8s.Interface, streamer stream.NewStreamerFunc) *Pod

func NewWithDefaults(name, ns string, client k8s.Interface) *Pod

func (p *Pod) Container(c string) *Container

Container returns the an instance of Container

func (p *Pod) Get() (*corev1.Pod, error)

Get gets the pod

func (p *Pod) Stream(opt *corev1.PodLogOptions) (io.ReadCloser, error)

Stream returns the stream object for given container and mode in order to fetch the logs

func (p *Pod) Wait() (*corev1.Pod, error)

Wait wait for the pod to get up and running

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

func (s *Stream) Stream() (io.ReadCloser, error)

Stream Creates a stream object which allows reading the logs

Path	Synopsis
fake
stream