diff options
Diffstat (limited to 'tvix/store/protos/rpc_blobstore_grpc.pb.go')
| -rw-r--r-- | tvix/store/protos/rpc_blobstore_grpc.pb.go | 19 |
1 files changed, 14 insertions, 5 deletions
diff --git a/tvix/store/protos/rpc_blobstore_grpc.pb.go b/tvix/store/protos/rpc_blobstore_grpc.pb.go index 25b3c0006a..5199fe1511 100644 --- a/tvix/store/protos/rpc_blobstore_grpc.pb.go +++ b/tvix/store/protos/rpc_blobstore_grpc.pb.go @@ -1,6 +1,9 @@ +// SPDX-License-Identifier: MIT +// Copyright © 2022 The Tvix Authors + // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc (unknown) // source: tvix/store/protos/rpc_blobstore.proto @@ -18,6 +21,12 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + BlobService_Stat_FullMethodName = "/tvix.store.v1.BlobService/Stat" + BlobService_Read_FullMethodName = "/tvix.store.v1.BlobService/Read" + BlobService_Put_FullMethodName = "/tvix.store.v1.BlobService/Put" +) + // BlobServiceClient is the client API for BlobService service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -62,7 +71,7 @@ func NewBlobServiceClient(cc grpc.ClientConnInterface) BlobServiceClient { func (c *blobServiceClient) Stat(ctx context.Context, in *StatBlobRequest, opts ...grpc.CallOption) (*BlobMeta, error) { out := new(BlobMeta) - err := c.cc.Invoke(ctx, "/tvix.store.v1.BlobService/Stat", in, out, opts...) + err := c.cc.Invoke(ctx, BlobService_Stat_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -70,7 +79,7 @@ func (c *blobServiceClient) Stat(ctx context.Context, in *StatBlobRequest, opts } func (c *blobServiceClient) Read(ctx context.Context, in *ReadBlobRequest, opts ...grpc.CallOption) (BlobService_ReadClient, error) { - stream, err := c.cc.NewStream(ctx, &BlobService_ServiceDesc.Streams[0], "/tvix.store.v1.BlobService/Read", opts...) + stream, err := c.cc.NewStream(ctx, &BlobService_ServiceDesc.Streams[0], BlobService_Read_FullMethodName, opts...) if err != nil { return nil, err } @@ -102,7 +111,7 @@ func (x *blobServiceReadClient) Recv() (*BlobChunk, error) { } func (c *blobServiceClient) Put(ctx context.Context, opts ...grpc.CallOption) (BlobService_PutClient, error) { - stream, err := c.cc.NewStream(ctx, &BlobService_ServiceDesc.Streams[1], "/tvix.store.v1.BlobService/Put", opts...) + stream, err := c.cc.NewStream(ctx, &BlobService_ServiceDesc.Streams[1], BlobService_Put_FullMethodName, opts...) if err != nil { return nil, err } @@ -206,7 +215,7 @@ func _BlobService_Stat_Handler(srv interface{}, ctx context.Context, dec func(in } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/tvix.store.v1.BlobService/Stat", + FullMethod: BlobService_Stat_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(BlobServiceServer).Stat(ctx, req.(*StatBlobRequest)) |