imjasonh/crush
1
0
Fork 0
mirror of https://github.com/imjasonh/crush synced 2026-07-07 00:12:50 +00:00
Code Activity

rename to crush

Browse source 
Signed-off-by: Jason Hall <imjasonh@gmail.com>
This commit is contained in:
Jason Hall 2026-02-22 22:46:38 -05:00
parent 48fa459675
commit 7e6a4f4d1d
12 changed files with 100 additions and 103 deletions
Download patch file Download diff file Expand all files Collapse all files

2
buf.gen.yaml
View file

@ -3,7 +3,7 @@ managed:
enabled: true
override:
- file_option: go_package_prefix
value: github.com/imjasonh/clod-run/gen
value: github.com/imjasonh/crush/gen
plugins:
- remote: buf.build/protocolbuffers/go
out: gen

8
cmd/grun/main.go → cmd/crush/main.go
View file

@ -7,20 +7,20 @@ import (
"os"
"github.com/chainguard-dev/clog"
"github.com/imjasonh/clod-run/internal/client"
"github.com/imjasonh/clod-run/internal/repl"
"github.com/imjasonh/crush/internal/client"
"github.com/imjasonh/crush/internal/repl"
)
func main() {
ctx := context.Background()
log := clog.FromContext(ctx)
service := flag.String("service", os.Getenv("GRUN_SERVICE"), "Cloud Run service host:port (or set GRUN_SERVICE)")
service := flag.String("service", os.Getenv("CRUSH_SERVICE"), "Cloud Run service host:port (or set CRUSH_SERVICE)")
insecure := flag.Bool("insecure", false, "disable TLS and auth (for local testing)")
flag.Parse()
if *service == "" {
fmt.Fprintln(os.Stderr, "error: --service or GRUN_SERVICE is required")
fmt.Fprintln(os.Stderr, "error: --service or CRUSH_SERVICE is required")
flag.Usage()
os.Exit(1)
}

2
cmd/server/main.go
View file

@ -5,7 +5,7 @@ import (
"net"
"github.com/chainguard-dev/clog"
"github.com/imjasonh/clod-run/internal/server"
"github.com/imjasonh/crush/internal/server"
"github.com/sethvargo/go-envconfig"
"google.golang.org/grpc"
"google.golang.org/grpc/reflection"

2
deploy.sh
View file

@ -3,4 +3,4 @@
PROJECT=${PROJECT:-kontaindotme}
REGION=${REGION:-us-east4}
gcloud run deploy grun --image=$(KO_DOCKER_REPO=gcr.io/kontaindotme ko build ./cmd/server -P --sbom=none) --region=us-east4 --project=kontaindotme
gcloud run deploy crush --image=$(KO_DOCKER_REPO=gcr.io/kontaindotme ko build ./cmd/server -P --sbom=none) --region=us-east4 --project=kontaindotme

163
gen/clodrun/v1/exec.pb.go → gen/crush/v1/exec.pb.go
View file

@ -2,9 +2,9 @@
// versions:
// protoc-gen-go v1.36.11
// protoc (unknown)
// source: clodrun/v1/exec.proto
// source: crush/v1/exec.proto
package clodrunv1
package crushv1
import (
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
@ -57,11 +57,11 @@ func (x Signal) String() string {
}
func (Signal) Descriptor() protoreflect.EnumDescriptor {
return file_clodrun_v1_exec_proto_enumTypes[0].Descriptor()
return file_crush_v1_exec_proto_enumTypes[0].Descriptor()
}
func (Signal) Type() protoreflect.EnumType {
return &file_clodrun_v1_exec_proto_enumTypes[0]
return &file_crush_v1_exec_proto_enumTypes[0]
}
func (x Signal) Number() protoreflect.EnumNumber {
@ -70,7 +70,7 @@ func (x Signal) Number() protoreflect.EnumNumber {
// Deprecated: Use Signal.Descriptor instead.
func (Signal) EnumDescriptor() ([]byte, []int) {
return file_clodrun_v1_exec_proto_rawDescGZIP(), []int{0}
return file_crush_v1_exec_proto_rawDescGZIP(), []int{0}
}
type WindowSize struct {
@ -83,7 +83,7 @@ type WindowSize struct {
func (x *WindowSize) Reset() {
*x = WindowSize{}
mi := &file_clodrun_v1_exec_proto_msgTypes[0]
mi := &file_crush_v1_exec_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@ -95,7 +95,7 @@ func (x *WindowSize) String() string {
func (*WindowSize) ProtoMessage() {}
func (x *WindowSize) ProtoReflect() protoreflect.Message {
mi := &file_clodrun_v1_exec_proto_msgTypes[0]
mi := &file_crush_v1_exec_proto_msgTypes[0]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@ -108,7 +108,7 @@ func (x *WindowSize) ProtoReflect() protoreflect.Message {
// Deprecated: Use WindowSize.ProtoReflect.Descriptor instead.
func (*WindowSize) Descriptor() ([]byte, []int) {
return file_clodrun_v1_exec_proto_rawDescGZIP(), []int{0}
return file_crush_v1_exec_proto_rawDescGZIP(), []int{0}
}
func (x *WindowSize) GetRows() uint32 {
@ -140,7 +140,7 @@ type ExecRequest struct {
func (x *ExecRequest) Reset() {
*x = ExecRequest{}
mi := &file_clodrun_v1_exec_proto_msgTypes[1]
mi := &file_crush_v1_exec_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@ -152,7 +152,7 @@ func (x *ExecRequest) String() string {
func (*ExecRequest) ProtoMessage() {}
func (x *ExecRequest) ProtoReflect() protoreflect.Message {
mi := &file_clodrun_v1_exec_proto_msgTypes[1]
mi := &file_crush_v1_exec_proto_msgTypes[1]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@ -165,7 +165,7 @@ func (x *ExecRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use ExecRequest.ProtoReflect.Descriptor instead.
func (*ExecRequest) Descriptor() ([]byte, []int) {
return file_clodrun_v1_exec_proto_rawDescGZIP(), []int{1}
return file_crush_v1_exec_proto_rawDescGZIP(), []int{1}
}
func (x *ExecRequest) GetRequest() isExecRequest_Request {
@ -224,7 +224,7 @@ type ExecRequest_Stdin struct {
}
type ExecRequest_Signal struct {
Signal Signal `protobuf:"varint,3,opt,name=signal,proto3,enum=clodrun.v1.Signal,oneof"`
Signal Signal `protobuf:"varint,3,opt,name=signal,proto3,enum=crush.v1.Signal,oneof"`
}
type ExecRequest_Resize struct {
@ -251,7 +251,7 @@ type StartRequest struct {
func (x *StartRequest) Reset() {
*x = StartRequest{}
mi := &file_clodrun_v1_exec_proto_msgTypes[2]
mi := &file_crush_v1_exec_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@ -263,7 +263,7 @@ func (x *StartRequest) String() string {
func (*StartRequest) ProtoMessage() {}
func (x *StartRequest) ProtoReflect() protoreflect.Message {
mi := &file_clodrun_v1_exec_proto_msgTypes[2]
mi := &file_crush_v1_exec_proto_msgTypes[2]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@ -276,7 +276,7 @@ func (x *StartRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.
func (*StartRequest) Descriptor() ([]byte, []int) {
return file_clodrun_v1_exec_proto_rawDescGZIP(), []int{2}
return file_crush_v1_exec_proto_rawDescGZIP(), []int{2}
}
func (x *StartRequest) GetCommand() []string {
@ -321,7 +321,7 @@ type ExecResponse struct {
func (x *ExecResponse) Reset() {
*x = ExecResponse{}
mi := &file_clodrun_v1_exec_proto_msgTypes[3]
mi := &file_crush_v1_exec_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@ -333,7 +333,7 @@ func (x *ExecResponse) String() string {
func (*ExecResponse) ProtoMessage() {}
func (x *ExecResponse) ProtoReflect() protoreflect.Message {
mi := &file_clodrun_v1_exec_proto_msgTypes[3]
mi := &file_crush_v1_exec_proto_msgTypes[3]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@ -346,7 +346,7 @@ func (x *ExecResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use ExecResponse.ProtoReflect.Descriptor instead.
func (*ExecResponse) Descriptor() ([]byte, []int) {
return file_clodrun_v1_exec_proto_rawDescGZIP(), []int{3}
return file_crush_v1_exec_proto_rawDescGZIP(), []int{3}
}
func (x *ExecResponse) GetResponse() isExecResponse_Response {
@ -415,7 +415,7 @@ type ExitStatus struct {
func (x *ExitStatus) Reset() {
*x = ExitStatus{}
mi := &file_clodrun_v1_exec_proto_msgTypes[4]
mi := &file_crush_v1_exec_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@ -427,7 +427,7 @@ func (x *ExitStatus) String() string {
func (*ExitStatus) ProtoMessage() {}
func (x *ExitStatus) ProtoReflect() protoreflect.Message {
mi := &file_clodrun_v1_exec_proto_msgTypes[4]
mi := &file_crush_v1_exec_proto_msgTypes[4]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@ -440,7 +440,7 @@ func (x *ExitStatus) ProtoReflect() protoreflect.Message {
// Deprecated: Use ExitStatus.ProtoReflect.Descriptor instead.
func (*ExitStatus) Descriptor() ([]byte, []int) {
return file_clodrun_v1_exec_proto_rawDescGZIP(), []int{4}
return file_crush_v1_exec_proto_rawDescGZIP(), []int{4}
}
func (x *ExitStatus) GetCode() int32 {
@ -457,35 +457,34 @@ func (x *ExitStatus) GetError() string {
return ""
}
var File_clodrun_v1_exec_proto protoreflect.FileDescriptor
var File_crush_v1_exec_proto protoreflect.FileDescriptor
const file_clodrun_v1_exec_proto_rawDesc = "" +
const file_crush_v1_exec_proto_rawDesc = "" +
"\n" +
"\x15clodrun/v1/exec.proto\x12\n" +
"clodrun.v1\"4\n" +
"\x13crush/v1/exec.proto\x12\bcrush.v1\"4\n" +
"\n" +
"WindowSize\x12\x12\n" +
"\x04rows\x18\x01 \x01(\rR\x04rows\x12\x12\n" +
"\x04cols\x18\x02 \x01(\rR\x04cols\"\xc2\x01\n" +
"\vExecRequest\x120\n" +
"\x05start\x18\x01 \x01(\v2\x18.clodrun.v1.StartRequestH\x00R\x05start\x12\x16\n" +
"\x05stdin\x18\x02 \x01(\fH\x00R\x05stdin\x12,\n" +
"\x06signal\x18\x03 \x01(\x0e2\x12.clodrun.v1.SignalH\x00R\x06signal\x120\n" +
"\x06resize\x18\x04 \x01(\v2\x16.clodrun.v1.WindowSizeH\x00R\x06resizeB\t\n" +
"\arequest\"\xe0\x01\n" +
"\x04cols\x18\x02 \x01(\rR\x04cols\"\xbc\x01\n" +
"\vExecRequest\x12.\n" +
"\x05start\x18\x01 \x01(\v2\x16.crush.v1.StartRequestH\x00R\x05start\x12\x16\n" +
"\x05stdin\x18\x02 \x01(\fH\x00R\x05stdin\x12*\n" +
"\x06signal\x18\x03 \x01(\x0e2\x10.crush.v1.SignalH\x00R\x06signal\x12.\n" +
"\x06resize\x18\x04 \x01(\v2\x14.crush.v1.WindowSizeH\x00R\x06resizeB\t\n" +
"\arequest\"\xdc\x01\n" +
"\fStartRequest\x12\x18\n" +
"\acommand\x18\x01 \x03(\tR\acommand\x123\n" +
"\x03env\x18\x02 \x03(\v2!.clodrun.v1.StartRequest.EnvEntryR\x03env\x12\x1f\n" +
"\acommand\x18\x01 \x03(\tR\acommand\x121\n" +
"\x03env\x18\x02 \x03(\v2\x1f.crush.v1.StartRequest.EnvEntryR\x03env\x12\x1f\n" +
"\vworking_dir\x18\x03 \x01(\tR\n" +
"workingDir\x12(\n" +
"\x03pty\x18\x04 \x01(\v2\x16.clodrun.v1.WindowSizeR\x03pty\x1a6\n" +
"workingDir\x12&\n" +
"\x03pty\x18\x04 \x01(\v2\x14.crush.v1.WindowSizeR\x03pty\x1a6\n" +
"\bEnvEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"\x89\x01\n" +
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"\x87\x01\n" +
"\fExecResponse\x12\x18\n" +
"\x06stdout\x18\x01 \x01(\fH\x00R\x06stdout\x12\x18\n" +
"\x06stderr\x18\x02 \x01(\fH\x00R\x06stderr\x129\n" +
"\vexit_status\x18\x03 \x01(\v2\x16.clodrun.v1.ExitStatusH\x00R\n" +
"\x06stderr\x18\x02 \x01(\fH\x00R\x06stderr\x127\n" +
"\vexit_status\x18\x03 \x01(\v2\x14.crush.v1.ExitStatusH\x00R\n" +
"exitStatusB\n" +
"\n" +
"\bresponse\"6\n" +
@ -498,45 +497,43 @@ const file_clodrun_v1_exec_proto_rawDesc = "" +
"\n" +
"SIGNAL_INT\x10\x01\x12\x0f\n" +
"\vSIGNAL_TERM\x10\x02\x12\x0f\n" +
"\vSIGNAL_KILL\x10\x032L\n" +
"\vExecService\x12=\n" +
"\x04Exec\x12\x17.clodrun.v1.ExecRequest\x1a\x18.clodrun.v1.ExecResponse(\x010\x01B\x9b\x01\n" +
"\x0ecom.clodrun.v1B\tExecProtoP\x01Z5github.com/imjasonh/clod-run/gen/clodrun/v1;clodrunv1\xa2\x02\x03CXX\xaa\x02\n" +
"Clodrun.V1\xca\x02\n" +
"Clodrun\\V1\xe2\x02\x16Clodrun\\V1\\GPBMetadata\xea\x02\vClodrun::V1b\x06proto3"
"\vSIGNAL_KILL\x10\x032H\n" +
"\vExecService\x129\n" +
"\x04Exec\x12\x15.crush.v1.ExecRequest\x1a\x16.crush.v1.ExecResponse(\x010\x01B\x8a\x01\n" +
"\fcom.crush.v1B\tExecProtoP\x01Z.github.com/imjasonh/crush/gen/crush/v1;crushv1\xa2\x02\x03CXX\xaa\x02\bCrush.V1\xca\x02\bCrush\\V1\xe2\x02\x14Crush\\V1\\GPBMetadata\xea\x02\tCrush::V1b\x06proto3"
var (
file_clodrun_v1_exec_proto_rawDescOnce sync.Once
file_clodrun_v1_exec_proto_rawDescData []byte
file_crush_v1_exec_proto_rawDescOnce sync.Once
file_crush_v1_exec_proto_rawDescData []byte
)
func file_clodrun_v1_exec_proto_rawDescGZIP() []byte {
file_clodrun_v1_exec_proto_rawDescOnce.Do(func() {
file_clodrun_v1_exec_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_clodrun_v1_exec_proto_rawDesc), len(file_clodrun_v1_exec_proto_rawDesc)))
func file_crush_v1_exec_proto_rawDescGZIP() []byte {
file_crush_v1_exec_proto_rawDescOnce.Do(func() {
file_crush_v1_exec_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_crush_v1_exec_proto_rawDesc), len(file_crush_v1_exec_proto_rawDesc)))
})
return file_clodrun_v1_exec_proto_rawDescData
return file_crush_v1_exec_proto_rawDescData
}
var file_clodrun_v1_exec_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_clodrun_v1_exec_proto_msgTypes = make([]protoimpl.MessageInfo, 6)
var file_clodrun_v1_exec_proto_goTypes = []any{
(Signal)(0), // 0: clodrun.v1.Signal
(*WindowSize)(nil), // 1: clodrun.v1.WindowSize
(*ExecRequest)(nil), // 2: clodrun.v1.ExecRequest
(*StartRequest)(nil), // 3: clodrun.v1.StartRequest
(*ExecResponse)(nil), // 4: clodrun.v1.ExecResponse
(*ExitStatus)(nil), // 5: clodrun.v1.ExitStatus
nil, // 6: clodrun.v1.StartRequest.EnvEntry
var file_crush_v1_exec_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_crush_v1_exec_proto_msgTypes = make([]protoimpl.MessageInfo, 6)
var file_crush_v1_exec_proto_goTypes = []any{
(Signal)(0), // 0: crush.v1.Signal
(*WindowSize)(nil), // 1: crush.v1.WindowSize
(*ExecRequest)(nil), // 2: crush.v1.ExecRequest
(*StartRequest)(nil), // 3: crush.v1.StartRequest
(*ExecResponse)(nil), // 4: crush.v1.ExecResponse
(*ExitStatus)(nil), // 5: crush.v1.ExitStatus
nil, // 6: crush.v1.StartRequest.EnvEntry
}
var file_clodrun_v1_exec_proto_depIdxs = []int32{
3, // 0: clodrun.v1.ExecRequest.start:type_name -> clodrun.v1.StartRequest
0, // 1: clodrun.v1.ExecRequest.signal:type_name -> clodrun.v1.Signal
1, // 2: clodrun.v1.ExecRequest.resize:type_name -> clodrun.v1.WindowSize
6, // 3: clodrun.v1.StartRequest.env:type_name -> clodrun.v1.StartRequest.EnvEntry
1, // 4: clodrun.v1.StartRequest.pty:type_name -> clodrun.v1.WindowSize
5, // 5: clodrun.v1.ExecResponse.exit_status:type_name -> clodrun.v1.ExitStatus
2, // 6: clodrun.v1.ExecService.Exec:input_type -> clodrun.v1.ExecRequest
4, // 7: clodrun.v1.ExecService.Exec:output_type -> clodrun.v1.ExecResponse
var file_crush_v1_exec_proto_depIdxs = []int32{
3, // 0: crush.v1.ExecRequest.start:type_name -> crush.v1.StartRequest
0, // 1: crush.v1.ExecRequest.signal:type_name -> crush.v1.Signal
1, // 2: crush.v1.ExecRequest.resize:type_name -> crush.v1.WindowSize
6, // 3: crush.v1.StartRequest.env:type_name -> crush.v1.StartRequest.EnvEntry
1, // 4: crush.v1.StartRequest.pty:type_name -> crush.v1.WindowSize
5, // 5: crush.v1.ExecResponse.exit_status:type_name -> crush.v1.ExitStatus
2, // 6: crush.v1.ExecService.Exec:input_type -> crush.v1.ExecRequest
4, // 7: crush.v1.ExecService.Exec:output_type -> crush.v1.ExecResponse
7, // [7:8] is the sub-list for method output_type
6, // [6:7] is the sub-list for method input_type
6, // [6:6] is the sub-list for extension type_name
@ -544,18 +541,18 @@ var file_clodrun_v1_exec_proto_depIdxs = []int32{
0, // [0:6] is the sub-list for field type_name
}
func init() { file_clodrun_v1_exec_proto_init() }
func file_clodrun_v1_exec_proto_init() {
if File_clodrun_v1_exec_proto != nil {
func init() { file_crush_v1_exec_proto_init() }
func file_crush_v1_exec_proto_init() {
if File_crush_v1_exec_proto != nil {
return
}
file_clodrun_v1_exec_proto_msgTypes[1].OneofWrappers = []any{
file_crush_v1_exec_proto_msgTypes[1].OneofWrappers = []any{
(*ExecRequest_Start)(nil),
(*ExecRequest_Stdin)(nil),
(*ExecRequest_Signal)(nil),
(*ExecRequest_Resize)(nil),
}
file_clodrun_v1_exec_proto_msgTypes[3].OneofWrappers = []any{
file_crush_v1_exec_proto_msgTypes[3].OneofWrappers = []any{
(*ExecResponse_Stdout)(nil),
(*ExecResponse_Stderr)(nil),
(*ExecResponse_ExitStatus)(nil),
@ -564,18 +561,18 @@ func file_clodrun_v1_exec_proto_init() {
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_clodrun_v1_exec_proto_rawDesc), len(file_clodrun_v1_exec_proto_rawDesc)),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_crush_v1_exec_proto_rawDesc), len(file_crush_v1_exec_proto_rawDesc)),
NumEnums: 1,
NumMessages: 6,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_clodrun_v1_exec_proto_goTypes,
DependencyIndexes: file_clodrun_v1_exec_proto_depIdxs,
EnumInfos: file_clodrun_v1_exec_proto_enumTypes,
MessageInfos: file_clodrun_v1_exec_proto_msgTypes,
GoTypes: file_crush_v1_exec_proto_goTypes,
DependencyIndexes: file_crush_v1_exec_proto_depIdxs,
EnumInfos: file_crush_v1_exec_proto_enumTypes,
MessageInfos: file_crush_v1_exec_proto_msgTypes,
}.Build()
File_clodrun_v1_exec_proto = out.File
file_clodrun_v1_exec_proto_goTypes = nil
file_clodrun_v1_exec_proto_depIdxs = nil
File_crush_v1_exec_proto = out.File
file_crush_v1_exec_proto_goTypes = nil
file_crush_v1_exec_proto_depIdxs = nil
}

10
gen/clodrun/v1/exec_grpc.pb.go → gen/crush/v1/exec_grpc.pb.go
View file

@ -2,9 +2,9 @@
// versions:
// - protoc-gen-go-grpc v1.6.1
// - protoc (unknown)
// source: clodrun/v1/exec.proto
// source: crush/v1/exec.proto
package clodrunv1
package crushv1
import (
context "context"
@ -19,7 +19,7 @@ import (
const _ = grpc.SupportPackageIsVersion9
const (
ExecService_Exec_FullMethodName = "/clodrun.v1.ExecService/Exec"
ExecService_Exec_FullMethodName = "/crush.v1.ExecService/Exec"
)
// ExecServiceClient is the client API for ExecService service.
@ -100,7 +100,7 @@ type ExecService_ExecServer = grpc.BidiStreamingServer[ExecRequest, ExecResponse
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var ExecService_ServiceDesc = grpc.ServiceDesc{
ServiceName: "clodrun.v1.ExecService",
ServiceName: "crush.v1.ExecService",
HandlerType: (*ExecServiceServer)(nil),
Methods: []grpc.MethodDesc{},
Streams: []grpc.StreamDesc{
@ -111,5 +111,5 @@ var ExecService_ServiceDesc = grpc.ServiceDesc{
ClientStreams: true,
},
},
Metadata: "clodrun/v1/exec.proto",
Metadata: "crush/v1/exec.proto",
}

2
go.mod
View file

@ -1,4 +1,4 @@
module github.com/imjasonh/clod-run
module github.com/imjasonh/crush
go 1.25.5

4
internal/client/client.go
View file

@ -4,8 +4,8 @@ import (
"context"
"fmt"
"io"
pb "github.com/imjasonh/clod-run/gen/clodrun/v1"
"github.com/imjasonh/clod-run/internal/auth"
pb "github.com/imjasonh/crush/gen/crush/v1"
"github.com/imjasonh/crush/internal/auth"
"google.golang.org/grpc"
"google.golang.org/grpc/credentials"
"google.golang.org/grpc/credentials/insecure"

2
internal/repl/repl.go
View file

@ -8,7 +8,7 @@ import (
"os/signal"
"syscall"
pb "github.com/imjasonh/clod-run/gen/clodrun/v1"
pb "github.com/imjasonh/crush/gen/crush/v1"
"golang.org/x/term"
)

2
internal/server/server.go
View file

@ -10,7 +10,7 @@ import (
"github.com/chainguard-dev/clog"
"github.com/creack/pty"
pb "github.com/imjasonh/clod-run/gen/clodrun/v1"
pb "github.com/imjasonh/crush/gen/crush/v1"
"google.golang.org/grpc"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"

2
internal/server/server_test.go
View file

@ -9,7 +9,7 @@ import (
"testing"
"github.com/creack/pty"
pb "github.com/imjasonh/clod-run/gen/clodrun/v1"
pb "github.com/imjasonh/crush/gen/crush/v1"
"google.golang.org/grpc"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/credentials/insecure"

4
proto/clodrun/v1/exec.proto → proto/crush/v1/exec.proto
View file

@ -1,8 +1,8 @@
syntax = "proto3";
package clodrun.v1;
package crush.v1;
option go_package = "github.com/imjasonh/clod-run/gen/clodrun/v1;clodrunv1";
option go_package = "github.com/imjasonh/crush/gen/crush/v1;crushv1";
service ExecService {
rpc Exec(stream ExecRequest) returns (stream ExecResponse);