(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
| 5638 | } |
| 5639 | |
| 5640 | func _Raft_JoinCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 5641 | in := new(RaftContext) |
| 5642 | if err := dec(in); err != nil { |
| 5643 | return nil, err |
| 5644 | } |
| 5645 | if interceptor == nil { |
| 5646 | return srv.(RaftServer).JoinCluster(ctx, in) |
| 5647 | } |
| 5648 | info := &grpc.UnaryServerInfo{ |
| 5649 | Server: srv, |
| 5650 | FullMethod: "/pb.Raft/JoinCluster", |
| 5651 | } |
| 5652 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 5653 | return srv.(RaftServer).JoinCluster(ctx, req.(*RaftContext)) |
| 5654 | } |
| 5655 | return interceptor(ctx, in, info, handler) |
| 5656 | } |
| 5657 | |
| 5658 | func _Raft_IsPeer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 5659 | in := new(RaftContext) |
nothing calls this directly
no test coverage detected