| 3147 | } |
| 3148 | |
| 3149 | func _Pusher_PushBytes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 3150 | in := new(PushBytesRequest) |
| 3151 | if err := dec(in); err != nil { |
| 3152 | return nil, err |
| 3153 | } |
| 3154 | if interceptor == nil { |
| 3155 | return srv.(PusherServer).PushBytes(ctx, in) |
| 3156 | } |
| 3157 | info := &grpc.UnaryServerInfo{ |
| 3158 | Server: srv, |
| 3159 | FullMethod: "/tempopb.Pusher/PushBytes", |
| 3160 | } |
| 3161 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 3162 | return srv.(PusherServer).PushBytes(ctx, req.(*PushBytesRequest)) |
| 3163 | } |
| 3164 | return interceptor(ctx, in, info, handler) |
| 3165 | } |
| 3166 | |
| 3167 | func _Pusher_PushBytesV2_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 3168 | in := new(PushBytesRequest) |