| LOW | main.go | 1 | // Copyright (c) Centrifugal Labs LTD | COMMENT |
| LOW | misc/packaging/initd.sh | 1 | #! /usr/bin/env bash | COMMENT |
| LOW | misc/scripts/test_packages.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | misc/scripts/release_preflight.sh | 1 | #!/bin/sh | COMMENT |
| LOW | internal/jwtverify/token_verifier.go | 21 | // Info contains additional information about connection. It will be | COMMENT |
| LOW | internal/jwtverify/token_verifier_jwt_test.go | 41 | // Generated with: https://github.com/lestrrat-go/jwx/tree/main/cmd/jwx | COMMENT |
| LOW | internal/jwtverify/token_verifier_jwt_test.go | 121 | | COMMENT |
| LOW | internal/jwtverify/token_verifier_jwt.go | 201 | // to manually track its position inside a stream. | COMMENT |
| LOW | internal/middleware/auththrottle.go | 101 | } | COMMENT |
| LOW | internal/websocket/server.go | 21 | | COMMENT |
| LOW | internal/websocket/server.go | 41 | // is not set, then write buffers are allocated to the connection for the | COMMENT |
| LOW | internal/websocket/server.go | 61 | Error func(w http.ResponseWriter, r *http.Request, status int, reason error) | COMMENT |
| LOW | internal/websocket/client.go | 41 | // NetDialTLSContext is nil, NetDialContext is used. | COMMENT |
| LOW | internal/websocket/client.go | 61 | // is not set, then write buffers are allocated to the connection for the | COMMENT |
| LOW | internal/websocket/util.go | 241 | } | COMMENT |
| LOW | internal/websocket/doc.go | 1 | // Copyright 2013 The Gorilla WebSocket Authors. All rights reserved. | COMMENT |
| LOW | internal/websocket/conn.go | 841 | if mask != c.isServer { | COMMENT |
| LOW | internal/pgschema/pgschema.go | 61 | // a PostgreSQL identifier. Every table, index and function name is this prefix | COMMENT |
| LOW | internal/pgschema/pgschema.go | 141 | // | COMMENT |
| LOW | internal/pgschema/pgschema.go | 161 | // nodes running the same idempotent schema DDL at the same time. That is the | COMMENT |
| LOW | internal/pgschema/pgschema.go | 201 | schemaExecBaseBackoff = 100 * time.Millisecond | COMMENT |
| LOW | internal/pgschema/pgschema.go | 261 | // All variants run in one transaction; a failure on any rolls back every | COMMENT |
| LOW | internal/pgschema/pgschema.go | 321 | } | COMMENT |
| LOW | internal/pgstreambroker/pgstreambroker_test.go | 121 | fmt.Sprintf("DROP TABLE IF EXISTS %sshard_lock CASCADE", prefix), | COMMENT |
| LOW | internal/pgstreambroker/pgstreambroker_test.go | 1041 | // TestPostgresStreamBroker_PartitionRetention_LookaheadAndDrop verifies that | COMMENT |
| LOW | internal/pgstreambroker/pgstreambroker.go | 1 | // Package pgstreambroker implements centrifuge.Broker using PostgreSQL as | COMMENT |
| LOW | internal/pgstreambroker/pgstreambroker.go | 201 | // TLS is an optional TLS configuration applied to all pools (primary, | COMMENT |
| LOW | internal/pgstreambroker/pgstreambroker.go | 221 | | COMMENT |
| LOW | internal/pgstreambroker/pgstreambroker.go | 241 | StreamRetention time.Duration | COMMENT |
| LOW | internal/pgstreambroker/pgstreambroker.go | 261 | // Default: same as PoolSize. | COMMENT |
| LOW | internal/pgstreambroker/outbox.go | 61 | } | COMMENT |
| LOW | internal/pgstreambroker/ensure_schema.go | 121 | // atomic schema_version bump. | COMMENT |
| LOW | internal/pgmapbroker/pgmapbroker_test.go | 1761 | return exists | COMMENT |
| LOW | internal/pgmapbroker/pgmapbroker.go | 41 | // EnsureSchema renders the template once per variant (jsonb + binary) and | COMMENT |
| LOW | internal/pgmapbroker/pgmapbroker.go | 121 | return sql[:i], sql[i:] | COMMENT |
| LOW | internal/pgmapbroker/pgmapbroker.go | 261 | // TLS is an optional TLS configuration applied to all pools (primary, | COMMENT |
| LOW | internal/pgmapbroker/pgmapbroker.go | 281 | | COMMENT |
| LOW | internal/pgmapbroker/pgmapbroker.go | 301 | // and their cf_binary_map_* counterparts for the binary data variant. | COMMENT |
| LOW | internal/pgmapbroker/pgmapbroker.go | 321 | // NotifyDSN is an optional separate connection string used exclusively for | COMMENT |
| LOW | internal/pgmapbroker/pgmapbroker.go | 341 | // When set, outbox workers use advisory locks (one worker per shard across | COMMENT |
| LOW | internal/pgmapbroker/pgmapbroker.go | 681 | // This method is safe to call concurrently from multiple nodes — all DDL | COMMENT |
| LOW | internal/pgmapbroker/pgmapbroker.go | 821 | // variants (jsonb + binary) are created by separate Exec calls, so a | COMMENT |
| LOW | internal/pgmapbroker/pgmapbroker.go | 861 | // (a) Migrations before DDL because the DDL template (`schema.sql`) | COMMENT |
| LOW | internal/pgmapbroker/pgmapbroker.go | 2261 | } | COMMENT |
| LOW | internal/config/config.go | 21 | ) | COMMENT |
| LOW | internal/config/config.go | 41 | // presence information storage and retrieval. By default, memory PresenceManager is used. Memory | COMMENT |
| LOW | internal/config/config.go | 81 | // WebTransport is a configuration for WebTransport transport. EXPERIMENTAL. | COMMENT |
| LOW | internal/config/envconfig/doc.go | 1 | // Copyright (c) 2013 Kelsey Hightower. All rights reserved. | COMMENT |
| LOW | internal/config/envconfig/envconfig_test.go | 801 | } | COMMENT |
| LOW | internal/redisqueue/consumer.go | 21 | // and process Messages. | COMMENT |
| LOW | internal/redisqueue/consumer.go | 41 | VisibilityTimeout time.Duration | COMMENT |
| LOW | internal/proxyproto/proxy_grpc.pb.go | 41 | // CentrifugoProxy is the service an application backend implements to receive | COMMENT |
| LOW | internal/proxyproto/proxy_grpc.pb.go | 61 | Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error) | COMMENT |
| LOW | internal/proxyproto/proxy_grpc.pb.go | 241 | return out, nil | COMMENT |
| LOW | internal/proxyproto/proxy_grpc.pb.go | 261 | // Refresh is called when a connection is about to expire, to decide whether | COMMENT |
| LOW | internal/proxyproto/proxy_grpc.pb.go | 281 | // always contains SubscribeRequest, then StreamSubscribeRequest will contain data published | COMMENT |
| LOW | internal/proxyproto/proxy.pb.go | 381 | // b64info is info in base64, for binary info. | COMMENT |
| LOW | internal/proxyproto/proxy.pb.go | 501 | ExpireAt int64 `protobuf:"varint,2,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"` | COMMENT |
| LOW | internal/proxyproto/proxy.pb.go | 1041 | // protocol is the client protocol: "json" or "protobuf". | COMMENT |
| LOW | internal/proxyproto/proxy.pb.go | 1661 | // b64data is data in base64, for binary data. | COMMENT |
| 72 more matches not shown… |
Adjusted legacy signal; badge bands: 25 / 50 / 75 (different from dashboard bands).