isolate

Documentation

Index

• Constants
• func GetLogger(ctx context.Context) log.Interface
• func IsCancelled(ctx context.Context) bool
• func NotifyAbouStart(ch chan ProcessOutput)
• type ArgsUnpacker
• type Box
• type BoxConfig
• type Boxes
• type ConnectionHandler
  • func NewConnectionHandler(ctx context.Context) (*ConnectionHandler, error)
  • func (h *ConnectionHandler) HandleConn(conn io.ReadWriteCloser)
• type Decoder
• type Dispatcher
• type Downstream
• type Encoder
• type Process
• type ProcessOutput
• type Profile
  • func (p Profile) Type() string

Constants

const (
	BoxesTag = "isolate.boxes.tag"
)

Functions

func GetLogger

func GetLogger(ctx context.Context) log.Interface

func IsCancelled

func IsCancelled(ctx context.Context) bool

IsCancelled checks whether context is cancelled

func NotifyAbouStart

func NotifyAbouStart(ch chan ProcessOutput)

Types

type ArgsUnpacker

type ArgsUnpacker interface {
	Unpack(in interface{}, out ...interface{}) error
}

type Box

type Box interface {
	Spool(ctx context.Context, name string, opts Profile) error
	Spawn(ctx context.Context, opts Profile, name, executable string, args, env map[string]string) (Process, error)
}

type BoxConfig

type BoxConfig map[string]interface{}

type Boxes

type Boxes map[string]Box

type ConnectionHandler

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

ConnectionHandler provides method to handle accepted connection for Listener

func NewConnectionHandler

func NewConnectionHandler(ctx context.Context) (*ConnectionHandler, error)

NewConnectionHandler creates new ConnectionHandler

func (*ConnectionHandler) HandleConn

func (h *ConnectionHandler) HandleConn(conn io.ReadWriteCloser)

type Decoder

type Decoder interface {
	Decode(interface{}) error
}

Decoder decodes messages from Cocaine-runtime

type Dispatcher

type Dispatcher interface {
	Handle(msg *message) (Dispatcher, error)
}

Dispatcher handles incoming messages and keeps the state of the channel

type Downstream

type Downstream interface {
	Reply(code int, args ...interface{}) error
}

type Encoder

type Encoder interface {
	Encode(interface{}) error
}

Encoder sends replies to the Cocaine-runtime

type Process

type Process interface {
	Output() <-chan ProcessOutput
	Kill() error
}

type ProcessOutput

type ProcessOutput struct {
	Err  error
	Data []byte
}

type Profile

type Profile map[string]interface{}

func (Profile) Type

func (p Profile) Type() string