func RegisterFlightServiceService()

in arrow/flight/Flight_grpc.pb.go [645:748]
103 lines of code
10 McCabe index (conditional complexity)

func RegisterFlightServiceService(s grpc.ServiceRegistrar, srv *FlightServiceService) {
	srvCopy := *srv
	if srvCopy.Handshake == nil {
		srvCopy.Handshake = func(FlightService_HandshakeServer) error {
			return status.Errorf(codes.Unimplemented, "method Handshake not implemented")
		}
	}
	if srvCopy.ListFlights == nil {
		srvCopy.ListFlights = func(*Criteria, FlightService_ListFlightsServer) error {
			return status.Errorf(codes.Unimplemented, "method ListFlights not implemented")
		}
	}
	if srvCopy.GetFlightInfo == nil {
		srvCopy.GetFlightInfo = func(context.Context, *FlightDescriptor) (*FlightInfo, error) {
			return nil, status.Errorf(codes.Unimplemented, "method GetFlightInfo not implemented")
		}
	}
	if srvCopy.GetSchema == nil {
		srvCopy.GetSchema = func(context.Context, *FlightDescriptor) (*SchemaResult, error) {
			return nil, status.Errorf(codes.Unimplemented, "method GetSchema not implemented")
		}
	}
	if srvCopy.DoGet == nil {
		srvCopy.DoGet = func(*Ticket, FlightService_DoGetServer) error {
			return status.Errorf(codes.Unimplemented, "method DoGet not implemented")
		}
	}
	if srvCopy.DoPut == nil {
		srvCopy.DoPut = func(FlightService_DoPutServer) error {
			return status.Errorf(codes.Unimplemented, "method DoPut not implemented")
		}
	}
	if srvCopy.DoExchange == nil {
		srvCopy.DoExchange = func(FlightService_DoExchangeServer) error {
			return status.Errorf(codes.Unimplemented, "method DoExchange not implemented")
		}
	}
	if srvCopy.DoAction == nil {
		srvCopy.DoAction = func(*Action, FlightService_DoActionServer) error {
			return status.Errorf(codes.Unimplemented, "method DoAction not implemented")
		}
	}
	if srvCopy.ListActions == nil {
		srvCopy.ListActions = func(*Empty, FlightService_ListActionsServer) error {
			return status.Errorf(codes.Unimplemented, "method ListActions not implemented")
		}
	}
	sd := grpc.ServiceDesc{
		ServiceName: "arrow.flight.protocol.FlightService",
		Methods: []grpc.MethodDesc{
			{
				MethodName: "GetFlightInfo",
				Handler:    srvCopy.getFlightInfo,
			},
			{
				MethodName: "GetSchema",
				Handler:    srvCopy.getSchema,
			},
		},
		Streams: []grpc.StreamDesc{
			{
				StreamName:    "Handshake",
				Handler:       srvCopy.handshake,
				ServerStreams: true,
				ClientStreams: true,
			},
			{
				StreamName:    "ListFlights",
				Handler:       srvCopy.listFlights,
				ServerStreams: true,
			},
			{
				StreamName:    "DoGet",
				Handler:       srvCopy.doGet,
				ServerStreams: true,
			},
			{
				StreamName:    "DoPut",
				Handler:       srvCopy.doPut,
				ServerStreams: true,
				ClientStreams: true,
			},
			{
				StreamName:    "DoExchange",
				Handler:       srvCopy.doExchange,
				ServerStreams: true,
				ClientStreams: true,
			},
			{
				StreamName:    "DoAction",
				Handler:       srvCopy.doAction,
				ServerStreams: true,
			},
			{
				StreamName:    "ListActions",
				Handler:       srvCopy.listActions,
				ServerStreams: true,
			},
		},
		Metadata: "Flight.proto",
	}

	s.RegisterService(&sd, nil)
}