This section is empty.


View Source
var (
	// PluginID is the java plugin metadata registered in the plugin
	// catalog.
	PluginID = loader.PluginID{
		Name:       pluginName,
		PluginType: base.PluginTypeDriver,

	// PluginConfig is the java driver factory function registered in the
	// plugin catalog.
	PluginConfig = &loader.InternalPluginConfig{
		Config:  map[string]interface{}{},
		Factory: func(l hclog.Logger) interface{} { return NewDriver(l) },


func GetAbsolutePath

func GetAbsolutePath(bin string) (string, error)

    GetAbsolutePath returns the absolute path of the passed binary by resolving it in the path and following symlinks.

    func NewDriver

    func NewDriver(logger hclog.Logger) drivers.DriverPlugin


    type Driver

    type Driver struct {
    	// contains filtered or unexported fields

      Driver is a driver for running images via Java

      func (*Driver) Capabilities

      func (d *Driver) Capabilities() (*drivers.Capabilities, error)

      func (*Driver) ConfigSchema

      func (d *Driver) ConfigSchema() (*hclspec.Spec, error)

      func (*Driver) DestroyTask

      func (d *Driver) DestroyTask(taskID string, force bool) error

      func (*Driver) ExecTask

      func (d *Driver) ExecTask(taskID string, cmd []string, timeout time.Duration) (*drivers.ExecTaskResult, error)

      func (*Driver) ExecTaskStreamingRaw

      func (d *Driver) ExecTaskStreamingRaw(ctx context.Context,
      	taskID string,
      	command []string,
      	tty bool,
      	stream drivers.ExecTaskStream) error

      func (*Driver) Fingerprint

      func (d *Driver) Fingerprint(ctx context.Context) (<-chan *drivers.Fingerprint, error)

      func (*Driver) InspectTask

      func (d *Driver) InspectTask(taskID string) (*drivers.TaskStatus, error)

      func (*Driver) PluginInfo

      func (d *Driver) PluginInfo() (*base.PluginInfoResponse, error)

      func (*Driver) RecoverTask

      func (d *Driver) RecoverTask(handle *drivers.TaskHandle) error

      func (*Driver) SetConfig

      func (d *Driver) SetConfig(cfg *base.Config) error

      func (*Driver) Shutdown

      func (d *Driver) Shutdown()

      func (*Driver) SignalTask

      func (d *Driver) SignalTask(taskID string, signal string) error

      func (*Driver) StartTask

      func (*Driver) StopTask

      func (d *Driver) StopTask(taskID string, timeout time.Duration, signal string) error

      func (*Driver) TaskConfigSchema

      func (d *Driver) TaskConfigSchema() (*hclspec.Spec, error)

      func (*Driver) TaskEvents

      func (d *Driver) TaskEvents(ctx context.Context) (<-chan *drivers.TaskEvent, error)

      func (*Driver) TaskStats

      func (d *Driver) TaskStats(ctx context.Context, taskID string, interval time.Duration) (<-chan *drivers.TaskResourceUsage, error)

      func (*Driver) WaitTask

      func (d *Driver) WaitTask(ctx context.Context, taskID string) (<-chan *drivers.ExitResult, error)

      type TaskConfig

      type TaskConfig struct {
      	Class     string   `codec:"class"`
      	ClassPath string   `codec:"class_path"`
      	JarPath   string   `codec:"jar_path"`
      	JvmOpts   []string `codec:"jvm_options"`
      	Args      []string `codec:"args"` // extra arguments to java executable

        TaskConfig is the driver configuration of a taskConfig within a job

        type TaskState

        type TaskState struct {
        	ReattachConfig *pstructs.ReattachConfig
        	TaskConfig     *drivers.TaskConfig
        	Pid            int
        	StartedAt      time.Time

          TaskState is the state which is encoded in the handle returned in StartTask. This information is needed to rebuild the taskConfig state and handler during recovery.