podlogstream

Documentation

Index

• type ContainerLogStreamStatus
• type Controller
  • func NewController(ctx context.Context, client ctrlclient.Client, st store.RStore, ...) *Controller
  • func (r *Controller) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (c *Controller) SetClient(client ctrlclient.Client)
  • func (c *Controller) SetupWithManager(mgr ctrl.Manager) error
  • func (c *Controller) TearDown(ctx context.Context)
• type ObjectMeta
• type PodLogStream
• type PodLogStreamSpec
• type PodLogStreamStatus
• type PodLogWatch
• type PodSource
  • func NewPodSource(ctx context.Context, kClient k8s.Client) *PodSource
  • func (s *PodSource) Start(ctx context.Context, handler handler.EventHandler, ...) error
  • func (s *PodSource) TearDown()

Types

type ContainerLogStreamStatus

type ContainerLogStreamStatus = v1alpha1.ContainerLogStreamStatus

type Controller

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

Reconciles the PodLogStream API object.

Collects logs from deployed containers.

func NewController

func NewController(ctx context.Context, client ctrlclient.Client, st store.RStore, kClient k8s.Client) *Controller

func (*Controller) Reconcile

func (r *Controller) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

Reconcile the given stream against what we're currently tracking.

func (*Controller) SetClient

func (c *Controller) SetClient(client ctrlclient.Client)

func (*Controller) SetupWithManager

func (c *Controller) SetupWithManager(mgr ctrl.Manager) error

func (*Controller) TearDown

func (c *Controller) TearDown(ctx context.Context)

type ObjectMeta

type ObjectMeta = metav1.ObjectMeta

type PodLogStream

type PodLogStream = v1alpha1.PodLogStream

type PodLogStreamSpec

type PodLogStreamSpec = v1alpha1.PodLogStreamSpec

type PodLogStreamStatus

type PodLogStreamStatus = v1alpha1.PodLogStreamStatus

type PodLogWatch

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

type PodSource

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

Helper struct that captures Pod changes and queues up a Reconcile() call for any PodLogStream watching that pod.

func NewPodSource

func NewPodSource(ctx context.Context, kClient k8s.Client) *PodSource

func (*PodSource) Start

func (s *PodSource) Start(ctx context.Context, handler handler.EventHandler, q workqueue.RateLimitingInterface, ps ...predicate.Predicate) error

func (*PodSource) TearDown

func (s *PodSource) TearDown()