Function NewTaskClient

core/runtime/v2/bridge.go:65–86

NewTaskClient returns a new task client interface which handles both GRPC and TTRPC servers depending on the client object type passed in. Supported client types are: - *ttrpc.Client - grpc.ClientConnInterface Currently supported servers: - TTRPC v2 (compatibility with shims before 2.0) - TTRPC v3

(client any, version int)

// - TTRPC v3
// - GRPC v3
func NewTaskClient(client any, version int) (TaskServiceClient, error) {
	switch c := client.(type) {
	case *ttrpc.Client:
		switch version {
		case 2:
			return &ttrpcV2Bridge{client: v2.NewTTRPCTaskClient(c)}, nil
		case 3:
			return api.NewTTRPCTaskClient(c), nil
		default:
			return nil, fmt.Errorf("containerd client supports only v2 and v3 TTRPC task client (got %d)", version)
		}

	case grpc.ClientConnInterface:
		if version != 3 {
			return nil, fmt.Errorf("containerd client supports only v3 GRPC task service (got %d)", version)
		}

		return &grpcV3Bridge{api.NewTaskClient(c)}, nil
	default:
		return nil, fmt.Errorf("unsupported shim client type %T", c)
	}
}

// ttrpcV2Bridge is a bridge from TTRPC v2 task service.
type ttrpcV2Bridge struct {