diff options
Diffstat (limited to 'weed/pb/master_pb/master_grpc.pb.go')
| -rw-r--r-- | weed/pb/master_pb/master_grpc.pb.go | 39 |
1 files changed, 38 insertions, 1 deletions
diff --git a/weed/pb/master_pb/master_grpc.pb.go b/weed/pb/master_pb/master_grpc.pb.go index 4c41658cf..c2f631827 100644 --- a/weed/pb/master_pb/master_grpc.pb.go +++ b/weed/pb/master_pb/master_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.3.0 -// - protoc v4.25.3 +// - protoc v5.26.1 // source: master.proto package master_pb @@ -41,6 +41,7 @@ const ( Seaweed_RaftListClusterServers_FullMethodName = "/master_pb.Seaweed/RaftListClusterServers" Seaweed_RaftAddServer_FullMethodName = "/master_pb.Seaweed/RaftAddServer" Seaweed_RaftRemoveServer_FullMethodName = "/master_pb.Seaweed/RaftRemoveServer" + Seaweed_VolumeGrow_FullMethodName = "/master_pb.Seaweed/VolumeGrow" ) // SeaweedClient is the client API for Seaweed service. @@ -69,6 +70,7 @@ type SeaweedClient interface { RaftListClusterServers(ctx context.Context, in *RaftListClusterServersRequest, opts ...grpc.CallOption) (*RaftListClusterServersResponse, error) RaftAddServer(ctx context.Context, in *RaftAddServerRequest, opts ...grpc.CallOption) (*RaftAddServerResponse, error) RaftRemoveServer(ctx context.Context, in *RaftRemoveServerRequest, opts ...grpc.CallOption) (*RaftRemoveServerResponse, error) + VolumeGrow(ctx context.Context, in *VolumeGrowRequest, opts ...grpc.CallOption) (*VolumeGrowResponse, error) } type seaweedClient struct { @@ -343,6 +345,15 @@ func (c *seaweedClient) RaftRemoveServer(ctx context.Context, in *RaftRemoveServ return out, nil } +func (c *seaweedClient) VolumeGrow(ctx context.Context, in *VolumeGrowRequest, opts ...grpc.CallOption) (*VolumeGrowResponse, error) { + out := new(VolumeGrowResponse) + err := c.cc.Invoke(ctx, Seaweed_VolumeGrow_FullMethodName, in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + // SeaweedServer is the server API for Seaweed service. // All implementations must embed UnimplementedSeaweedServer // for forward compatibility @@ -369,6 +380,7 @@ type SeaweedServer interface { RaftListClusterServers(context.Context, *RaftListClusterServersRequest) (*RaftListClusterServersResponse, error) RaftAddServer(context.Context, *RaftAddServerRequest) (*RaftAddServerResponse, error) RaftRemoveServer(context.Context, *RaftRemoveServerRequest) (*RaftRemoveServerResponse, error) + VolumeGrow(context.Context, *VolumeGrowRequest) (*VolumeGrowResponse, error) mustEmbedUnimplementedSeaweedServer() } @@ -442,6 +454,9 @@ func (UnimplementedSeaweedServer) RaftAddServer(context.Context, *RaftAddServerR func (UnimplementedSeaweedServer) RaftRemoveServer(context.Context, *RaftRemoveServerRequest) (*RaftRemoveServerResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method RaftRemoveServer not implemented") } +func (UnimplementedSeaweedServer) VolumeGrow(context.Context, *VolumeGrowRequest) (*VolumeGrowResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method VolumeGrow not implemented") +} func (UnimplementedSeaweedServer) mustEmbedUnimplementedSeaweedServer() {} // UnsafeSeaweedServer may be embedded to opt out of forward compatibility for this service. @@ -875,6 +890,24 @@ func _Seaweed_RaftRemoveServer_Handler(srv interface{}, ctx context.Context, dec return interceptor(ctx, in, info, handler) } +func _Seaweed_VolumeGrow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(VolumeGrowRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(SeaweedServer).VolumeGrow(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Seaweed_VolumeGrow_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(SeaweedServer).VolumeGrow(ctx, req.(*VolumeGrowRequest)) + } + return interceptor(ctx, in, info, handler) +} + // Seaweed_ServiceDesc is the grpc.ServiceDesc for Seaweed service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) @@ -958,6 +991,10 @@ var Seaweed_ServiceDesc = grpc.ServiceDesc{ MethodName: "RaftRemoveServer", Handler: _Seaweed_RaftRemoveServer_Handler, }, + { + MethodName: "VolumeGrow", + Handler: _Seaweed_VolumeGrow_Handler, + }, }, Streams: []grpc.StreamDesc{ { |