server

Documentation

Index

• func Entry(port int, labelStore labelstore.LabelStore, gadgetID string, ...) error
• type Server
  • func NewServer(labelStore labelstore.LabelStore, gadgetID string, maxBatchSize int, ...) *Server
  • func (s *Server) Listen(port int) error

Functions

func Entry

func Entry(
	port int,
	labelStore labelstore.LabelStore,
	gadgetID string,
	defaultRef *gadget.DataRef,
	maxBatchSize int,
	log *zap.Logger,
) error

Types

type Server

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

Server is a server that samples frames from an input gadget and allows the user to label those frames. The labels are stored in a database, and they can be sampled like any other gadget output.

func NewServer

func NewServer(
	labelStore labelstore.LabelStore,
	gadgetID string,
	maxBatchSize int,
	defaultRef *gadget.DataRef,
	log *zap.Logger,
) *Server

NewServer creates a new filter server.

func (*Server) Listen

func (s *Server) Listen(port int) error

Listen starts the filter server.