portforward

Documentation

Index

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

Functions

func HandlePortForwardDeleteAction

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

func HandlePortForwardUpsertAction

func HandlePortForwardUpsertAction(state *store.EngineState, action PortForwardUpsertAction)

Types

type Forward

type Forward = v1alpha1.Forward

type ObjectMeta

type ObjectMeta = metav1.ObjectMeta

type PortForward

type PortForward = v1alpha1.PortForward

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 PortForwardUpsertAction

type PortForwardUpsertAction struct {
	PortForward *PortForward
}

func NewPortForwardUpsertAction

func NewPortForwardUpsertAction(pf *PortForward) PortForwardUpsertAction

func (PortForwardUpsertAction) Action

func (PortForwardUpsertAction) Action()

func (PortForwardUpsertAction) Summarize

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

type Subscriber

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

func NewSubscriber

func NewSubscriber(kClient k8s.Client, ctrlClient ctrlclient.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) error