Initial commit

go/api/v2/apiv2connect/get_runner.connect.go

@@ -0,0 +1,86 @@
+// Code generated by protoc-gen-connect-go. DO NOT EDIT.
+//
+// Source: api/v2/get_runner.proto
+
+package apiv2connect
+
+import (
+	context "context"
+	errors "errors"
+	v2 "git.ohea.xyz/cursorius/pipeline-api/go/api/v2"
+	connect_go "github.com/bufbuild/connect-go"
+	http "net/http"
+	strings "strings"
+)
+
+// This is a compile-time assertion to ensure that this generated file and the connect package are
+// compatible. If you get a compiler error that this constant is not defined, this code was
+// generated with a version of connect newer than the one compiled into your binary. You can fix the
+// problem by either regenerating this code with an older version of connect or updating the connect
+// version compiled into your binary.
+const _ = connect_go.IsAtLeastVersion0_1_0
+
+const (
+	// GetRunnerServiceName is the fully-qualified name of the GetRunnerService service.
+	GetRunnerServiceName = "api.v2.GetRunnerService"
+)
+
+// GetRunnerServiceClient is a client for the api.v2.GetRunnerService service.
+type GetRunnerServiceClient interface {
+	GetRunner(context.Context, *connect_go.Request[v2.GetRunnerRequest]) (*connect_go.Response[v2.GetRunnerResponse], error)
+}
+
+// NewGetRunnerServiceClient constructs a client for the api.v2.GetRunnerService service. By
+// default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses,
+// and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the
+// connect.WithGRPC() or connect.WithGRPCWeb() options.
+//
+// The URL supplied here should be the base URL for the Connect or gRPC server (for example,
+// http://api.acme.com or https://acme.com/grpc).
+func NewGetRunnerServiceClient(httpClient connect_go.HTTPClient, baseURL string, opts ...connect_go.ClientOption) GetRunnerServiceClient {
+	baseURL = strings.TrimRight(baseURL, "/")
+	return &getRunnerServiceClient{
+		getRunner: connect_go.NewClient[v2.GetRunnerRequest, v2.GetRunnerResponse](
+			httpClient,
+			baseURL+"/api.v2.GetRunnerService/GetRunner",
+			opts...,
+		),
+	}
+}
+
+// getRunnerServiceClient implements GetRunnerServiceClient.
+type getRunnerServiceClient struct {
+	getRunner *connect_go.Client[v2.GetRunnerRequest, v2.GetRunnerResponse]
+}
+
+// GetRunner calls api.v2.GetRunnerService.GetRunner.
+func (c *getRunnerServiceClient) GetRunner(ctx context.Context, req *connect_go.Request[v2.GetRunnerRequest]) (*connect_go.Response[v2.GetRunnerResponse], error) {
+	return c.getRunner.CallUnary(ctx, req)
+}
+
+// GetRunnerServiceHandler is an implementation of the api.v2.GetRunnerService service.
+type GetRunnerServiceHandler interface {
+	GetRunner(context.Context, *connect_go.Request[v2.GetRunnerRequest]) (*connect_go.Response[v2.GetRunnerResponse], error)
+}
+
+// NewGetRunnerServiceHandler builds an HTTP handler from the service implementation. It returns the
+// path on which to mount the handler and the handler itself.
+//
+// By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf
+// and JSON codecs. They also support gzip compression.
+func NewGetRunnerServiceHandler(svc GetRunnerServiceHandler, opts ...connect_go.HandlerOption) (string, http.Handler) {
+	mux := http.NewServeMux()
+	mux.Handle("/api.v2.GetRunnerService/GetRunner", connect_go.NewUnaryHandler(
+		"/api.v2.GetRunnerService/GetRunner",
+		svc.GetRunner,
+		opts...,
+	))
+	return "/api.v2.GetRunnerService/", mux
+}
+
+// UnimplementedGetRunnerServiceHandler returns CodeUnimplemented from all methods.
+type UnimplementedGetRunnerServiceHandler struct{}
+
+func (UnimplementedGetRunnerServiceHandler) GetRunner(context.Context, *connect_go.Request[v2.GetRunnerRequest]) (*connect_go.Response[v2.GetRunnerResponse], error) {
+	return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("api.v2.GetRunnerService.GetRunner is not implemented"))
+}

