@@ -27,42 +27,42 @@ by looking at our [docs](docs/index.md).
2727package main
2828
2929import (
30- " github.com/Trendyol/go-dcp"
31- " github.com/Trendyol/go-dcp/logger"
32- " github.com/Trendyol/go-dcp/models"
30+ " github.com/Trendyol/go-dcp"
31+ " github.com/Trendyol/go-dcp/logger"
32+ " github.com/Trendyol/go-dcp/models"
3333)
3434
3535func listener (ctx *models .ListenerContext ) {
36- switch event := ctx.Event .(type ) {
37- case models.DcpMutation :
38- logger.Log .Info (
39- " mutated(vb=%v ,eventTime=%v ) | id: %v , value: %v | isCreated: %v " ,
40- event.VbID , event.EventTime , string (event.Key ), string (event.Value ), event.IsCreated (),
41- )
42- case models.DcpDeletion :
43- logger.Log .Info (
44- " deleted(vb=%v ,eventTime=%v ) | id: %v " ,
45- event.VbID , event.EventTime , string (event.Key ),
46- )
47- case models.DcpExpiration :
48- logger.Log .Info (
49- " expired(vb=%v ,eventTime=%v ) | id: %v " ,
50- event.VbID , event.EventTime , string (event.Key ),
51- )
52- }
53-
54- ctx.Ack ()
36+ switch event := ctx.Event .(type ) {
37+ case models.DcpMutation :
38+ logger.Log .Info (
39+ " mutated(vb=%v ,eventTime=%v ) | id: %v , value: %v | isCreated: %v " ,
40+ event.VbID , event.EventTime , string (event.Key ), string (event.Value ), event.IsCreated (),
41+ )
42+ case models.DcpDeletion :
43+ logger.Log .Info (
44+ " deleted(vb=%v ,eventTime=%v ) | id: %v " ,
45+ event.VbID , event.EventTime , string (event.Key ),
46+ )
47+ case models.DcpExpiration :
48+ logger.Log .Info (
49+ " expired(vb=%v ,eventTime=%v ) | id: %v " ,
50+ event.VbID , event.EventTime , string (event.Key ),
51+ )
52+ }
53+
54+ ctx.Ack ()
5555}
5656
5757func main () {
58- connector , err := dcp.NewDcp (" config.yml" , listener)
59- if err != nil {
60- panic (err)
61- }
58+ connector , err := dcp.NewDcp (" config.yml" , listener)
59+ if err != nil {
60+ panic (err)
61+ }
6262
63- defer connector.Close ()
63+ defer connector.Close ()
6464
65- connector.Start ()
65+ connector.Start ()
6666}
6767```
6868
@@ -205,4 +205,11 @@ In case you haven't configured a metric.path, the metrics will be exposed at the
205205
206206## Distributed Tracing
207207
208- [ otel-go-dcp] ( https://github.com/Trendyol/otel-go-dcp )
208+ [ otel-go-dcp] ( https://github.com/Trendyol/otel-go-dcp )
209+
210+ ## Before Contribution
211+
212+ ```
213+ # Make sure to use .githooks as hooks path of your git
214+ git config core.hooksPath .githooks
215+ ```
0 commit comments