Distributor registers logproto.Pusher service to receive logs via GRPC (

#2922)
grafana · Nov 13, 2020 · a5cc650 · a5cc650
1 parent f0d4adc
commit a5cc650
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/loki/modules.go b/pkg/loki/modules.go
@@ -144,6 +144,8 @@ func (t *Loki) initDistributor() (services.Service, error) {
 		return nil, err
 	}
 
+	logproto.RegisterPusherServer(t.server.GRPC, t.distributor)
+
 	pushHandler := middleware.Merge(
 		serverutil.RecoveryHTTPMiddleware,
 		t.httpAuthMiddleware,