server

Documentation

Index

• func BytesArrayToStrArray(ba [][]byte) []string
• func Len(sm *sync.Map) int
• func NewSN() uint32
• type Commander
  • func NewCommander(in *apis.Command) *Commander
• type Executor
  • func (e *Executor) ExecCommand(ctx context.Context, req *apis.Command) (*apis.Sn, error)
  • func (e *Executor) FetchStderr(sn *apis.Sn, s apis.Executor_FetchStderrServer) error
  • func (e *Executor) FetchStdout(sn *apis.Sn, s apis.Executor_FetchStdoutServer) error
  • func (e *Executor) Kill(ctx context.Context, req *apis.Sn) (*apis.Error, error)
  • func (e *Executor) SendInput(s apis.Executor_SendInputServer) error
  • func (e *Executor) Start(ctx context.Context, req *apis.StartInput) (*apis.StartResponse, error)
  • func (e *Executor) Wait(ctx context.Context, in *apis.Sn) (*apis.WaitResponse, error)

Functions

func BytesArrayToStrArray

func BytesArrayToStrArray(ba [][]byte) []string

func Len

func Len(sm *sync.Map) int

func NewSN

func NewSN() uint32

Types

type Commander

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

func NewCommander

func NewCommander(in *apis.Command) *Commander

type Executor

type Executor struct{}

func (*Executor) ExecCommand

func (e *Executor) ExecCommand(ctx context.Context, req *apis.Command) (*apis.Sn, error)

func (*Executor) FetchStderr

func (e *Executor) FetchStderr(sn *apis.Sn, s apis.Executor_FetchStderrServer) error

func (*Executor) FetchStdout

func (e *Executor) FetchStdout(sn *apis.Sn, s apis.Executor_FetchStdoutServer) error

func (*Executor) Kill

func (e *Executor) Kill(ctx context.Context, req *apis.Sn) (*apis.Error, error)

func (*Executor) SendInput

func (e *Executor) SendInput(s apis.Executor_SendInputServer) error

func (*Executor) Start

func (e *Executor) Start(ctx context.Context, req *apis.StartInput) (*apis.StartResponse, error)

func (*Executor) Wait

func (e *Executor) Wait(ctx context.Context, in *apis.Sn) (*apis.WaitResponse, error)