pods

package

v0.36.0 Latest Latest Go to latest Published: Mar 20, 2024 License: Apache-2.0 Imports: 18 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

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) (pod.PodTemplate, error)

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

func (c *Container) LogReader(follow, timestamps 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