go/api/v2/apiv2connect/run_command.connect.go

@@ -0,0 +1,86 @@
+// Code generated by protoc-gen-connect-go. DO NOT EDIT.
+//
+// Source: api/v2/run_command.proto
+
+package apiv2connect
+
+import (
+	context "context"
+	errors "errors"
+	v2 "git.ohea.xyz/cursorius/pipeline-api/go/api/v2"
+	connect_go "github.com/bufbuild/connect-go"
+	http "net/http"
+	strings "strings"
+)
+
+// This is a compile-time assertion to ensure that this generated file and the connect package are
+// compatible. If you get a compiler error that this constant is not defined, this code was
+// generated with a version of connect newer than the one compiled into your binary. You can fix the
+// problem by either regenerating this code with an older version of connect or updating the connect
+// version compiled into your binary.
+const _ = connect_go.IsAtLeastVersion0_1_0
+
+const (
+	// RunCommandServiceName is the fully-qualified name of the RunCommandService service.
+	RunCommandServiceName = "api.v2.RunCommandService"
+)
+
+// RunCommandServiceClient is a client for the api.v2.RunCommandService service.
+type RunCommandServiceClient interface {
+	RunCommand(context.Context, *connect_go.Request[v2.RunCommandRequest]) (*connect_go.Response[v2.RunCommandResponse], error)
+}
+
+// NewRunCommandServiceClient constructs a client for the api.v2.RunCommandService service. By
+// default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses,
+// and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the
+// connect.WithGRPC() or connect.WithGRPCWeb() options.
+//
+// The URL supplied here should be the base URL for the Connect or gRPC server (for example,
+// http://api.acme.com or https://acme.com/grpc).
+func NewRunCommandServiceClient(httpClient connect_go.HTTPClient, baseURL string, opts ...connect_go.ClientOption) RunCommandServiceClient {
+	baseURL = strings.TrimRight(baseURL, "/")
+	return &runCommandServiceClient{
+		runCommand: connect_go.NewClient[v2.RunCommandRequest, v2.RunCommandResponse](
+			httpClient,
+			baseURL+"/api.v2.RunCommandService/RunCommand",
+			opts...,
+		),
+	}
+}
+
+// runCommandServiceClient implements RunCommandServiceClient.
+type runCommandServiceClient struct {
+	runCommand *connect_go.Client[v2.RunCommandRequest, v2.RunCommandResponse]
+}
+
+// RunCommand calls api.v2.RunCommandService.RunCommand.
+func (c *runCommandServiceClient) RunCommand(ctx context.Context, req *connect_go.Request[v2.RunCommandRequest]) (*connect_go.Response[v2.RunCommandResponse], error) {
+	return c.runCommand.CallUnary(ctx, req)
+}
+
+// RunCommandServiceHandler is an implementation of the api.v2.RunCommandService service.
+type RunCommandServiceHandler interface {
+	RunCommand(context.Context, *connect_go.Request[v2.RunCommandRequest]) (*connect_go.Response[v2.RunCommandResponse], error)
+}
+
+// NewRunCommandServiceHandler builds an HTTP handler from the service implementation. It returns
+// the path on which to mount the handler and the handler itself.
+//
+// By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf
+// and JSON codecs. They also support gzip compression.
+func NewRunCommandServiceHandler(svc RunCommandServiceHandler, opts ...connect_go.HandlerOption) (string, http.Handler) {
+	mux := http.NewServeMux()
+	mux.Handle("/api.v2.RunCommandService/RunCommand", connect_go.NewUnaryHandler(
+		"/api.v2.RunCommandService/RunCommand",
+		svc.RunCommand,
+		opts...,
+	))
+	return "/api.v2.RunCommandService/", mux
+}
+
+// UnimplementedRunCommandServiceHandler returns CodeUnimplemented from all methods.
+type UnimplementedRunCommandServiceHandler struct{}
+
+func (UnimplementedRunCommandServiceHandler) RunCommand(context.Context, *connect_go.Request[v2.RunCommandRequest]) (*connect_go.Response[v2.RunCommandResponse], error) {
+	return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("api.v2.RunCommandService.RunCommand is not implemented"))
+}

go/api/v2/get_runner.pb.go

