server

Documentation

Index

• type Handler
• type Interceptor
• type Options
• type Server
  • func NewServer(options Options) (Server, error)

Types

type Handler

type Handler grpc.UnaryHandler

Handler is a CRI server generic request handler.

type Interceptor

type Interceptor func(context.Context, string, interface{}, Handler) (interface{}, error)

Interceptor is a hook that intercepts processing a request by a handler.

type Options

type Options struct {
	// Socket is the path of our gRPC servers unix-domain socket.
	Socket string
	// User is the user ID for our gRPC socket.
	User int
	// Group is the group ID for our gRPC socket.
	Group int
	// Mode is the permission mode bits for our gRPC socket.
	Mode os.FileMode
	// QualifyReqFn produces return context for disambiguating a CRI request/reply.
	QualifyReqFn func(interface{}) string
}

Options contains the configurable options of our CRI server.

type Server

type Server interface {
	// RegisterImageService registers the provided image service with the server.
	RegisterImageService(criv1.ImageServiceServer) error
	// RegistersRuntimeService registers the provided runtime service with the server.
	RegisterRuntimeService(criv1.RuntimeServiceServer) error
	// RegisterInterceptors registers the given interceptors with the server.
	RegisterInterceptors(map[string]Interceptor) error
	// Start starts the request processing loop (goroutine) of the server.
	Start() error
	// Stop stops the request processing loop (goroutine) of the server.
	Stop()
	// Chmod changes the permissions of the server's socket.
	Chmod(mode os.FileMode) error
	// Chown changes ownership of the server's socket.
	Chown(uid, gid int) error
}

Server is the interface we expose for controlling our CRI server.

func NewServer

func NewServer(options Options) (Server, error)

NewServer creates a new server instance.