commit b465e469e054367990d9abcb87c0965d1ac5829c · hailey.at/peruse

cmd/peruse/main.go

···

       89
       89
        
       				EnvVars: []string{"PERUSE_RELAY_HOST"},

     

       90
       90
        
       				Value:   "wss://bsky.network",

     

       91
       91
        
       			},

     

       92
       92
       +
       			&cli.StringFlag{

     

       93
       93
       +
       				Name:     "cursor-file",

     

       94
       94
       +
       				EnvVars:  []string{"PERUSE_CURSOR_FILE"},

     

       95
       95
       +
       				Required: true,

     

       96
       96
       +
       			},

     

       92
       97
        
       		},

     

       93
       98
        
       		Action: run,

     

       94
       99
        
       	}

     
···

       120
       125
        
       		NervanaEndpoint:      cmd.String("nervana-endpoint"),

     

       121
       126
        
       		NervanaApiKey:        cmd.String("nervana-api-key"),

     

       122
       127
        
       		RelayHost:            cmd.String("relay-host"),

     

       128
       128
       +
       		CursorFile:           cmd.String("cursor-file"),

     

       123
       129
        
       	})

     

       124
       130
        
       	if err != nil {

     

       125
       131
        
       		logger.Error("error creating server", "error", err)

+1 -1

peruse/handle_seattle_feed.go peruse/handle_city_area_feed.go

···

       53
       53
        
       	}

     

       54
       54
        
       

     

       55
       55
        
       	inserter, err := clickhouse_inserter.New(ctx, &clickhouse_inserter.Args{

     

       56
       56
       -
       		PrometheusCounterPrefix: "photocopy_follows",

     

       56
       56
       +
       		PrometheusCounterPrefix: "peruse_city_area_" + feedName,

     

       57
       57
        
       		BatchSize:               1,

     

       58
       58
        
       		Logger:                  s.logger,

     

       59
       59
        
       		Conn:                    s.conn,