@@ -0,0 +1,290 @@
+// Code generated by protoc-gen-go. DO NOT EDIT.
+// versions:
+// 	protoc-gen-go v1.28.1
+// 	protoc        (unknown)
+// source: api/v2/get_runner.proto
+
+package apiv2
+
+import (
+	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
+	reflect "reflect"
+	sync "sync"
+)
+
+const (
+	// Verify that this generated code is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
+	// Verify that runtime/protoimpl is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
+)
+
+type GetRunnerOptions struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	CloneSource bool `protobuf:"varint,2,opt,name=clone_source,json=cloneSource,proto3" json:"clone_source,omitempty"`
+}
+
+func (x *GetRunnerOptions) Reset() {
+	*x = GetRunnerOptions{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_api_v2_get_runner_proto_msgTypes[0]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *GetRunnerOptions) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetRunnerOptions) ProtoMessage() {}
+
+func (x *GetRunnerOptions) ProtoReflect() protoreflect.Message {
+	mi := &file_api_v2_get_runner_proto_msgTypes[0]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetRunnerOptions.ProtoReflect.Descriptor instead.
+func (*GetRunnerOptions) Descriptor() ([]byte, []int) {
+	return file_api_v2_get_runner_proto_rawDescGZIP(), []int{0}
+}
+
+func (x *GetRunnerOptions) GetCloneSource() bool {
+	if x != nil {
+		return x.CloneSource
+	}
+	return false
+}
+
+type GetRunnerRequest struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Tags    []string          `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
+	Options *GetRunnerOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
+}
+
+func (x *GetRunnerRequest) Reset() {
+	*x = GetRunnerRequest{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_api_v2_get_runner_proto_msgTypes[1]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *GetRunnerRequest) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetRunnerRequest) ProtoMessage() {}
+
+func (x *GetRunnerRequest) ProtoReflect() protoreflect.Message {
+	mi := &file_api_v2_get_runner_proto_msgTypes[1]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetRunnerRequest.ProtoReflect.Descriptor instead.
+func (*GetRunnerRequest) Descriptor() ([]byte, []int) {
+	return file_api_v2_get_runner_proto_rawDescGZIP(), []int{1}
+}
+
+func (x *GetRunnerRequest) GetTags() []string {
+	if x != nil {
+		return x.Tags
+	}
+	return nil
+}
+
+func (x *GetRunnerRequest) GetOptions() *GetRunnerOptions {
+	if x != nil {
+		return x.Options
+	}
+	return nil
+}
+
+type GetRunnerResponse struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
+}
+
+func (x *GetRunnerResponse) Reset() {
+	*x = GetRunnerResponse{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_api_v2_get_runner_proto_msgTypes[2]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *GetRunnerResponse) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*GetRunnerResponse) ProtoMessage() {}
+
+func (x *GetRunnerResponse) ProtoReflect() protoreflect.Message {
+	mi := &file_api_v2_get_runner_proto_msgTypes[2]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use GetRunnerResponse.ProtoReflect.Descriptor instead.
+func (*GetRunnerResponse) Descriptor() ([]byte, []int) {
+	return file_api_v2_get_runner_proto_rawDescGZIP(), []int{2}
+}
+
+func (x *GetRunnerResponse) GetId() string {
+	if x != nil {
+		return x.Id
+	}
+	return ""
+}
+
+var File_api_v2_get_runner_proto protoreflect.FileDescriptor
+
+var file_api_v2_get_runner_proto_rawDesc = []byte{
+	0x0a, 0x17, 0x61, 0x70, 0x69, 0x2f, 0x76, 0x32, 0x2f, 0x67, 0x65, 0x74, 0x5f, 0x72, 0x75, 0x6e,
+	0x6e, 0x65, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x06, 0x61, 0x70, 0x69, 0x2e, 0x76,
+	0x32, 0x22, 0x35, 0x0a, 0x10, 0x47, 0x65, 0x74, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x4f, 0x70,
+	0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x6c, 0x6f, 0x6e, 0x65, 0x5f, 0x73,
+	0x6f, 0x75, 0x72, 0x63, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0b, 0x63, 0x6c, 0x6f,
+	0x6e, 0x65, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x22, 0x5a, 0x0a, 0x10, 0x47, 0x65, 0x74, 0x52,
+	0x75, 0x6e, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04,
+	0x74, 0x61, 0x67, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x04, 0x74, 0x61, 0x67, 0x73,
+	0x12, 0x32, 0x0a, 0x07, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28,
+	0x0b, 0x32, 0x18, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x75,
+	0x6e, 0x6e, 0x65, 0x72, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x07, 0x6f, 0x70, 0x74,
+	0x69, 0x6f, 0x6e, 0x73, 0x22, 0x23, 0x0a, 0x11, 0x47, 0x65, 0x74, 0x52, 0x75, 0x6e, 0x6e, 0x65,
+	0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18,
+	0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x32, 0x56, 0x0a, 0x10, 0x47, 0x65, 0x74,
+	0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x42, 0x0a,
+	0x09, 0x47, 0x65, 0x74, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x12, 0x18, 0x2e, 0x61, 0x70, 0x69,
+	0x2e, 0x76, 0x32, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x71,
+	0x75, 0x65, 0x73, 0x74, 0x1a, 0x19, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x47, 0x65,
+	0x74, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22,
+	0x00, 0x42, 0x35, 0x5a, 0x33, 0x67, 0x69, 0x74, 0x2e, 0x6f, 0x68, 0x65, 0x61, 0x2e, 0x78, 0x79,
+	0x7a, 0x2f, 0x63, 0x75, 0x72, 0x73, 0x6f, 0x72, 0x69, 0x75, 0x73, 0x2f, 0x70, 0x69, 0x70, 0x65,
+	0x6c, 0x69, 0x6e, 0x65, 0x2d, 0x61, 0x70, 0x69, 0x2f, 0x67, 0x6f, 0x2f, 0x61, 0x70, 0x69, 0x2f,
+	0x76, 0x32, 0x3b, 0x61, 0x70, 0x69, 0x76, 0x32, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+}
+
+var (
+	file_api_v2_get_runner_proto_rawDescOnce sync.Once
+	file_api_v2_get_runner_proto_rawDescData = file_api_v2_get_runner_proto_rawDesc
+)
+
+func file_api_v2_get_runner_proto_rawDescGZIP() []byte {
+	file_api_v2_get_runner_proto_rawDescOnce.Do(func() {
+		file_api_v2_get_runner_proto_rawDescData = protoimpl.X.CompressGZIP(file_api_v2_get_runner_proto_rawDescData)
+	})
+	return file_api_v2_get_runner_proto_rawDescData
+}
+
+var file_api_v2_get_runner_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
+var file_api_v2_get_runner_proto_goTypes = []interface{}{
+	(*GetRunnerOptions)(nil),  // 0: api.v2.GetRunnerOptions
+	(*GetRunnerRequest)(nil),  // 1: api.v2.GetRunnerRequest
+	(*GetRunnerResponse)(nil), // 2: api.v2.GetRunnerResponse
+}
+var file_api_v2_get_runner_proto_depIdxs = []int32{
+	0, // 0: api.v2.GetRunnerRequest.options:type_name -> api.v2.GetRunnerOptions
+	1, // 1: api.v2.GetRunnerService.GetRunner:input_type -> api.v2.GetRunnerRequest
+	2, // 2: api.v2.GetRunnerService.GetRunner:output_type -> api.v2.GetRunnerResponse
+	2, // [2:3] is the sub-list for method output_type
+	1, // [1:2] is the sub-list for method input_type
+	1, // [1:1] is the sub-list for extension type_name
+	1, // [1:1] is the sub-list for extension extendee
+	0, // [0:1] is the sub-list for field type_name
+}
+
+func init() { file_api_v2_get_runner_proto_init() }
+func file_api_v2_get_runner_proto_init() {
+	if File_api_v2_get_runner_proto != nil {
+		return
+	}
+	if !protoimpl.UnsafeEnabled {
+		file_api_v2_get_runner_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*GetRunnerOptions); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_api_v2_get_runner_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*GetRunnerRequest); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_api_v2_get_runner_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*GetRunnerResponse); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+	}
+	type x struct{}
+	out := protoimpl.TypeBuilder{
+		File: protoimpl.DescBuilder{
+			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
+			RawDescriptor: file_api_v2_get_runner_proto_rawDesc,
+			NumEnums:      0,
+			NumMessages:   3,
+			NumExtensions: 0,
+			NumServices:   1,
+		},
+		GoTypes:           file_api_v2_get_runner_proto_goTypes,
+		DependencyIndexes: file_api_v2_get_runner_proto_depIdxs,
+		MessageInfos:      file_api_v2_get_runner_proto_msgTypes,
+	}.Build()
+	File_api_v2_get_runner_proto = out.File
+	file_api_v2_get_runner_proto_rawDesc = nil
+	file_api_v2_get_runner_proto_goTypes = nil
+	file_api_v2_get_runner_proto_depIdxs = nil
+}

go/api/v2/run_command.pb.go

@@ -0,0 +1,245 @@
+// Code generated by protoc-gen-go. DO NOT EDIT.
+// versions:
+// 	protoc-gen-go v1.28.1
+// 	protoc        (unknown)
+// source: api/v2/run_command.proto
+
+package apiv2
+
+import (
+	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
+	reflect "reflect"
+	sync "sync"
+)
+
+const (
+	// Verify that this generated code is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
+	// Verify that runtime/protoimpl is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
+)
+
+type RunCommandRequest struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
+	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
+}
+
+func (x *RunCommandRequest) Reset() {
+	*x = RunCommandRequest{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_api_v2_run_command_proto_msgTypes[0]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *RunCommandRequest) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*RunCommandRequest) ProtoMessage() {}
+
+func (x *RunCommandRequest) ProtoReflect() protoreflect.Message {
+	mi := &file_api_v2_run_command_proto_msgTypes[0]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use RunCommandRequest.ProtoReflect.Descriptor instead.
+func (*RunCommandRequest) Descriptor() ([]byte, []int) {
+	return file_api_v2_run_command_proto_rawDescGZIP(), []int{0}
+}
+
+func (x *RunCommandRequest) GetId() string {
+	if x != nil {
+		return x.Id
+	}
+	return ""
+}
+
+func (x *RunCommandRequest) GetCommand() string {
+	if x != nil {
+		return x.Command
+	}
+	return ""
+}
+
+type RunCommandResponse struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	ReturnCode int64  `protobuf:"varint,1,opt,name=return_code,json=returnCode,proto3" json:"return_code,omitempty"`
+	Stdout     string `protobuf:"bytes,2,opt,name=stdout,proto3" json:"stdout,omitempty"`
+	Stderr     string `protobuf:"bytes,3,opt,name=stderr,proto3" json:"stderr,omitempty"`
+}
+
+func (x *RunCommandResponse) Reset() {
+	*x = RunCommandResponse{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_api_v2_run_command_proto_msgTypes[1]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *RunCommandResponse) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*RunCommandResponse) ProtoMessage() {}
+
+func (x *RunCommandResponse) ProtoReflect() protoreflect.Message {
+	mi := &file_api_v2_run_command_proto_msgTypes[1]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use RunCommandResponse.ProtoReflect.Descriptor instead.
+func (*RunCommandResponse) Descriptor() ([]byte, []int) {
+	return file_api_v2_run_command_proto_rawDescGZIP(), []int{1}
+}
+
+func (x *RunCommandResponse) GetReturnCode() int64 {
+	if x != nil {
+		return x.ReturnCode
+	}
+	return 0
+}
+
+func (x *RunCommandResponse) GetStdout() string {
+	if x != nil {
+		return x.Stdout
+	}
+	return ""
+}
+
+func (x *RunCommandResponse) GetStderr() string {
+	if x != nil {
+		return x.Stderr
+	}
+	return ""
+}
+
+var File_api_v2_run_command_proto protoreflect.FileDescriptor
+
+var file_api_v2_run_command_proto_rawDesc = []byte{
+	0x0a, 0x18, 0x61, 0x70, 0x69, 0x2f, 0x76, 0x32, 0x2f, 0x72, 0x75, 0x6e, 0x5f, 0x63, 0x6f, 0x6d,
+	0x6d, 0x61, 0x6e, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x06, 0x61, 0x70, 0x69, 0x2e,
+	0x76, 0x32, 0x22, 0x3d, 0x0a, 0x11, 0x52, 0x75, 0x6e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64,
+	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20,
+	0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, 0x6d, 0x6d, 0x61,
+	0x6e, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e,
+	0x64, 0x22, 0x65, 0x0a, 0x12, 0x52, 0x75, 0x6e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52,
+	0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x72, 0x65, 0x74, 0x75, 0x72,
+	0x6e, 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0a, 0x72, 0x65,
+	0x74, 0x75, 0x72, 0x6e, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x64, 0x6f,
+	0x75, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x64, 0x6f, 0x75, 0x74,
+	0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x64, 0x65, 0x72, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09,
+	0x52, 0x06, 0x73, 0x74, 0x64, 0x65, 0x72, 0x72, 0x32, 0x5a, 0x0a, 0x11, 0x52, 0x75, 0x6e, 0x43,
+	0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x45, 0x0a,
+	0x0a, 0x52, 0x75, 0x6e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x12, 0x19, 0x2e, 0x61, 0x70,
+	0x69, 0x2e, 0x76, 0x32, 0x2e, 0x52, 0x75, 0x6e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52,
+	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1a, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e,
+	0x52, 0x75, 0x6e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
+	0x73, 0x65, 0x22, 0x00, 0x42, 0x35, 0x5a, 0x33, 0x67, 0x69, 0x74, 0x2e, 0x6f, 0x68, 0x65, 0x61,
+	0x2e, 0x78, 0x79, 0x7a, 0x2f, 0x63, 0x75, 0x72, 0x73, 0x6f, 0x72, 0x69, 0x75, 0x73, 0x2f, 0x70,
+	0x69, 0x70, 0x65, 0x6c, 0x69, 0x6e, 0x65, 0x2d, 0x61, 0x70, 0x69, 0x2f, 0x67, 0x6f, 0x2f, 0x61,
+	0x70, 0x69, 0x2f, 0x76, 0x32, 0x3b, 0x61, 0x70, 0x69, 0x76, 0x32, 0x62, 0x06, 0x70, 0x72, 0x6f,
+	0x74, 0x6f, 0x33,
+}
+
+var (
+	file_api_v2_run_command_proto_rawDescOnce sync.Once
+	file_api_v2_run_command_proto_rawDescData = file_api_v2_run_command_proto_rawDesc
+)
+
+func file_api_v2_run_command_proto_rawDescGZIP() []byte {
+	file_api_v2_run_command_proto_rawDescOnce.Do(func() {
+		file_api_v2_run_command_proto_rawDescData = protoimpl.X.CompressGZIP(file_api_v2_run_command_proto_rawDescData)
+	})
+	return file_api_v2_run_command_proto_rawDescData
+}
+
+var file_api_v2_run_command_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
+var file_api_v2_run_command_proto_goTypes = []interface{}{
+	(*RunCommandRequest)(nil),  // 0: api.v2.RunCommandRequest
+	(*RunCommandResponse)(nil), // 1: api.v2.RunCommandResponse
+}
+var file_api_v2_run_command_proto_depIdxs = []int32{
+	0, // 0: api.v2.RunCommandService.RunCommand:input_type -> api.v2.RunCommandRequest
+	1, // 1: api.v2.RunCommandService.RunCommand:output_type -> api.v2.RunCommandResponse
+	1, // [1:2] is the sub-list for method output_type
+	0, // [0:1] is the sub-list for method input_type
+	0, // [0:0] is the sub-list for extension type_name
+	0, // [0:0] is the sub-list for extension extendee
+	0, // [0:0] is the sub-list for field type_name
+}
+
+func init() { file_api_v2_run_command_proto_init() }
+func file_api_v2_run_command_proto_init() {
+	if File_api_v2_run_command_proto != nil {
+		return
+	}
+	if !protoimpl.UnsafeEnabled {
+		file_api_v2_run_command_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*RunCommandRequest); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_api_v2_run_command_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*RunCommandResponse); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+	}
+	type x struct{}
+	out := protoimpl.TypeBuilder{
+		File: protoimpl.DescBuilder{
+			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
+			RawDescriptor: file_api_v2_run_command_proto_rawDesc,
+			NumEnums:      0,
+			NumMessages:   2,
+			NumExtensions: 0,
+			NumServices:   1,
+		},
+		GoTypes:           file_api_v2_run_command_proto_goTypes,
+		DependencyIndexes: file_api_v2_run_command_proto_depIdxs,
+		MessageInfos:      file_api_v2_run_command_proto_msgTypes,
+	}.Build()
+	File_api_v2_run_command_proto = out.File
+	file_api_v2_run_command_proto_rawDesc = nil
+	file_api_v2_run_command_proto_goTypes = nil
+	file_api_v2_run_command_proto_depIdxs = nil
+}