server

package
v0.0.0-...-3e0e934 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 28, 2026 License: Apache-2.0, BSD-2-Clause Imports: 39 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Success         errCode = 0
	ParseJsonFailed         = iota + 1000
	CannotFindDevice
	TapDoesNotMatchId
)
View Source
const (
	TapAllTime         = "tap_all_time"
	TapChangeGoRoutine = "tap_change_goroutine"
	TapReadTime        = "tap_read_time"
	TapSearchFd        = "tap_search_fd"
	TapUnmarshal       = "tap_unmarshal"
	TapMapLoad         = "tap_map_load"
	TapWriteMsg        = "tap_write_msg"
)
View Source
const CodeBadRequest = 400
View Source
const CodeInternalServerError = 500
View Source
const CodeMethodNotAllowed = 405
View Source
const CodeNotFound = 404
View Source
const CodeOK = 200

Variables

View Source
var (
	ErrNotFound         = errors.New("resource not found")
	ErrMethodNotAllowed = errors.New("method not allowed")
)

Functions

func CreateTopLevelDirectories

func CreateTopLevelDirectories(config *srvconfig.Config) error

Types

type OperationServer

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

func NewOperationServer

func NewOperationServer(engine *workflow.Engine, imgExpirationSetter images.ExpirationTimeSetter) *OperationServer

func (*OperationServer) ApplyHostConfig

func (s *OperationServer) ApplyHostConfig() error

func (*OperationServer) Serve

func (s *OperationServer) Serve(l net.Listener) error

func (*OperationServer) Stop

func (s *OperationServer) Stop()

type Req

type Req struct {
	Name      string `json:"name"`
	SandboxId string `json:"sandboxId"`
}

type Server

type Server struct {
	*containerdserver.Server
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, config *srvconfig.Config) (*Server, error)

func (*Server) OnEvent

func (s *Server) OnEvent(conf *dynamConf.Config)

func (*Server) ServeDebug

func (s *Server) ServeDebug(l net.Listener) error

func (*Server) ServeGRPC

func (s *Server) ServeGRPC(l net.Listener) error

func (*Server) ServeHttp

func (s *Server) ServeHttp(l net.Listener) error

func (*Server) ServeOperation

func (s *Server) ServeOperation(l net.Listener) error

func (*Server) ServeTCP

func (s *Server) ServeTCP(l net.Listener) error

func (*Server) ServeTTRPC

func (s *Server) ServeTTRPC(l net.Listener) error

func (*Server) ServeTap

func (s *Server) ServeTap(l net.Listener) error

func (*Server) Stop

func (s *Server) Stop()

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL