ingest

Documentation

Index

• func AutocompleteContainer(cmd *cobra.Command, args []string, _ 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 *rpc.IngestInfo, mountError error) *Info
  • func (ii *Info) WriteTo(w io.Writer) (int64, error)
• type State
  • func NewState(args *Command, mountError error) State

Functions

func AutocompleteContainer

func AutocompleteContainer(cmd *cobra.Command, args []string, _ string) ([]string, cobra.ShellCompDirective)

Types

type Command

type Command struct {
	EnvFlags        env.Flags
	DockerFlags     docker.Flags
	MountFlags      mount.Flags
	WorkloadName    string // --workload || Command[0] // only valid if !localOnly
	ContainerName   string // --container
	WaitMessage     string
	ToPod           []string // --to-pod
	Cmdline         []string
	FormattedOutput 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 {
	WorkloadKind string            `json:"workload_kind,omitempty"              yaml:"workload_kind,omitempty"`
	Container    string            `json:"container,omitempty"            yaml:"container,omitempty"`
	Environment  map[string]string `json:"environment,omitempty"     yaml:"environment,omitempty"`
	Mount        *mount.Info       `json:"mount,omitempty"           yaml:"mount,omitempty"`
	PodIP        string            `json:"pod_ip,omitempty"          yaml:"pod_ip,omitempty"`
}

func NewInfo

func NewInfo(ctx context.Context, ii *rpc.IngestInfo, mountError error) *Info

func (*Info) WriteTo

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

type State

type State interface {
	CreateRequest() (*rpc.IngestRequest, error)
	Run(context.Context) error
	RunAndLeave() bool
}

func NewState

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