Add prototype of pipeline api using connect

This includes refactoring of the http listener to use a custom mux.
2022-12-24 19:45:25 -07:00
parent 08e8104cd9
commit cd098d794d
10 changed files with 394 additions and 9 deletions
@@ -0,0 +1,218 @@
+// Code generated by protoc-gen-go. DO NOT EDIT.
+// versions:
+// 	protoc-gen-go v1.28.1
+// 	protoc        (unknown)
+// source: get_runner/v1/get_runner.proto
+
+package get_runnerv1
+
+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 GetRunnerRequest struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Tag string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
+}
+
+func (x *GetRunnerRequest) Reset() {
+	*x = GetRunnerRequest{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_get_runner_v1_get_runner_proto_msgTypes[0]
+		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_get_runner_v1_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 GetRunnerRequest.ProtoReflect.Descriptor instead.
+func (*GetRunnerRequest) Descriptor() ([]byte, []int) {
+	return file_get_runner_v1_get_runner_proto_rawDescGZIP(), []int{0}
+}
+
+func (x *GetRunnerRequest) GetTag() string {
+	if x != nil {
+		return x.Tag
+	}
+	return ""
+}
+
+type GetRunnerResponse struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
+}
+
+func (x *GetRunnerResponse) Reset() {
+	*x = GetRunnerResponse{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_get_runner_v1_get_runner_proto_msgTypes[1]
+		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_get_runner_v1_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 GetRunnerResponse.ProtoReflect.Descriptor instead.
+func (*GetRunnerResponse) Descriptor() ([]byte, []int) {
+	return file_get_runner_v1_get_runner_proto_rawDescGZIP(), []int{1}
+}
+
+func (x *GetRunnerResponse) GetSuccess() bool {
+	if x != nil {
+		return x.Success
+	}
+	return false
+}
+
+var File_get_runner_v1_get_runner_proto protoreflect.FileDescriptor
+
+var file_get_runner_v1_get_runner_proto_rawDesc = []byte{
+	0x0a, 0x1e, 0x67, 0x65, 0x74, 0x5f, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2f, 0x76, 0x31, 0x2f,
+	0x67, 0x65, 0x74, 0x5f, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
+	0x12, 0x0d, 0x67, 0x65, 0x74, 0x5f, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x22,
+	0x24, 0x0a, 0x10, 0x47, 0x65, 0x74, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75,
+	0x65, 0x73, 0x74, 0x12, 0x10, 0x0a, 0x03, 0x74, 0x61, 0x67, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
+	0x52, 0x03, 0x74, 0x61, 0x67, 0x22, 0x2d, 0x0a, 0x11, 0x47, 0x65, 0x74, 0x52, 0x75, 0x6e, 0x6e,
+	0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x75,
+	0x63, 0x63, 0x65, 0x73, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x73, 0x75, 0x63,
+	0x63, 0x65, 0x73, 0x73, 0x32, 0x64, 0x0a, 0x10, 0x47, 0x65, 0x74, 0x52, 0x75, 0x6e, 0x6e, 0x65,
+	0x72, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x50, 0x0a, 0x09, 0x47, 0x65, 0x74, 0x52,
+	0x75, 0x6e, 0x6e, 0x65, 0x72, 0x12, 0x1f, 0x2e, 0x67, 0x65, 0x74, 0x5f, 0x72, 0x75, 0x6e, 0x6e,
+	0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x52,
+	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x20, 0x2e, 0x67, 0x65, 0x74, 0x5f, 0x72, 0x75, 0x6e,
+	0x6e, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x52, 0x75, 0x6e, 0x6e, 0x65, 0x72,
+	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x44, 0x5a, 0x42, 0x67, 0x69,
+	0x74, 0x2e, 0x6f, 0x68, 0x65, 0x61, 0x2e, 0x78, 0x79, 0x7a, 0x2f, 0x63, 0x75, 0x72, 0x73, 0x6f,
+	0x72, 0x69, 0x75, 0x73, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2f, 0x70, 0x72, 0x6f, 0x74,
+	0x6f, 0x2f, 0x67, 0x65, 0x6e, 0x2f, 0x67, 0x65, 0x74, 0x5f, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72,
+	0x2f, 0x76, 0x31, 0x3b, 0x67, 0x65, 0x74, 0x5f, 0x72, 0x75, 0x6e, 0x6e, 0x65, 0x72, 0x76, 0x31,
+	0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+}
+
+var (
+	file_get_runner_v1_get_runner_proto_rawDescOnce sync.Once
+	file_get_runner_v1_get_runner_proto_rawDescData = file_get_runner_v1_get_runner_proto_rawDesc
+)
+
+func file_get_runner_v1_get_runner_proto_rawDescGZIP() []byte {
+	file_get_runner_v1_get_runner_proto_rawDescOnce.Do(func() {
+		file_get_runner_v1_get_runner_proto_rawDescData = protoimpl.X.CompressGZIP(file_get_runner_v1_get_runner_proto_rawDescData)
+	})
+	return file_get_runner_v1_get_runner_proto_rawDescData
+}
+
+var file_get_runner_v1_get_runner_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
+var file_get_runner_v1_get_runner_proto_goTypes = []interface{}{
+	(*GetRunnerRequest)(nil),  // 0: get_runner.v1.GetRunnerRequest
+	(*GetRunnerResponse)(nil), // 1: get_runner.v1.GetRunnerResponse
+}
+var file_get_runner_v1_get_runner_proto_depIdxs = []int32{
+	0, // 0: get_runner.v1.GetRunnerService.GetRunner:input_type -> get_runner.v1.GetRunnerRequest
+	1, // 1: get_runner.v1.GetRunnerService.GetRunner:output_type -> get_runner.v1.GetRunnerResponse
+	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_get_runner_v1_get_runner_proto_init() }
+func file_get_runner_v1_get_runner_proto_init() {
+	if File_get_runner_v1_get_runner_proto != nil {
+		return
+	}
+	if !protoimpl.UnsafeEnabled {
+		file_get_runner_v1_get_runner_proto_msgTypes[0].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_get_runner_v1_get_runner_proto_msgTypes[1].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_get_runner_v1_get_runner_proto_rawDesc,
+			NumEnums:      0,
+			NumMessages:   2,
+			NumExtensions: 0,
+			NumServices:   1,
+		},
+		GoTypes:           file_get_runner_v1_get_runner_proto_goTypes,
+		DependencyIndexes: file_get_runner_v1_get_runner_proto_depIdxs,
+		MessageInfos:      file_get_runner_v1_get_runner_proto_msgTypes,
+	}.Build()
+	File_get_runner_v1_get_runner_proto = out.File
+	file_get_runner_v1_get_runner_proto_rawDesc = nil
+	file_get_runner_v1_get_runner_proto_goTypes = nil
+	file_get_runner_v1_get_runner_proto_depIdxs = nil
+}
@@ -0,0 +1,86 @@
+// Code generated by protoc-gen-connect-go. DO NOT EDIT.
+//
+// Source: get_runner/v1/get_runner.proto
+
+package get_runnerv1connect
+
+import (
+	context "context"
+	errors "errors"
+	v1 "git.ohea.xyz/cursorius/server/proto/gen/get_runner/v1"
+	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 = "get_runner.v1.GetRunnerService"
+)
+
+// GetRunnerServiceClient is a client for the get_runner.v1.GetRunnerService service.
+type GetRunnerServiceClient interface {
+	GetRunner(context.Context, *connect_go.Request[v1.GetRunnerRequest]) (*connect_go.Response[v1.GetRunnerResponse], error)
+}
+
+// NewGetRunnerServiceClient constructs a client for the get_runner.v1.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[v1.GetRunnerRequest, v1.GetRunnerResponse](
+			httpClient,
+			baseURL+"/get_runner.v1.GetRunnerService/GetRunner",
+			opts...,
+		),
+	}
+}
+
+// getRunnerServiceClient implements GetRunnerServiceClient.
+type getRunnerServiceClient struct {
+	getRunner *connect_go.Client[v1.GetRunnerRequest, v1.GetRunnerResponse]
+}
+
+// GetRunner calls get_runner.v1.GetRunnerService.GetRunner.
+func (c *getRunnerServiceClient) GetRunner(ctx context.Context, req *connect_go.Request[v1.GetRunnerRequest]) (*connect_go.Response[v1.GetRunnerResponse], error) {
+	return c.getRunner.CallUnary(ctx, req)
+}
+
+// GetRunnerServiceHandler is an implementation of the get_runner.v1.GetRunnerService service.
+type GetRunnerServiceHandler interface {
+	GetRunner(context.Context, *connect_go.Request[v1.GetRunnerRequest]) (*connect_go.Response[v1.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("/get_runner.v1.GetRunnerService/GetRunner", connect_go.NewUnaryHandler(
+		"/get_runner.v1.GetRunnerService/GetRunner",
+		svc.GetRunner,
+		opts...,
+	))
+	return "/get_runner.v1.GetRunnerService/", mux
+}
+
+// UnimplementedGetRunnerServiceHandler returns CodeUnimplemented from all methods.
+type UnimplementedGetRunnerServiceHandler struct{}
+
+func (UnimplementedGetRunnerServiceHandler) GetRunner(context.Context, *connect_go.Request[v1.GetRunnerRequest]) (*connect_go.Response[v1.GetRunnerResponse], error) {
+	return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("get_runner.v1.GetRunnerService.GetRunner is not implemented"))
+}