Lines Matching refs:drivers

31 	drivers.DriverPlugin
36 	impl   drivers.DriverPlugin
39 func (d *DriverHarness) Impl() drivers.DriverPlugin {
42 func NewDriverHarness(t testing.T, d drivers.DriverPlugin) *DriverHarness {
45 	pd := drivers.NewDriverPlugin(d, logger)
60 	dClient := raw.(drivers.DriverPlugin)
83 func (h *DriverHarness) MkAllocDir(t *drivers.TaskConfig, enableLogs bool) func() {
96 	require.NoError(h.t, taskDir.Build(fsi == drivers.FSIsolationChroot, config.DefaultChrootEnv))
162 	var lastState drivers.TaskState
168 		if status.State == drivers.TaskStateRunning {
185 	FingerprintF       func(context.Context) (<-chan *drivers.Fingerprint, error)
186 	CapabilitiesF      func() (*drivers.Capabilities, error)
187 	RecoverTaskF       func(*drivers.TaskHandle) error
188 	StartTaskF         func(*drivers.TaskConfig) (*drivers.TaskHandle, *drivers.DriverNetwork, error)
189 	WaitTaskF          func(context.Context, string) (<-chan *drivers.ExitResult, error)
192 	InspectTaskF       func(string) (*drivers.TaskStatus, error)
193 …TaskStatsF         func(context.Context, string, time.Duration) (<-chan *drivers.TaskResourceUsage…
194 	TaskEventsF        func(context.Context) (<-chan *drivers.TaskEvent, error)
196 	ExecTaskF          func(string, []string, time.Duration) (*drivers.ExecTaskResult, error)
197 	ExecTaskStreamingF func(context.Context, string, *drivers.ExecOptions) (*drivers.ExitResult, error)
202 	CreateNetworkF  func(string) (*drivers.NetworkIsolationSpec, bool, error)
203 	DestroyNetworkF func(string, *drivers.NetworkIsolationSpec) error
206 func (m *MockNetworkManager) CreateNetwork(id string) (*drivers.NetworkIsolationSpec, bool, error) {
209 func (m *MockNetworkManager) DestroyNetwork(id string, spec *drivers.NetworkIsolationSpec) error {
214 func (d *MockDriver) Fingerprint(ctx context.Context) (<-chan *drivers.Fingerprint, error) {
217 func (d *MockDriver) Capabilities() (*drivers.Capabilities, error) { return d.CapabilitiesF() }
218 func (d *MockDriver) RecoverTask(h *drivers.TaskHandle) error      { return d.RecoverTaskF(h) }
219 func (d *MockDriver) StartTask(c *drivers.TaskConfig) (*drivers.TaskHandle, *drivers.DriverNetwork,…
222 func (d *MockDriver) WaitTask(ctx context.Context, id string) (<-chan *drivers.ExitResult, error) {
231 func (d *MockDriver) InspectTask(taskID string) (*drivers.TaskStatus, error) {
234 … TaskStats(ctx context.Context, taskID string, i time.Duration) (<-chan *drivers.TaskResourceUsage…
237 func (d *MockDriver) TaskEvents(ctx context.Context) (<-chan *drivers.TaskEvent, error) {
243 func (d *MockDriver) ExecTask(taskID string, cmd []string, timeout time.Duration) (*drivers.ExecTas…
247 …cTaskStreaming(ctx context.Context, taskID string, execOpts *drivers.ExecOptions) (*drivers.ExitRe…
252 func SetEnvvars(envBuilder *taskenv.Builder, fsi drivers.FSIsolation, taskDir *allocdir.TaskDir, co…
261 	case drivers.FSIsolationNone:
274 	if fsi != drivers.FSIsolationImage {