Commit62f2b39

committed

flake

1 parentfa799a6 commit62f2b39Copy full SHA for 62f2b39

File tree

-5

lines changed

-5

lines changed

Lines changed: 4 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -609,8 +609,8 @@ func (p *PGPubsub) Collect(metrics chan<- prometheus.Metric) {`
`609`	`609`	`}`
`610`	`610`
`611`	`611`	`// New creates a new Pubsub implementation using a PostgreSQL connection.`
`612`		`-funcNew(startCtx context.Context,logger slog.Logger,databasesql.DB,connectURLstring) (PGPubsub,error) {`
`613`		`-p:=newWithoutListener(logger,database)`
	`612`	`+funcNew(startCtx context.Context,logger slog.Logger,dbsql.DB,connectURLstring) (PGPubsub,error) {`
	`613`	`+p:=newWithoutListener(logger,db)`
`614`	`614`	`iferr:=p.startListener(startCtx,connectURL);err!=nil {`
`615`	`615`	`returnnil,err`
`616`	`616`	`}`
`@@ -620,11 +620,11 @@ func New(startCtx context.Context, logger slog.Logger, database *sql.DB, connect`
`620`	`620`	`}`
`621`	`621`
`622`	`622`	`// newWithoutListener creates a new PGPubsub without creating the pqListener.`
`623`		`-funcnewWithoutListener(logger slog.Logger,databasesql.DB)PGPubsub {`
	`623`	`+funcnewWithoutListener(logger slog.Logger,dbsql.DB)PGPubsub {`
`624`	`624`	`return&PGPubsub{`
`625`	`625`	`logger:logger,`
`626`	`626`	`listenDone:make(chanstruct{}),`
`627`		`-db:database,`
	`627`	`+db:db,`
`628`	`628`	`queues:make(map[string]map[uuid.UUID]*msgQueue),`
`629`	`629`	`latencyMeasurer:NewLatencyMeasurer(logger.Named("latency-measurer")),`
`630`	`630`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -117,7 +117,7 @@`
`117`	`117`	`name="coder-${osArch}";`
`118`	`118`	# Updated with ./scripts/update-flake.sh`.
`119`	`119`	`# This should be updated whenever go.mod changes!`
`120`		`-vendorHash="sha256-AZ0qzh7H+UwnZNyg2iaNMSUWlGgomI/mo70T+FdF7ws=";`
	`120`	`+vendorHash="sha256-AWWSj+tNYEzvf4lTgdUJMi2bY6rXxZHGh50P4WY2BUo=";`
`121`	`121`	`proxyVendor=true;`
`122`	`122`	`src=./.;`
`123`	`123`	`nativeBuildInputs=withpkgs;[getoptopensslzstd];`

Comments

(0)