k8s

type AgentOpt func(o AgentOpts) AgentOpts

type AgentOpts struct {
	SnapshotLen  int32         // https://www.tcpdump.org/manpages/pcap_set_snaplen.3pcap.html
	Promiscuous  bool          // https://www.tcpdump.org/manpages/pcap_set_promisc.3pcap.html
	Device       string        // https://www.tcpdump.org/manpages/pcap_create.3pcap.html
	Timeout      time.Duration // https://www.tcpdump.org/manpages/pcap_set_timeout.3pcap.html
	TargetIP     string        // proxy endpoint address to send packet via gRPC
	TargetPort   int           // proxy endpoint port to send packet via gRPC
	UUID         string        // kpture uuid used in  ephemeral container name
	SetupTimeout time.Duration // timeout for ephemeral container injection
}

type Forwarder interface {
	ForwardPorts() error
}

type KubeClient struct {
	Clientset *kubernetes.Clientset
	RestConf  *rest.Config
	Namespace string
}

type KubeEphemeralHandler interface {
	Get(ctx context.Context, name string, opts metav1.GetOptions) (*v1.Pod, error)
	UpdateEphemeralContainers(ctx context.Context, podName string, pod *v1.Pod, opts metav1.UpdateOptions) (*v1.Pod, error)
	List(ctx context.Context, opts metav1.ListOptions) (*v1.PodList, error)
}

type KubeProxyHandler interface {
	Get(ctx context.Context, name string, opts metav1.GetOptions) (*v1.Pod, error)
	Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error
	Create(ctx context.Context, pod *v1.Pod, opts metav1.CreateOptions) (*v1.Pod, error)
}

type PodLister interface {
	List(ctx context.Context, opts metav1.ListOptions) (*v1.PodList, error)
}

type ProxyOpt func(o ProxyOpts) ProxyOpts

type ProxyOpts struct {
	ServerPort   int32
	UUID         string
	SetupTimeout time.Duration // timeout for pod creation
}

type VersionGetter interface {
	ServerVersion() (*version.Info, error)
}