MCPcopy Create free account
hub / github.com/containerd/containerd / newTaskService

Function newTaskService

core/runtime/v2/example/example.go:89–93  ·  view source on GitHub ↗
(ctx context.Context, publisher shim.Publisher, sd shutdown.Service)

Source from the content-addressed store, hash-verified

87}
88
89func newTaskService(ctx context.Context, publisher shim.Publisher, sd shutdown.Service) (taskAPI.TTRPCTaskService, error) {
90 // The shim.Publisher and shutdown.Service are usually useful for your task service,
91 // but we don't need them in the exampleTaskService.
92 return &exampleTaskService{}, nil
93}
94
95var (
96 _ = shim.TTRPCService(&exampleTaskService{})

Callers 1

initFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…