oci_judge

Documentation

Index

• Variables
• type ContainerdJudgeConfig
• type ContainerdJudgeOption
  • func WithContainerdAddress(address string) ContainerdJudgeOption
  • func WithContainerdCheckerPlugin(plugin tarus_io.Router) ContainerdJudgeOption
  • func WithContainerdCompilerPlugin(plugin tarus_compiler.Compiler) ContainerdJudgeOption
  • func WithContainerdConcurrencyNum(cc int) ContainerdJudgeOption
  • func WithContainerdJudgeCachePath(path string) ContainerdJudgeOption
  • func WithContainerdJudgeSeccomp(sc *specs.LinuxSeccomp) ContainerdJudgeOption
  • func WithContainerdJudgeWorkdir(wd string) ContainerdJudgeOption
• type ContainerdJudgeServiceServer
  • func NewContainerdServer(options ...ContainerdJudgeOption) (svc *ContainerdJudgeServiceServer, err error)
  • func (c *ContainerdJudgeServiceServer) Close() error
  • func (c *ContainerdJudgeServiceServer) CompileProgram(ctx context.Context, request *tarus.CompileProgramRequest) (*tarus.CompileProgramResponse, error)
  • func (c *ContainerdJudgeServiceServer) CopyFile(ctx context.Context, request *tarus.CopyFileRequest) (*emptypb.Empty, error)
  • func (c *ContainerdJudgeServiceServer) CreateContainer(ctx context.Context, request *tarus.CreateContainerRequest) (_ *emptypb.Empty, err error)
  • func (c *ContainerdJudgeServiceServer) Handshake(_ context.Context, request *tarus.HandshakeRequest) (*tarus.HandshakeResponse, error)
  • func (c *ContainerdJudgeServiceServer) ImportOCIArchive(ctx context.Context, fp string) error
  • func (c *ContainerdJudgeServiceServer) ImportOCIArchiveR(ctx context.Context, f io.Reader, ref string) error
  • func (c *ContainerdJudgeServiceServer) MakeJudge(rawCtx context.Context, request *tarus.MakeJudgeRequest) (*tarus.MakeJudgeResponse, error)
  • func (c *ContainerdJudgeServiceServer) QueryJudge(ctx context.Context, request *tarus.QueryJudgeRequest) (*tarus.QueryJudgeResponse, error)
  • func (c *ContainerdJudgeServiceServer) RemoveContainer(ctx context.Context, request *tarus.RemoveContainerRequest) (*emptypb.Empty, error)
• type JudgeEnvironment
• type JudgeHint
• type JudgeMetric
• type MemoryJudgeConfig
• type OCIJudgeServiceServer

Variables

var (
	ContainerdJudgeVersion = []byte("oci-v1.0.0")
)

Types

type ContainerdJudgeConfig

type ContainerdJudgeConfig struct {
	Address            string              `json:"address"`
	JudgeCachePath     string              `json:"judge_cache_path"`
	Concurrency        int                 `json:"concurrency"`
	JudgeWorkdir       string              `json:"judge_workdir"`
	JudgeSeccompOption *specs.LinuxSeccomp `json:"judge_seccomp_option"`
}

type ContainerdJudgeOption

type ContainerdJudgeOption func(svc *ContainerdJudgeServiceServer) error

func WithContainerdAddress

func WithContainerdAddress(address string) ContainerdJudgeOption

func WithContainerdCheckerPlugin

func WithContainerdCheckerPlugin(plugin tarus_io.Router) ContainerdJudgeOption

func WithContainerdCompilerPlugin

func WithContainerdCompilerPlugin(plugin tarus_compiler.Compiler) ContainerdJudgeOption

func WithContainerdConcurrencyNum

func WithContainerdConcurrencyNum(cc int) ContainerdJudgeOption

func WithContainerdJudgeCachePath

func WithContainerdJudgeCachePath(path string) ContainerdJudgeOption

func WithContainerdJudgeSeccomp

