portforward

Documentation

Index

• func HandlePortForwardCreateAction(state *store.EngineState, action PortForwardCreateAction)
• func HandlePortForwardDeleteAction(state *store.EngineState, action PortForwardDeleteAction)
• type Forward
• type ObjectMeta
• type PortForward
• type PortForwardCreateAction
  • func NewPortForwardCreateAction(pf *PortForward) PortForwardCreateAction
  • func (PortForwardCreateAction) Action()
  • func (a PortForwardCreateAction) Summarize(s *store.ChangeSummary)
• type PortForwardDeleteAction
  • func NewPortForwardDeleteAction(pfName string) PortForwardDeleteAction
  • func (PortForwardDeleteAction) Action()
  • func (a PortForwardDeleteAction) Summarize(s *store.ChangeSummary)
• type PortForwardSpec
• type PortForwardStatus
• type Subscriber
  • func NewSubscriber(kClient k8s.Client) *Subscriber
  • func (s *Subscriber) DisableForTesting()
  • func (s *Subscriber) OnChange(ctx context.Context, st store.RStore, summary store.ChangeSummary)

Functions

func HandlePortForwardCreateAction

func HandlePortForwardCreateAction(state *store.EngineState, action PortForwardCreateAction)

func HandlePortForwardDeleteAction

func HandlePortForwardDeleteAction(state *store.EngineState, action PortForwardDeleteAction)

Types

type Forward

type Forward = v1alpha1.Forward

type ObjectMeta

type ObjectMeta = metav1.ObjectMeta

type PortForward

type PortForward = v1alpha1.PortForward

type PortForwardCreateAction

type PortForwardCreateAction struct {
	PortForward *PortForward
}

func NewPortForwardCreateAction

func NewPortForwardCreateAction(pf *PortForward) PortForwardCreateAction

func (PortForwardCreateAction) Action

func (PortForwardCreateAction) Action()

func (PortForwardCreateAction) Summarize

func (a PortForwardCreateAction) Summarize(s *store.ChangeSummary)

type PortForwardDeleteAction

type PortForwardDeleteAction struct {
	Name string
}

func NewPortForwardDeleteAction

func NewPortForwardDeleteAction(pfName string) PortForwardDeleteAction

func (PortForwardDeleteAction) Action

func (PortForwardDeleteAction) Action()

func (PortForwardDeleteAction) Summarize

func (a PortForwardDeleteAction) Summarize(s *store.ChangeSummary)

type PortForwardSpec

type PortForwardSpec = v1alpha1.PortForwardSpec

type PortForwardStatus

type PortForwardStatus = v1alpha1.PortForwardStatus

type Subscriber

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

func NewSubscriber

func NewSubscriber(kClient k8s.Client) *Subscriber

func (*Subscriber) DisableForTesting

func (s *Subscriber) DisableForTesting()

func (*Subscriber) OnChange

func (s *Subscriber) OnChange(ctx context.Context, st store.RStore, summary store.ChangeSummary)