intercept

Documentation

Index

• func DescribeIntercepts(ctx context.Context, iis []*manager.InterceptInfo, igs []*rpc.IngestInfo, ...) string
• func PreviewURL(pu string) string
• func Result(r *connector.InterceptResult, err error) error
• func ValidArgs(cmd *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective)
• type Command
  • func (c *Command) AddFlags(cmd *cobra.Command)
  • func (c *Command) Run(cmd *cobra.Command, positional []string) error
  • func (c *Command) Validate(cmd *cobra.Command, positional []string) error
• type Info
  • func NewInfo(ctx context.Context, ii *manager.InterceptInfo, ro bool, mountError error) *Info
  • func (ii *Info) WriteTo(w io.Writer) (int64, error)
• type Ingress
  • func NewIngress(ps *manager.PreviewSpec) *Ingress
• type State
  • func NewState(args *Command, mountError error) State

Functions

func DescribeIntercepts

func DescribeIntercepts(ctx context.Context, iis []*manager.InterceptInfo, igs []*rpc.IngestInfo, volumeMountsPrevented error, debug bool) string

func PreviewURL

func PreviewURL(pu string) string

func Result

func Result(r *connector.InterceptResult, err error) error

func ValidArgs

func ValidArgs(cmd *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective)

Types

type Command

type Command struct {
	EnvFlags      env.Flags
	DockerFlags   docker.Flags
	MountFlags    mount.Flags
	Name          string // Command[0] || `${Command[0]}-${--namespace}` // which depends on a combinationof --workload and --namespace
	AgentName     string // --workload || Command[0] // only valid if !localOnly
	Port          string // --port
	ServiceName   string // --service
	ContainerName string // --container
	Address       string // --address

	Replace bool // whether --replace was passed

	ToPod []string // --to-pod

	Cmdline []string // Command[1:]

	Mechanism       string // --mechanism tcp
	MechanismArgs   []string
	ExtendedInfo    []byte
	WaitMessage     string // Message printed when a containerized intercept handler is started and waiting for an interrupt
	FormattedOutput bool
	DetailedOutput  bool
	Silent          bool
}

func (*Command) AddFlags

func (c *Command) AddFlags(cmd *cobra.Command)

func (*Command) Run

func (c *Command) Run(cmd *cobra.Command, positional []string) error

func (*Command) Validate

func (c *Command) Validate(cmd *cobra.Command, positional []string) error

type Info

type Info struct {
	ID            string            `json:"id,omitempty"              yaml:"id,omitempty"`
	Name          string            `json:"name,omitempty"            yaml:"name,omitempty"`
	Disposition   string            `json:"disposition,omitempty"     yaml:"disposition,omitempty"`
	Message       string            `json:"message,omitempty"         yaml:"message,omitempty"`
	WorkloadKind  string            `json:"workload_kind,omitempty"   yaml:"workload_kind,omitempty"`
	TargetHost    string            `json:"target_host,omitempty"     yaml:"target_host,omitempty"`
	TargetPort    int32             `json:"target_port,omitempty"     yaml:"target_port,omitempty"`
	ServiceUID    string            `json:"service_uid,omitempty"     yaml:"service_uid,omitempty"`
	ServicePortID string            `json:"service_port_id,omitempty" yaml:"service_port_id,omitempty"` // ServicePortID is deprecated. Use PortID
	PortID        string            `json:"port_id,omitempty"         yaml:"port_id,omitempty"`
	ContainerPort int32             `json:"container_port,omitempty"  yaml:"container_port,omitempty"`
	Environment   map[string]string `json:"environment,omitempty"     yaml:"environment,omitempty"`
	Mount         *mount.Info       `json:"mount,omitempty"           yaml:"mount,omitempty"`
	FilterDesc    string            `json:"filter_desc,omitempty"     yaml:"filter_desc,omitempty"`
	Metadata      map[string]string `json:"metadata,omitempty"        yaml:"metadata,omitempty"`
	HttpFilter    []string          `json:"http_filter,omitempty"     yaml:"http_filter,omitempty"`
	Global        bool              `json:"global,omitempty"          yaml:"global,omitempty"`
	PreviewURL    string            `json:"preview_url,omitempty"     yaml:"preview_url,omitempty"`
	Ingress       *Ingress          `json:"ingress,omitempty"         yaml:"ingress,omitempty"`
	PodIP         string            `json:"pod_ip,omitempty"          yaml:"pod_ip,omitempty"`
	// contains filtered or unexported fields
}

func NewInfo

func NewInfo(ctx context.Context, ii *manager.InterceptInfo, ro bool, mountError error) *Info

func (*Info) WriteTo

func (ii *Info) WriteTo(w io.Writer) (int64, error)

type Ingress

type Ingress struct {
	Host   string `json:"host,omitempty"    yaml:"host,omitempty"`
	Port   int32  `json:"port,omitempty"    yaml:"port,omitempty"`
	UseTLS bool   `json:"use_tls,omitempty" yaml:"use_tls,omitempty"`
	L5Host string `json:"l5host,omitempty"  yaml:"l5host,omitempty"`
}

func NewIngress

func NewIngress(ps *manager.PreviewSpec) *Ingress

type State

type State interface {
	CreateRequest(context.Context) (*connector.CreateInterceptRequest, error)
	Name() string
	Run(context.Context) (*Info, error)
	RunAndLeave() bool
}

func NewState

func NewState(
	args *Command,
	mountError error,
) State