func WithContainerdJudgeSeccomp(sc *specs.LinuxSeccomp) ContainerdJudgeOption

func WithContainerdJudgeWorkdir

func WithContainerdJudgeWorkdir(wd string) ContainerdJudgeOption

type ContainerdJudgeServiceServer

type ContainerdJudgeServiceServer struct {
	tarus.UnimplementedJudgeServiceServer
	// contains filtered or unexported fields
}

func NewContainerdServer

func NewContainerdServer(options ...ContainerdJudgeOption) (svc *ContainerdJudgeServiceServer, err error)

func (*ContainerdJudgeServiceServer) Close

func (c *ContainerdJudgeServiceServer) Close() error

func (*ContainerdJudgeServiceServer) CompileProgram

func (c *ContainerdJudgeServiceServer) CompileProgram(ctx context.Context, request *tarus.CompileProgramRequest) (*tarus.CompileProgramResponse, error)

func (*ContainerdJudgeServiceServer) CopyFile

func (c *ContainerdJudgeServiceServer) CopyFile(ctx context.Context, request *tarus.CopyFileRequest) (*emptypb.Empty, error)

func (*ContainerdJudgeServiceServer) CreateContainer

func (c *ContainerdJudgeServiceServer) CreateContainer(ctx context.Context, request *tarus.CreateContainerRequest) (_ *emptypb.Empty, err error)

func (*ContainerdJudgeServiceServer) Handshake

func (c *ContainerdJudgeServiceServer) Handshake(_ context.Context, request *tarus.HandshakeRequest) (*tarus.HandshakeResponse, error)

func (*ContainerdJudgeServiceServer) ImportOCIArchive

func (c *ContainerdJudgeServiceServer) ImportOCIArchive(ctx context.Context, fp string) error

func (*ContainerdJudgeServiceServer) ImportOCIArchiveR

func (c *ContainerdJudgeServiceServer) ImportOCIArchiveR(ctx context.Context, f io.Reader, ref string) error

func (*ContainerdJudgeServiceServer) MakeJudge

func (c *ContainerdJudgeServiceServer) MakeJudge(rawCtx context.Context, request *tarus.MakeJudgeRequest) (*tarus.MakeJudgeResponse, error)

func (*ContainerdJudgeServiceServer) QueryJudge

func (c *ContainerdJudgeServiceServer) QueryJudge(ctx context.Context, request *tarus.QueryJudgeRequest) (*tarus.QueryJudgeResponse, error)

func (*ContainerdJudgeServiceServer) RemoveContainer

func (c *ContainerdJudgeServiceServer) RemoveContainer(ctx context.Context, request *tarus.RemoveContainerRequest) (*emptypb.Empty, error)

type JudgeEnvironment

type JudgeEnvironment struct {
	ProcessSpec    specs.Process
	MemoryLimit    int64
	StackLimit     int64
	CpuTime        int64
	CpuHard        int64
	ChannelFactory tarus_io.ChannelFactory
	JudgeIO        tarus_io.Factory
}

type JudgeHint

type JudgeHint struct {
	Code          int    `json:"code" yaml:"code"`
	Signal        string `json:"signal,omitempty" yaml:"signal,omitempty"`
	CheckerResult string `json:"checker_result" yaml:"checker_result"`
}

type JudgeMetric

type JudgeMetric struct {
	ContainerInfo *types.Metric
	Code          uint32
	IsTimeout     bool
	StartedAt     time.Time
	ExitedAt      time.Time
	JudgeReport   []byte
}

type MemoryJudgeConfig

type MemoryJudgeConfig struct {
	CallbackKey []byte
	ImageId     string
	ProcessArgs []string
	Input       io.ReadCloser
	Output      io.WriteCloser
	Timeout     int64 // in microsecond
	Memory      int64 // in bytes
}

type OCIJudgeServiceServer

type OCIJudgeServiceServer interface {
	tarus.JudgeServiceServer
}