proxy

Documentation

Index

• type Proxy
  • func NewProxyServer(bufferSize int, cleanup func(wg *sync.WaitGroup, cancel context.CancelFunc)) *Proxy
  • func (s *Proxy) AddPacket(packetStream capture.AgentService_AddPacketServer) error
  • func (s *Proxy) GetPackets(in *capture.Empty, stream capture.ClientService_GetPacketsServer) error
  • func (s *Proxy) Ready(ctx context.Context, pod *capture.Pod) (*capture.Empty, error)

Types

type Proxy

type Proxy struct {
	capture.UnimplementedAgentServiceServer
	capture.UnimplementedClientServiceServer
	// contains filtered or unexported fields
}

func NewProxyServer

func NewProxyServer(bufferSize int, cleanup func(wg *sync.WaitGroup, cancel context.CancelFunc)) *Proxy

func (*Proxy) AddPacket

func (s *Proxy) AddPacket(packetStream capture.AgentService_AddPacketServer) error

func (*Proxy) GetPackets

func (s *Proxy) GetPackets(in *capture.Empty, stream capture.ClientService_GetPacketsServer) error

func (*Proxy) Ready

func (s *Proxy) Ready(ctx context.Context, pod *capture.Pod) (*capture.Empty, error)