diff options
Diffstat (limited to 'weed/pb/master_pb/master_grpc.pb.go')
| -rw-r--r-- | weed/pb/master_pb/master_grpc.pb.go | 111 |
1 files changed, 68 insertions, 43 deletions
diff --git a/weed/pb/master_pb/master_grpc.pb.go b/weed/pb/master_pb/master_grpc.pb.go index 2afcdbbd9..5406444fe 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.2.0 -// - protoc v4.23.3 +// - protoc-gen-go-grpc v1.3.0 +// - protoc v4.24.4 // source: master.proto package master_pb @@ -18,6 +18,31 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + Seaweed_SendHeartbeat_FullMethodName = "/master_pb.Seaweed/SendHeartbeat" + Seaweed_KeepConnected_FullMethodName = "/master_pb.Seaweed/KeepConnected" + Seaweed_LookupVolume_FullMethodName = "/master_pb.Seaweed/LookupVolume" + Seaweed_Assign_FullMethodName = "/master_pb.Seaweed/Assign" + Seaweed_StreamAssign_FullMethodName = "/master_pb.Seaweed/StreamAssign" + Seaweed_Statistics_FullMethodName = "/master_pb.Seaweed/Statistics" + Seaweed_CollectionList_FullMethodName = "/master_pb.Seaweed/CollectionList" + Seaweed_CollectionDelete_FullMethodName = "/master_pb.Seaweed/CollectionDelete" + Seaweed_VolumeList_FullMethodName = "/master_pb.Seaweed/VolumeList" + Seaweed_LookupEcVolume_FullMethodName = "/master_pb.Seaweed/LookupEcVolume" + Seaweed_VacuumVolume_FullMethodName = "/master_pb.Seaweed/VacuumVolume" + Seaweed_DisableVacuum_FullMethodName = "/master_pb.Seaweed/DisableVacuum" + Seaweed_EnableVacuum_FullMethodName = "/master_pb.Seaweed/EnableVacuum" + Seaweed_VolumeMarkReadonly_FullMethodName = "/master_pb.Seaweed/VolumeMarkReadonly" + Seaweed_GetMasterConfiguration_FullMethodName = "/master_pb.Seaweed/GetMasterConfiguration" + Seaweed_ListClusterNodes_FullMethodName = "/master_pb.Seaweed/ListClusterNodes" + Seaweed_LeaseAdminToken_FullMethodName = "/master_pb.Seaweed/LeaseAdminToken" + Seaweed_ReleaseAdminToken_FullMethodName = "/master_pb.Seaweed/ReleaseAdminToken" + Seaweed_Ping_FullMethodName = "/master_pb.Seaweed/Ping" + Seaweed_RaftListClusterServers_FullMethodName = "/master_pb.Seaweed/RaftListClusterServers" + Seaweed_RaftAddServer_FullMethodName = "/master_pb.Seaweed/RaftAddServer" + Seaweed_RaftRemoveServer_FullMethodName = "/master_pb.Seaweed/RaftRemoveServer" +) + // SeaweedClient is the client API for Seaweed 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. @@ -55,7 +80,7 @@ func NewSeaweedClient(cc grpc.ClientConnInterface) SeaweedClient { } func (c *seaweedClient) SendHeartbeat(ctx context.Context, opts ...grpc.CallOption) (Seaweed_SendHeartbeatClient, error) { - stream, err := c.cc.NewStream(ctx, &Seaweed_ServiceDesc.Streams[0], "/master_pb.Seaweed/SendHeartbeat", opts...) + stream, err := c.cc.NewStream(ctx, &Seaweed_ServiceDesc.Streams[0], Seaweed_SendHeartbeat_FullMethodName, opts...) if err != nil { return nil, err } @@ -86,7 +111,7 @@ func (x *seaweedSendHeartbeatClient) Recv() (*HeartbeatResponse, error) { } func (c *seaweedClient) KeepConnected(ctx context.Context, opts ...grpc.CallOption) (Seaweed_KeepConnectedClient, error) { - stream, err := c.cc.NewStream(ctx, &Seaweed_ServiceDesc.Streams[1], "/master_pb.Seaweed/KeepConnected", opts...) + stream, err := c.cc.NewStream(ctx, &Seaweed_ServiceDesc.Streams[1], Seaweed_KeepConnected_FullMethodName, opts...) if err != nil { return nil, err } @@ -118,7 +143,7 @@ func (x *seaweedKeepConnectedClient) Recv() (*KeepConnectedResponse, error) { func (c *seaweedClient) LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error) { out := new(LookupVolumeResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/LookupVolume", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_LookupVolume_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -127,7 +152,7 @@ func (c *seaweedClient) LookupVolume(ctx context.Context, in *LookupVolumeReques func (c *seaweedClient) Assign(ctx context.Context, in *AssignRequest, opts ...grpc.CallOption) (*AssignResponse, error) { out := new(AssignResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/Assign", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_Assign_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -135,7 +160,7 @@ func (c *seaweedClient) Assign(ctx context.Context, in *AssignRequest, opts ...g } func (c *seaweedClient) StreamAssign(ctx context.Context, opts ...grpc.CallOption) (Seaweed_StreamAssignClient, error) { - stream, err := c.cc.NewStream(ctx, &Seaweed_ServiceDesc.Streams[2], "/master_pb.Seaweed/StreamAssign", opts...) + stream, err := c.cc.NewStream(ctx, &Seaweed_ServiceDesc.Streams[2], Seaweed_StreamAssign_FullMethodName, opts...) if err != nil { return nil, err } @@ -167,7 +192,7 @@ func (x *seaweedStreamAssignClient) Recv() (*AssignResponse, error) { func (c *seaweedClient) Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error) { out := new(StatisticsResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/Statistics", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_Statistics_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -176,7 +201,7 @@ func (c *seaweedClient) Statistics(ctx context.Context, in *StatisticsRequest, o func (c *seaweedClient) CollectionList(ctx context.Context, in *CollectionListRequest, opts ...grpc.CallOption) (*CollectionListResponse, error) { out := new(CollectionListResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/CollectionList", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_CollectionList_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -185,7 +210,7 @@ func (c *seaweedClient) CollectionList(ctx context.Context, in *CollectionListRe func (c *seaweedClient) CollectionDelete(ctx context.Context, in *CollectionDeleteRequest, opts ...grpc.CallOption) (*CollectionDeleteResponse, error) { out := new(CollectionDeleteResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/CollectionDelete", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_CollectionDelete_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -194,7 +219,7 @@ func (c *seaweedClient) CollectionDelete(ctx context.Context, in *CollectionDele func (c *seaweedClient) VolumeList(ctx context.Context, in *VolumeListRequest, opts ...grpc.CallOption) (*VolumeListResponse, error) { out := new(VolumeListResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/VolumeList", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_VolumeList_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -203,7 +228,7 @@ func (c *seaweedClient) VolumeList(ctx context.Context, in *VolumeListRequest, o func (c *seaweedClient) LookupEcVolume(ctx context.Context, in *LookupEcVolumeRequest, opts ...grpc.CallOption) (*LookupEcVolumeResponse, error) { out := new(LookupEcVolumeResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/LookupEcVolume", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_LookupEcVolume_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -212,7 +237,7 @@ func (c *seaweedClient) LookupEcVolume(ctx context.Context, in *LookupEcVolumeRe func (c *seaweedClient) VacuumVolume(ctx context.Context, in *VacuumVolumeRequest, opts ...grpc.CallOption) (*VacuumVolumeResponse, error) { out := new(VacuumVolumeResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/VacuumVolume", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_VacuumVolume_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -221,7 +246,7 @@ func (c *seaweedClient) VacuumVolume(ctx context.Context, in *VacuumVolumeReques func (c *seaweedClient) DisableVacuum(ctx context.Context, in *DisableVacuumRequest, opts ...grpc.CallOption) (*DisableVacuumResponse, error) { out := new(DisableVacuumResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/DisableVacuum", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_DisableVacuum_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -230,7 +255,7 @@ func (c *seaweedClient) DisableVacuum(ctx context.Context, in *DisableVacuumRequ func (c *seaweedClient) EnableVacuum(ctx context.Context, in *EnableVacuumRequest, opts ...grpc.CallOption) (*EnableVacuumResponse, error) { out := new(EnableVacuumResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/EnableVacuum", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_EnableVacuum_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -239,7 +264,7 @@ func (c *seaweedClient) EnableVacuum(ctx context.Context, in *EnableVacuumReques func (c *seaweedClient) VolumeMarkReadonly(ctx context.Context, in *VolumeMarkReadonlyRequest, opts ...grpc.CallOption) (*VolumeMarkReadonlyResponse, error) { out := new(VolumeMarkReadonlyResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/VolumeMarkReadonly", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_VolumeMarkReadonly_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -248,7 +273,7 @@ func (c *seaweedClient) VolumeMarkReadonly(ctx context.Context, in *VolumeMarkRe func (c *seaweedClient) GetMasterConfiguration(ctx context.Context, in *GetMasterConfigurationRequest, opts ...grpc.CallOption) (*GetMasterConfigurationResponse, error) { out := new(GetMasterConfigurationResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/GetMasterConfiguration", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_GetMasterConfiguration_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -257,7 +282,7 @@ func (c *seaweedClient) GetMasterConfiguration(ctx context.Context, in *GetMaste func (c *seaweedClient) ListClusterNodes(ctx context.Context, in *ListClusterNodesRequest, opts ...grpc.CallOption) (*ListClusterNodesResponse, error) { out := new(ListClusterNodesResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/ListClusterNodes", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_ListClusterNodes_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -266,7 +291,7 @@ func (c *seaweedClient) ListClusterNodes(ctx context.Context, in *ListClusterNod func (c *seaweedClient) LeaseAdminToken(ctx context.Context, in *LeaseAdminTokenRequest, opts ...grpc.CallOption) (*LeaseAdminTokenResponse, error) { out := new(LeaseAdminTokenResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/LeaseAdminToken", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_LeaseAdminToken_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -275,7 +300,7 @@ func (c *seaweedClient) LeaseAdminToken(ctx context.Context, in *LeaseAdminToken func (c *seaweedClient) ReleaseAdminToken(ctx context.Context, in *ReleaseAdminTokenRequest, opts ...grpc.CallOption) (*ReleaseAdminTokenResponse, error) { out := new(ReleaseAdminTokenResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/ReleaseAdminToken", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_ReleaseAdminToken_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -284,7 +309,7 @@ func (c *seaweedClient) ReleaseAdminToken(ctx context.Context, in *ReleaseAdminT func (c *seaweedClient) Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) { out := new(PingResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/Ping", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_Ping_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -293,7 +318,7 @@ func (c *seaweedClient) Ping(ctx context.Context, in *PingRequest, opts ...grpc. func (c *seaweedClient) RaftListClusterServers(ctx context.Context, in *RaftListClusterServersRequest, opts ...grpc.CallOption) (*RaftListClusterServersResponse, error) { out := new(RaftListClusterServersResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/RaftListClusterServers", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_RaftListClusterServers_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -302,7 +327,7 @@ func (c *seaweedClient) RaftListClusterServers(ctx context.Context, in *RaftList func (c *seaweedClient) RaftAddServer(ctx context.Context, in *RaftAddServerRequest, opts ...grpc.CallOption) (*RaftAddServerResponse, error) { out := new(RaftAddServerResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/RaftAddServer", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_RaftAddServer_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -311,7 +336,7 @@ func (c *seaweedClient) RaftAddServer(ctx context.Context, in *RaftAddServerRequ func (c *seaweedClient) RaftRemoveServer(ctx context.Context, in *RaftRemoveServerRequest, opts ...grpc.CallOption) (*RaftRemoveServerResponse, error) { out := new(RaftRemoveServerResponse) - err := c.cc.Invoke(ctx, "/master_pb.Seaweed/RaftRemoveServer", in, out, opts...) + err := c.cc.Invoke(ctx, Seaweed_RaftRemoveServer_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -492,7 +517,7 @@ func _Seaweed_LookupVolume_Handler(srv interface{}, ctx context.Context, dec fun } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/LookupVolume", + FullMethod: Seaweed_LookupVolume_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).LookupVolume(ctx, req.(*LookupVolumeRequest)) @@ -510,7 +535,7 @@ func _Seaweed_Assign_Handler(srv interface{}, ctx context.Context, dec func(inte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/Assign", + FullMethod: Seaweed_Assign_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).Assign(ctx, req.(*AssignRequest)) @@ -554,7 +579,7 @@ func _Seaweed_Statistics_Handler(srv interface{}, ctx context.Context, dec func( } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/Statistics", + FullMethod: Seaweed_Statistics_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).Statistics(ctx, req.(*StatisticsRequest)) @@ -572,7 +597,7 @@ func _Seaweed_CollectionList_Handler(srv interface{}, ctx context.Context, dec f } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/CollectionList", + FullMethod: Seaweed_CollectionList_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).CollectionList(ctx, req.(*CollectionListRequest)) @@ -590,7 +615,7 @@ func _Seaweed_CollectionDelete_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/CollectionDelete", + FullMethod: Seaweed_CollectionDelete_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).CollectionDelete(ctx, req.(*CollectionDeleteRequest)) @@ -608,7 +633,7 @@ func _Seaweed_VolumeList_Handler(srv interface{}, ctx context.Context, dec func( } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/VolumeList", + FullMethod: Seaweed_VolumeList_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).VolumeList(ctx, req.(*VolumeListRequest)) @@ -626,7 +651,7 @@ func _Seaweed_LookupEcVolume_Handler(srv interface{}, ctx context.Context, dec f } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/LookupEcVolume", + FullMethod: Seaweed_LookupEcVolume_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).LookupEcVolume(ctx, req.(*LookupEcVolumeRequest)) @@ -644,7 +669,7 @@ func _Seaweed_VacuumVolume_Handler(srv interface{}, ctx context.Context, dec fun } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/VacuumVolume", + FullMethod: Seaweed_VacuumVolume_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).VacuumVolume(ctx, req.(*VacuumVolumeRequest)) @@ -662,7 +687,7 @@ func _Seaweed_DisableVacuum_Handler(srv interface{}, ctx context.Context, dec fu } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/DisableVacuum", + FullMethod: Seaweed_DisableVacuum_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).DisableVacuum(ctx, req.(*DisableVacuumRequest)) @@ -680,7 +705,7 @@ func _Seaweed_EnableVacuum_Handler(srv interface{}, ctx context.Context, dec fun } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/EnableVacuum", + FullMethod: Seaweed_EnableVacuum_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).EnableVacuum(ctx, req.(*EnableVacuumRequest)) @@ -698,7 +723,7 @@ func _Seaweed_VolumeMarkReadonly_Handler(srv interface{}, ctx context.Context, d } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/VolumeMarkReadonly", + FullMethod: Seaweed_VolumeMarkReadonly_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).VolumeMarkReadonly(ctx, req.(*VolumeMarkReadonlyRequest)) @@ -716,7 +741,7 @@ func _Seaweed_GetMasterConfiguration_Handler(srv interface{}, ctx context.Contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/GetMasterConfiguration", + FullMethod: Seaweed_GetMasterConfiguration_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).GetMasterConfiguration(ctx, req.(*GetMasterConfigurationRequest)) @@ -734,7 +759,7 @@ func _Seaweed_ListClusterNodes_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/ListClusterNodes", + FullMethod: Seaweed_ListClusterNodes_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).ListClusterNodes(ctx, req.(*ListClusterNodesRequest)) @@ -752,7 +777,7 @@ func _Seaweed_LeaseAdminToken_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/LeaseAdminToken", + FullMethod: Seaweed_LeaseAdminToken_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).LeaseAdminToken(ctx, req.(*LeaseAdminTokenRequest)) @@ -770,7 +795,7 @@ func _Seaweed_ReleaseAdminToken_Handler(srv interface{}, ctx context.Context, de } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/ReleaseAdminToken", + FullMethod: Seaweed_ReleaseAdminToken_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).ReleaseAdminToken(ctx, req.(*ReleaseAdminTokenRequest)) @@ -788,7 +813,7 @@ func _Seaweed_Ping_Handler(srv interface{}, ctx context.Context, dec func(interf } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/Ping", + FullMethod: Seaweed_Ping_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).Ping(ctx, req.(*PingRequest)) @@ -806,7 +831,7 @@ func _Seaweed_RaftListClusterServers_Handler(srv interface{}, ctx context.Contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/RaftListClusterServers", + FullMethod: Seaweed_RaftListClusterServers_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).RaftListClusterServers(ctx, req.(*RaftListClusterServersRequest)) @@ -824,7 +849,7 @@ func _Seaweed_RaftAddServer_Handler(srv interface{}, ctx context.Context, dec fu } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/RaftAddServer", + FullMethod: Seaweed_RaftAddServer_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).RaftAddServer(ctx, req.(*RaftAddServerRequest)) @@ -842,7 +867,7 @@ func _Seaweed_RaftRemoveServer_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/master_pb.Seaweed/RaftRemoveServer", + FullMethod: Seaweed_RaftRemoveServer_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(SeaweedServer).RaftRemoveServer(ctx, req.(*RaftRemoveServerRequest)) |