server

Documentation

Index

• type Marker
• type Server
  • func NewServer(labelStore labelstore.LabelStore, initInputRef *gadget.DataRef, ...) *Server
  • func (s *Server) ListenAndServe(port int) error

Types

type Marker

type Marker struct {
	Start time.Duration
	End   time.Duration
}

type Server

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

func NewServer

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

func (*Server) ListenAndServe

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