podlogstream

Documentation

Index

• type ContainerLogStreamStatus
• type Controller
  • func NewController(ctx context.Context, client ctrlclient.Client, scheme *runtime.Scheme, ...) *Controller
  • func (c *Controller) CreateBuilder(mgr ctrl.Manager) (*builder.Builder, error)
  • func (c *Controller) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (c *Controller) TearDown(ctx context.Context)
• type ObjectMeta
• type PodLogStream
• type PodLogStreamSpec
• type PodLogStreamStatus
• type PodSource
  • func NewPodSource(ctx context.Context, kClient k8s.Client, scheme *runtime.Scheme, ...) *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, scheme *runtime.Scheme, st store.RStore, kClient k8s.Client, podSource *PodSource, clock clockwork.Clock) *Controller

func (*Controller) CreateBuilder

func (c *Controller) CreateBuilder(mgr ctrl.Manager) (*builder.Builder, error)

func (*Controller) Reconcile

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

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

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 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, scheme *runtime.Scheme, clock clockwork.Clock) *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()