From f37b3f2293b10d517c7d6d95a5b0be1a70145468 Mon Sep 17 00:00:00 2001 From: xiandong Date: Fri, 5 May 2023 00:15:12 +0800 Subject: [PATCH] rm event_bus_rocketmq --- event_bus.go | 12 - event_bus_dtm.go | 81 ------ event_bus_rocketmq.go | 187 -------------- event_bus_rocketmq_demo_listener.go | 69 ------ event_bus_rocketmq_test.go | 55 ----- go.mod | 17 -- go.sum | 65 ----- proto/message.pb.go | 370 ---------------------------- 8 files changed, 856 deletions(-) delete mode 100644 event_bus_rocketmq.go delete mode 100644 event_bus_rocketmq_demo_listener.go delete mode 100644 event_bus_rocketmq_test.go delete mode 100644 proto/message.pb.go diff --git a/event_bus.go b/event_bus.go index e1e4450..0d44773 100644 --- a/event_bus.go +++ b/event_bus.go @@ -4,7 +4,6 @@ import ( "context" "encoding/json" "fmt" - "github.com/wuyazi/gddd/proto" "strings" ) @@ -54,14 +53,3 @@ func newDomainEventMessage(event DomainEvent) (msg DomainEventMessage, err error } return } - -func newDomainEventMessageProto(msg0 DomainEventMessage) (msg proto.DomainEventMessageProto) { - msg = proto.DomainEventMessageProto{ - AggregateId: msg0.AggregateId, - AggregateName: msg0.AggregateName, - EventName: msg0.EventName, - EventId: msg0.EventId, - EventBody: msg0.EventBody, - } - return -} diff --git a/event_bus_dtm.go b/event_bus_dtm.go index b216707..613c980 100644 --- a/event_bus_dtm.go +++ b/event_bus_dtm.go @@ -5,9 +5,6 @@ import ( "database/sql" "encoding/json" "fmt" - "github.com/apache/rocketmq-client-go/v2" - "github.com/apache/rocketmq-client-go/v2/consumer" - "github.com/apache/rocketmq-client-go/v2/primitive" "github.com/dtm-labs/client/dtmcli" "github.com/dtm-labs/client/dtmgrpc" "github.com/lithammer/shortuuid/v3" @@ -130,81 +127,3 @@ type DtmEventConsumerConfig struct { GroupName string NameServers []string } - -type DtmEventConsumer struct { - DomainName string - GroupName string - Consumer rocketmq.PushConsumer -} - -func NewDtmEventConsumer(ctx context.Context, config DtmEventConsumerConfig) (eventConsumer *DtmEventConsumer, err error) { - eventConsumer.DomainName = config.DomainName - eventConsumer.GroupName = config.GroupName - c, err := rocketmq.NewPushConsumer( - consumer.WithGroupName(eventConsumer.GroupName), - consumer.WithNsResolver(primitive.NewPassthroughResolver(config.NameServers)), - ) - eventConsumer.Consumer = c - return -} - -func (c *DtmEventConsumer) Start() { - err := c.Consumer.Start() - if err != nil { - fmt.Printf("DtmEventConsumer start error: %v\n", err) - panic(err) - } -} - -func (c *DtmEventConsumer) Stop() { - err := c.Consumer.Shutdown() - if err != nil { - fmt.Printf("DtmEventConsumer stop error: %v\n", err) - panic(err) - } -} - -func (c *DtmEventConsumer) Subscribe(topicName string, change aggregateChange, eventHandle EventHandle) { - topicName = strings.TrimSpace(topicName) - if topicName == "" { - err := fmt.Errorf("DtmEventConsumer subscribe event failed, topicName is empty") - panic(err) - } - if change == nil { - err := fmt.Errorf("DtmEventConsumer subscribe event failed, change is nil") - panic(err) - } - if eventHandle == nil { - err := fmt.Errorf("DtmEventConsumer subscribe event failed, eventHandle is nil") - panic(err) - } - err := c.Consumer.Subscribe(topicName, consumer.MessageSelector{}, - func(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) { - for _, msg := range msgs { - if topicName == msg.Message.Topic { - domainEventMessage := new(DomainEventMessage) - err := json.Unmarshal(msg.Message.Body, domainEventMessage) - if err != nil { - return consumer.ConsumeRetryLater, err - } - if getAggregateChangeName(change) == domainEventMessage.EventName { - var event SampleDomainEvent - // TODO: change is read only? - newChange := change - event, err = newSampleDomainEvent(*domainEventMessage, newChange) - if err != nil { - return 0, err - } - err, _ = eventHandle(context.TODO(), &event) - if err != nil { - return consumer.ConsumeRetryLater, err - } - } - } - } - return consumer.ConsumeSuccess, nil - }) - if err != nil { - panic(nil) - } -} diff --git a/event_bus_rocketmq.go b/event_bus_rocketmq.go deleted file mode 100644 index 43bd811..0000000 --- a/event_bus_rocketmq.go +++ /dev/null @@ -1,187 +0,0 @@ -package gddd - -import ( - "context" - "encoding/json" - "fmt" - "github.com/apache/rocketmq-client-go/v2" - "github.com/apache/rocketmq-client-go/v2/consumer" - "github.com/apache/rocketmq-client-go/v2/primitive" - "github.com/apache/rocketmq-client-go/v2/producer" - "strings" -) - -type RocketMqEventProducerConfig struct { - DomainName string - SubDomainName string - NameServers []string - EventStore *EventStore -} - -type RocketmqEventProducer struct { - Name string - Brokers []string - Producer rocketmq.TransactionProducer -} - -func NewRocketMqEventProducer(ctx context.Context, config RocketMqEventProducerConfig) (eventProducer RocketmqEventProducer, err error) { - domainName := strings.TrimSpace(config.DomainName) - if domainName == "" { - err = fmt.Errorf("new rocketmq event producer failed, DomainName is empty") - return - } - subDomainName := strings.TrimSpace(config.SubDomainName) - if subDomainName == "" { - err = fmt.Errorf("new rocketmq event producer failed, SubDomainName is empty") - return - } - if config.NameServers == nil || len(config.NameServers) == 0 { - err = fmt.Errorf("new rocketmq event producer failed, NameServers is nil or empty") - return - } - p, err := rocketmq.NewTransactionProducer( - NewDemoListener(config.EventStore), - producer.WithNsResolver(primitive.NewPassthroughResolver(config.NameServers)), - producer.WithRetry(1), - ) - if err != nil { - fmt.Printf("new producer error: %s\n", err.Error()) - panic(err) - } - eventProducer = RocketmqEventProducer{ - Name: fmt.Sprintf("%s_%s", config.DomainName, config.SubDomainName), - Brokers: config.NameServers, - Producer: p, - } - eventProducer.Producer = p - return -} - -func (p *RocketmqEventProducer) Start() { - err := p.Producer.Start() - if err != nil { - fmt.Printf("start producer error: %s\n", err.Error()) - panic(err) - } -} - -func (p *RocketmqEventProducer) Stop() { - err := p.Producer.Shutdown() - if err != nil { - fmt.Printf("stop producer error: %s\n", err.Error()) - panic(err) - } - return -} - -func (p *RocketmqEventProducer) Send(ctx context.Context, eventMessages ...DomainEventMessage) (err error) { - if p.Producer == nil { - err = fmt.Errorf("rocketmq event producer send event failed, Producer is nil") - return - } - if eventMessages == nil || len(eventMessages) == 0 { - err = fmt.Errorf("rocketmq event producer send event failed, eventMessages is nil or empty") - return - } - msgs := make([]*primitive.Message, 0, 1) - for _, eventMessage := range eventMessages { - var messageBody []byte - messageBody, err = json.Marshal(eventMessage) - if err != nil { - return - } - msg := primitive.NewMessage(eventMessage.TopicName(p.Name), messageBody) - msgs = append(msgs, msg) - } - res, err := p.Producer.SendMessageInTransaction(ctx, msgs...) - if err != nil { - fmt.Printf("send message error: %s\n", err) - } else { - fmt.Printf("send message success: result=%s\n", res.String()) - } - return -} - -type RocketMqEventConsumerConfig struct { - DomainName string - GroupName string - NameServers []string -} - -type RocketMqEventConsumer struct { - DomainName string - GroupName string - Consumer rocketmq.PushConsumer -} - -func NewRocketMqEventConsumer(ctx context.Context, config RocketMqEventConsumerConfig) (eventConsumer *RocketMqEventConsumer, err error) { - eventConsumer.DomainName = config.DomainName - eventConsumer.GroupName = config.GroupName - c, err := rocketmq.NewPushConsumer( - consumer.WithGroupName(eventConsumer.GroupName), - consumer.WithNsResolver(primitive.NewPassthroughResolver(config.NameServers)), - ) - eventConsumer.Consumer = c - return -} - -func (c *RocketMqEventConsumer) Start() { - err := c.Consumer.Start() - if err != nil { - fmt.Printf("RocketMqEventConsumer start error: %v\n", err) - panic(err) - } -} - -func (c *RocketMqEventConsumer) Stop() { - err := c.Consumer.Shutdown() - if err != nil { - fmt.Printf("RocketMqEventConsumer stop error: %v\n", err) - panic(err) - } -} - -func (c *RocketMqEventConsumer) Subscribe(topicName string, change aggregateChange, eventHandle EventHandle) { - topicName = strings.TrimSpace(topicName) - if topicName == "" { - err := fmt.Errorf("RocketMqEventConsumer subscribe event failed, topicName is empty") - panic(err) - } - if change == nil { - err := fmt.Errorf("RocketMqEventConsumer subscribe event failed, change is nil") - panic(err) - } - if eventHandle == nil { - err := fmt.Errorf("RocketMqEventConsumer subscribe event failed, eventHandle is nil") - panic(err) - } - err := c.Consumer.Subscribe(topicName, consumer.MessageSelector{}, - func(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) { - for _, msg := range msgs { - if topicName == msg.Message.Topic { - domainEventMessage := new(DomainEventMessage) - err := json.Unmarshal(msg.Message.Body, domainEventMessage) - if err != nil { - return consumer.ConsumeRetryLater, err - } - if getAggregateChangeName(change) == domainEventMessage.EventName { - var event SampleDomainEvent - // TODO: change is read only? - newChange := change - event, err = newSampleDomainEvent(*domainEventMessage, newChange) - if err != nil { - return 0, err - } - err, _ = eventHandle(context.TODO(), &event) - if err != nil { - return consumer.ConsumeRetryLater, err - } - } - } - } - return consumer.ConsumeSuccess, nil - }) - if err != nil { - panic(nil) - } -} diff --git a/event_bus_rocketmq_demo_listener.go b/event_bus_rocketmq_demo_listener.go deleted file mode 100644 index f78741f..0000000 --- a/event_bus_rocketmq_demo_listener.go +++ /dev/null @@ -1,69 +0,0 @@ -package gddd - -import ( - "context" - "github.com/apache/rocketmq-client-go/v2/primitive" - "sync" -) - -type DemoListener struct { - es *EventStore - localTrans *sync.Map - transactionIndex int32 -} - -func NewDemoListener(eventStore *EventStore) *DemoListener { - return &DemoListener{ - es: eventStore, - localTrans: new(sync.Map), - } -} - -// ExecuteLocalTransaction 在 SendMessageInTransaction 方法调用 -// 如果返回 primitive.UnknowState 那么 brocker 就会调用 CheckLocalTransaction 方法检查消息状态 -// 如果返回 primitive.CommitMessageState 和 primitive.RollbackMessageState 则不会调用 CheckLocalTransaction -func (dl *DemoListener) ExecuteLocalTransaction(ctx context.Context, msgs ...*primitive.Message) primitive.LocalTransactionState { - storedEvents := make([]StoredEvent, 0, 1) - for _, msg := range msgs { - eventMessage := new(DomainEventMessage) - err := eventMessage.Decode(msg.Body) - if err != nil { - return primitive.RollbackMessageState - } - var storedEvent StoredEvent - storedEvent, err = newJsonStoredEvent(eventMessage.AggregateId, eventMessage.AggregateName, eventMessage.EventId, eventMessage.EventName, eventMessage.EventBody) - if err != nil { - return primitive.RollbackMessageState - } - storedEvents = append(storedEvents, storedEvent) - } - storeEventsErr := (*dl.es).StoreEvents(ctx, storedEvents) - if storeEventsErr != nil { - //err := fmt.Errorf("aggregates repository save failed, store domain events failed, %v", storeEventsErr) - return primitive.RollbackMessageState - } - return primitive.CommitMessageState -} - -func (dl *DemoListener) CheckLocalTransaction(msges ...*primitive.MessageExt) primitive.LocalTransactionState { - storedEvents := make([]StoredEvent, 0, 1) - for _, msge := range msges { - eventMessage := new(DomainEventMessage) - err := eventMessage.Decode(msge.Message.Body) - if err != nil { - return primitive.RollbackMessageState - } - var storedEvent StoredEvent - storedEvent, err = newJsonStoredEvent(eventMessage.AggregateId, eventMessage.AggregateName, eventMessage.EventId, eventMessage.EventName, eventMessage.EventBody) - if err != nil { - return primitive.RollbackMessageState - } - storedEvents = append(storedEvents, storedEvent) - } - err := (*dl.es).CheckEvents(context.TODO(), storedEvents) - if err != nil { - // todo - return primitive.RollbackMessageState - } - return primitive.CommitMessageState -} diff --git a/event_bus_rocketmq_test.go b/event_bus_rocketmq_test.go deleted file mode 100644 index 39052db..0000000 --- a/event_bus_rocketmq_test.go +++ /dev/null @@ -1,55 +0,0 @@ -package gddd - -import ( - "context" - "fmt" - "testing" - "time" -) - -func TestNewRocketMqEventBus(t *testing.T) { - config := RocketMqEventProducerConfig{"apple", "community", []string{"127.0.0.1:9876"}, nil} - gotBus, err := NewRocketMqEventProducer(context.TODO(), config) - if err != nil { - t.Errorf("NewRocketMqEventProducer() error = %v", err) - return - } - fmt.Println(gotBus) -} - -func Test_rocketmqEventBus_Start(t *testing.T) { - config := RocketMqEventProducerConfig{"apple", "community", []string{"127.0.0.1:9876"}, nil} - gotBus, err := NewRocketMqEventProducer(context.TODO(), config) - if err != nil { - t.Errorf("NewRocketMqEventProducer() error = %v", err) - return - } - gotBus.Start() -} - -func Test_rocketmqEventBus_Send(t *testing.T) { - config := RocketMqEventProducerConfig{"apple", "community", []string{"127.0.0.1:9876"}, nil} - gotBus, err := NewRocketMqEventProducer(context.TODO(), config) - if err != nil { - t.Errorf("NewRocketMqEventProducer() error = %v", err) - return - } - event := SampleDomainEvent{aggregateId: 1, aggregateName: "book", eventId: 1, eventName: "BookCreated", eventBody: BookCreated{Book: "aa", Price: 2, CreateTime: time.Now().UTC()}} - msg, _ := newDomainEventMessage(&event) - err = gotBus.Send(context.TODO(), msg) - if err != nil { - t.Errorf("send error = %v", err) - return - } -} - -func Test_rocketmqEventBus_Recv(t *testing.T) { - config := RocketMqEventProducerConfig{"apple", "community", []string{"127.0.0.1:9876"}, nil} - gotBus, err := NewRocketMqEventProducer(context.TODO(), config) - if err != nil { - t.Errorf("NewRocketMqEventProducer() error = %v", err) - return - } - gotBus.Start() - select {} -} diff --git a/go.mod b/go.mod index 289f054..12ec7b8 100644 --- a/go.mod +++ b/go.mod @@ -3,7 +3,6 @@ module github.com/wuyazi/gddd go 1.18 require ( - github.com/apache/rocketmq-client-go/v2 v2.1.1 github.com/bwmarrin/snowflake v0.3.0 github.com/dtm-labs/client v1.18.7 github.com/jinzhu/copier v0.3.5 @@ -18,30 +17,15 @@ require ( github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect github.com/dtm-labs/dtmdriver v0.0.6 // indirect github.com/dtm-labs/logger v0.0.1 // indirect - github.com/emirpasic/gods v1.12.0 // indirect github.com/go-redis/redis/v8 v8.11.5 // indirect github.com/go-resty/resty/v2 v2.7.0 // indirect github.com/go-stack/stack v1.8.0 // indirect - github.com/golang/mock v1.6.0 // indirect github.com/golang/protobuf v1.5.2 // indirect github.com/golang/snappy v0.0.1 // indirect github.com/google/uuid v1.2.0 // indirect - github.com/gopherjs/gopherjs v0.0.0-20200217142428-fce0ec30dd00 // indirect - github.com/json-iterator/go v1.1.12 // indirect github.com/klauspost/compress v1.13.6 // indirect - github.com/kr/pretty v0.3.0 // indirect - github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect - github.com/modern-go/reflect2 v1.0.2 // indirect github.com/natefinch/lumberjack v2.0.0+incompatible // indirect - github.com/patrickmn/go-cache v2.1.0+incompatible // indirect github.com/pkg/errors v0.9.1 // indirect - github.com/rogpeppe/go-internal v1.8.1 // indirect - github.com/satori/go.uuid v1.2.1-0.20181028125025-b2ce2384e17b // indirect - github.com/sirupsen/logrus v1.8.1 // indirect - github.com/smartystreets/assertions v1.1.0 // indirect - github.com/stathat/consistent v1.0.0 // indirect - github.com/tidwall/gjson v1.13.0 // indirect - github.com/tidwall/match v1.1.1 // indirect github.com/tidwall/pretty v1.2.0 // indirect github.com/xdg-go/pbkdf2 v1.0.0 // indirect github.com/xdg-go/scram v1.0.2 // indirect @@ -57,7 +41,6 @@ require ( golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f // indirect golang.org/x/text v0.3.6 // indirect google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 // indirect - gopkg.in/natefinch/lumberjack.v2 v2.0.0 // indirect ) replace github.com/dtm-labs/dtm => ../../../github.com/wuyazi/dtm diff --git a/go.sum b/go.sum index 85101a4..aca2340 100644 --- a/go.sum +++ b/go.sum @@ -1,12 +1,9 @@ cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw= cloud.google.com/go v0.34.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw= github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU= -github.com/BurntSushi/toml v1.1.0/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ= github.com/BurntSushi/toml v1.2.0 h1:Rt8g24XnyGTyglgET/PRUNlrUeu9F5L+7FilkXfZgs0= github.com/BurntSushi/toml v1.2.0/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ= github.com/antihax/optional v1.0.0/go.mod h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kdvxnR2qWY= -github.com/apache/rocketmq-client-go/v2 v2.1.1 h1:WY/LkOYSQaVyV+HOqdiIgF4LE3beZ/jwdSLKZlzpabw= -github.com/apache/rocketmq-client-go/v2 v2.1.1/go.mod h1:GZzExtXY9zpI6FfiVJYAhw2IXQtgnHUuWpULo7nr5lw= github.com/benbjohnson/clock v1.1.0 h1:Q92kusRqC1XV2MjkWETPvjJVqKetz1OzxZB7mHJLju8= github.com/benbjohnson/clock v1.1.0/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA= github.com/bwmarrin/snowflake v0.3.0 h1:xm67bEhkKh6ij1790JB83OujPR5CzNe8QuQqAgISZN0= @@ -25,7 +22,6 @@ github.com/cncf/udpa/go v0.0.0-20210930031921-04548b0d99d4/go.mod h1:6pvJx4me5XP github.com/cncf/xds/go v0.0.0-20210922020428-25de7278fc84/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= github.com/cncf/xds/go v0.0.0-20211001041855-01bcc9b48dfe/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= github.com/cncf/xds/go v0.0.0-20211011173535-cb28da3451f1/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= -github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= @@ -37,8 +33,6 @@ github.com/dtm-labs/dtmdriver v0.0.6 h1:Iz6xnO+hE2TKDHI2TX4BKCzMtgXYgeQFBEGvvaNh github.com/dtm-labs/dtmdriver v0.0.6/go.mod h1:V5E1uFsExb6Do32ezpB8bMX6be+izLhkcboniLP5shU= github.com/dtm-labs/logger v0.0.1 h1:187UPkYviyOXelmkbew+Q94mg/BFjxJEsHfyHawu5YQ= github.com/dtm-labs/logger v0.0.1/go.mod h1:0woMQZ6ljx9wZIl7hW8cuV2PRQmwEKxhqYtab7zVNWg= -github.com/emirpasic/gods v1.12.0 h1:QAUIPSaCu4G+POclxeqb3F+WPpdKqFGlw36+yOzGlrg= -github.com/emirpasic/gods v1.12.0/go.mod h1:YfzfFFoVP/catgzJb4IKIqXjX78Ha8FMSDh3ymbK86o= github.com/envoyproxy/go-control-plane v0.9.0/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4= github.com/envoyproxy/go-control-plane v0.9.1-0.20191026205805-5f8ba28d4473/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4= github.com/envoyproxy/go-control-plane v0.9.4/go.mod h1:6rpuAdCZL397s3pYoYcLgu1mIlRU8Am5FuJP05cCM98= @@ -58,9 +52,6 @@ github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/me github.com/go-task/slim-sprig v0.0.0-20210107165309-348f09dbbbc0/go.mod h1:fyg7847qk6SyHyPtNmDHnmrv/HOrqktSC+C9fM+CJOE= github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q= github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A= -github.com/golang/mock v1.3.1/go.mod h1:sBzyDLLjw3U8JLTeZvSv8jJB+tU5PVekmnlKIyFUx0Y= -github.com/golang/mock v1.6.0 h1:ErTB+efbowRARo13NNdxyJji2egdxLGQhRaY+DUumQc= -github.com/golang/mock v1.6.0/go.mod h1:p6yTPP+5HYm5mzsMV8JkE6ZKdX+/wYM6Hr+LicevLPs= github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= github.com/golang/protobuf v1.3.2/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= github.com/golang/protobuf v1.3.3/go.mod h1:vzj43D7+SQXF/4pzW/hwtAqwc6iTitCiVSaWz5lYuqw= @@ -86,41 +77,22 @@ github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/ github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.6 h1:BKbKCqvP6I+rmFHt06ZmyQtvB8xAkWdhFyr0ZUNZcxQ= github.com/google/go-cmp v0.5.6/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= -github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg= github.com/google/pprof v0.0.0-20210407192527-94a9f03dee38/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE= github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= github.com/google/uuid v1.2.0 h1:qJYtXnJRWmpe7m/3XlyhrsLrEURqHRM2kxzoxXqyUDs= github.com/google/uuid v1.2.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= -github.com/gopherjs/gopherjs v0.0.0-20181017120253-0766667cb4d1/go.mod h1:wJfORRmW1u3UXTncJ5qlYoELFm8eSnnEO6hX4iZ3EWY= -github.com/gopherjs/gopherjs v0.0.0-20200217142428-fce0ec30dd00 h1:l5lAOZEym3oK3SQ2HBHWsJUfbNBiTXJDeW2QDxw9AQ0= -github.com/gopherjs/gopherjs v0.0.0-20200217142428-fce0ec30dd00/go.mod h1:wJfORRmW1u3UXTncJ5qlYoELFm8eSnnEO6hX4iZ3EWY= github.com/grpc-ecosystem/grpc-gateway v1.16.0/go.mod h1:BDjrQk3hbvj6Nolgz8mAMFbcEtjT1g+wF4CSlocrBnw= github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU= github.com/ianlancetaylor/demangle v0.0.0-20200824232613-28f6c0f3b639/go.mod h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc= github.com/jinzhu/copier v0.3.5 h1:GlvfUwHk62RokgqVNvYsku0TATCF7bAHVwEXoBh3iJg= github.com/jinzhu/copier v0.3.5/go.mod h1:DfbEm0FYsaqBcKcFuvmOZb218JkPGtvSHsKg8S8hyyg= -github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM= -github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo= -github.com/jtolds/gls v4.20.0+incompatible h1:xdiiI2gbIgH/gLH7ADydsJ1uDOEzR8yvV7C0MuV77Wo= -github.com/jtolds/gls v4.20.0+incompatible/go.mod h1:QJZ7F/aHp+rZTRtaJ1ow/lLfFfVYBRgL+9YlvaHOwJU= github.com/klauspost/compress v1.13.6 h1:P76CopJELS0TiO2mebmnzgWaajssP/EszplttgQxcgc= github.com/klauspost/compress v1.13.6/go.mod h1:/3/Vjq9QcHkK5uEr5lBEmyoZ1iFhe47etQ6QUkpK6sk= -github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ= github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo= -github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI= -github.com/kr/pretty v0.3.0 h1:WgNl7dwNpEZ6jJ9k1snq4pZsg7DOEN8hP9Xw0Tsjwk0= -github.com/kr/pretty v0.3.0/go.mod h1:640gp4NfQd8pI5XOwp5fnNeVWj67G7CFk/SaSQn7NBk= github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ= github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI= -github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= -github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= github.com/lithammer/shortuuid/v3 v3.0.7 h1:trX0KTHy4Pbwo/6ia8fscyHoGA+mf1jWbPJVuvyJQQ8= github.com/lithammer/shortuuid/v3 v3.0.7/go.mod h1:vMk8ke37EmiewwolSO1NLW8vP4ZaKlRuDIi8tWWmAts= -github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= -github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg= -github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= -github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M= -github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk= github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe/go.mod h1:wL8QJuTMNUDYhXwkmfOly8iTdp5TEcJFWZD2D7SIkUc= github.com/natefinch/lumberjack v2.0.0+incompatible h1:4QJd3OLAMgj7ph+yZTuX13Ld4UpgHp07nNdFX7mqFfM= github.com/natefinch/lumberjack v2.0.0+incompatible/go.mod h1:Wi9p2TTF5DG5oU+6YfsmYQpsTIOm0B1VNzQg9Mw6nPk= @@ -138,9 +110,6 @@ github.com/onsi/gomega v1.10.1/go.mod h1:iN09h71vgCQne3DLsj+A5owkum+a2tYe+TOCB1y github.com/onsi/gomega v1.17.0/go.mod h1:HnhC7FXeEQY45zxNK3PPoIUhzk/80Xly9PcubAlGdZY= github.com/onsi/gomega v1.18.1 h1:M1GfJqGRrBrrGGsbxzV5dqM2U2ApXefZCQpkukxYRLE= github.com/onsi/gomega v1.18.1/go.mod h1:0q+aL8jAiMXy9hbwj2mr5GziHiwhAIQpFmmtT5hitRs= -github.com/patrickmn/go-cache v2.1.0+incompatible h1:HRMgzkcYKYpi3C8ajMPV8OFXaaRUnok+kx1WdO15EQc= -github.com/patrickmn/go-cache v2.1.0+incompatible/go.mod h1:3Qf8kWWT7OJRJbdiICTKqZju1ZixQ/KpMGzzAfe6+WQ= -github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e/go.mod h1:pJLUxLENpZxwdsKMEsNbx1VGcRFpLqf3715MtcvvzbA= github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4= github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= @@ -148,26 +117,8 @@ github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZb github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA= github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ= -github.com/rogpeppe/go-internal v1.6.1/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTEfhy4qGm1nDQc= -github.com/rogpeppe/go-internal v1.8.1 h1:geMPLpDpQOgVyCg5z5GoRwLHepNdb71NXb67XFkP+Eg= -github.com/rogpeppe/go-internal v1.8.1/go.mod h1:JeRgkft04UBgHMgCIwADu4Pn6Mtm5d4nPKWu0nJ5d+o= -github.com/satori/go.uuid v1.2.0/go.mod h1:dA0hQrYB0VpLJoorglMZABFdXlWrHn1NEOzdhQKdks0= -github.com/satori/go.uuid v1.2.1-0.20181028125025-b2ce2384e17b h1:gQZ0qzfKHQIybLANtM3mBXNUtOfsCFXeTsnBqCsx1KM= -github.com/satori/go.uuid v1.2.1-0.20181028125025-b2ce2384e17b/go.mod h1:dA0hQrYB0VpLJoorglMZABFdXlWrHn1NEOzdhQKdks0= -github.com/sirupsen/logrus v1.4.0/go.mod h1:LxeOpSwHxABJmUn/MG1IvRgCAasNZTLOkJPxbbu5VWo= -github.com/sirupsen/logrus v1.8.1 h1:dJKuHgqk1NNQlqoA6BTlM1Wf9DOH3NBjQyu0h9+AZZE= -github.com/sirupsen/logrus v1.8.1/go.mod h1:yWOB1SBYBC5VeMP7gHvWumXLIWorT60ONWic61uBYv0= -github.com/smartystreets/assertions v0.0.0-20180927180507-b2de0cb4f26d/go.mod h1:OnSkiWE9lh6wB0YB77sQom3nweQdgAjqCqsofrRNTgc= -github.com/smartystreets/assertions v1.1.0 h1:MkTeG1DMwsrdH7QtLXy5W+fUxWq+vmb6cLmyJ7aRtF0= -github.com/smartystreets/assertions v1.1.0/go.mod h1:tcbTF8ujkAEcZ8TElKY+i30BzYlVhC/LOxJk7iOWnoo= -github.com/smartystreets/goconvey v1.6.4 h1:fv0U8FUIMPNf1L9lnHLvLhgicrIVChEkdzIKYqbNC9s= -github.com/smartystreets/goconvey v1.6.4/go.mod h1:syvi0/a8iFYH4r/RixwvyeAJjdLS9QV7WQ/tjFTllLA= -github.com/stathat/consistent v1.0.0 h1:ZFJ1QTRn8npNBKW065raSZ8xfOqhpb8vLOkfp4CcL/U= -github.com/stathat/consistent v1.0.0/go.mod h1:uajTPbgSygZBJ+V+0mY7meZ8i0XAcZs7AQ6V121XSxw= github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= -github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw= -github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs= github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI= github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA= github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= @@ -175,10 +126,6 @@ github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/ github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= github.com/stretchr/testify v1.8.0 h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk= github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU= -github.com/tidwall/gjson v1.13.0 h1:3TFY9yxOQShrvmjdM76K+jc66zJeT6D3/VFFYCGQf7M= -github.com/tidwall/gjson v1.13.0/go.mod h1:/wbyibRr2FHMks5tjHJ5F8dMZh3AcwJEMf5vlfC0lxk= -github.com/tidwall/match v1.1.1 h1:+Ho715JplO36QYgwN9PGYNhgZvoUSc9X2c80KVTi+GA= -github.com/tidwall/match v1.1.1/go.mod h1:eRSPERbgtNPcGhD8UCthc6PmLEQXEWd3PRB5JTxsfmM= github.com/tidwall/pretty v1.0.0/go.mod h1:XNkn88O1ChpSDQmQeStsy+sBenx6DDtFZJxhVysOjyk= github.com/tidwall/pretty v1.2.0 h1:RWIZEg2iJ8/g6fDDYzMpobmaoGh5OLl4AXtGUGPcqCs= github.com/tidwall/pretty v1.2.0/go.mod h1:ITEVvHYasfjBbM0u2Pg8T2nJnzm8xPwvNhhsoaGGjNU= @@ -197,7 +144,6 @@ github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1 go.mongodb.org/mongo-driver v1.9.1 h1:m078y9v7sBItkt1aaoe2YlvWEXcD263e1a4E1fBrJ1c= go.mongodb.org/mongo-driver v1.9.1/go.mod h1:0sQWfOeY63QTntERDJJ/0SuKK0T1uVSgKCuAROlKEPY= go.opentelemetry.io/proto/otlp v0.7.0/go.mod h1:PqfVotwruBrMGOCsRd/89rSnXhoiJIqeYNgFYFoEGnI= -go.uber.org/atomic v1.5.1/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ= go.uber.org/atomic v1.7.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc= go.uber.org/atomic v1.9.0 h1:ECmE8Bn/WFTYwEW/bpKD3M8VtR/zQVbavAoalC1PYyE= go.uber.org/atomic v1.9.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc= @@ -207,7 +153,6 @@ go.uber.org/multierr v1.6.0 h1:y6IPFStTAIT5Ytl7/XYmHvzXQ7S3g/IeZW9hyZ5thw4= go.uber.org/multierr v1.6.0/go.mod h1:cdWPpRnG4AhwMwsgIHip0KRBQjJy5kYEpYjJxpXp9iU= go.uber.org/zap v1.21.0 h1:WefMeulhovoZ2sYXz7st6K0sLj7bBhpiFaud4r4zST8= go.uber.org/zap v1.21.0/go.mod h1:wjWOCqI0f2ZZrJF/UufIOkiC8ii6tm1iqIsLo76RfJw= -golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4= golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI= golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= @@ -246,7 +191,6 @@ golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJ golang.org/x/sync v0.0.0-20210220032951-036812b2e83c h1:5KslGYwFpkhGh+Q16bwMP3cOontH8FOep7tGV86Y7SQ= golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= -golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= @@ -277,14 +221,10 @@ golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGm golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY= golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs= -golang.org/x/tools v0.0.0-20190328211700-ab21143f2384/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs= -golang.org/x/tools v0.0.0-20190425150028-36563e24a262/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q= golang.org/x/tools v0.0.0-20190524140312-2c0ae7006135/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q= golang.org/x/tools v0.0.0-20190531172133-b3315ee88b7d/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc= -golang.org/x/tools v0.0.0-20191029041327-9cc4af7d6b2c/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= golang.org/x/tools v0.0.0-20201224043029-2b0845dc783e/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA= -golang.org/x/tools v0.1.1/go.mod h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk= golang.org/x/tools v0.1.5/go.mod h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk= golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= @@ -322,9 +262,6 @@ google.golang.org/protobuf v1.28.0 h1:w43yiav+6bVFTBQFZX0r7ipe9JQ1QsbMgHwbBziscL google.golang.org/protobuf v1.28.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= -gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk= -gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q= -gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI= gopkg.in/fsnotify.v1 v1.4.7/go.mod h1:Tz8NjZHkW78fSQdbUxIjBTcgA1z1m8ZHf0WmKUhAMys= gopkg.in/natefinch/lumberjack.v2 v2.0.0 h1:1Lc07Kr7qY4U2YPouBjpCLxpiyxIVoxqXgkXLknAOE8= gopkg.in/natefinch/lumberjack.v2 v2.0.0/go.mod h1:l0ndWWf7gzL7RNwBG7wST/UCcT4T24xpD6X8LsfU/+k= @@ -343,5 +280,3 @@ gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= honnef.co/go/tools v0.0.0-20190523083050-ea95bdfd59fc/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= -stathat.com/c/consistent v1.0.0 h1:ezyc51EGcRPJUxfHGSgJjWzJdj3NiMU9pNfLNGiXV0c= -stathat.com/c/consistent v1.0.0/go.mod h1:QkzMWzcbB+yQBL2AttO6sgsQS/JSTapcDISJalmCDS0= diff --git a/proto/message.pb.go b/proto/message.pb.go deleted file mode 100644 index 6783864..0000000 --- a/proto/message.pb.go +++ /dev/null @@ -1,370 +0,0 @@ -// Code generated by protoc-gen-go. DO NOT EDIT. -// versions: -// protoc-gen-go v1.30.0 -// protoc v4.22.3 -// source: message.proto - -package proto - -import ( - protoreflect "google.golang.org/protobuf/reflect/protoreflect" - protoimpl "google.golang.org/protobuf/runtime/protoimpl" - reflect "reflect" - sync "sync" -) - -const ( - // Verify that this generated code is sufficiently up-to-date. - _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) - // Verify that runtime/protoimpl is sufficiently up-to-date. - _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) -) - -type DomainEventMessageProto struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - AggregateId int64 `protobuf:"varint,1,opt,name=aggregateId,proto3" json:"aggregateId,omitempty"` - AggregateName string `protobuf:"bytes,2,opt,name=aggregateName,proto3" json:"aggregateName,omitempty"` - EventName string `protobuf:"bytes,3,opt,name=eventName,proto3" json:"eventName,omitempty"` - EventId int64 `protobuf:"varint,4,opt,name=eventId,proto3" json:"eventId,omitempty"` - EventBody []byte `protobuf:"bytes,5,opt,name=EventBody,proto3" json:"EventBody,omitempty"` -} - -func (x *DomainEventMessageProto) Reset() { - *x = DomainEventMessageProto{} - if protoimpl.UnsafeEnabled { - mi := &file_message_proto_msgTypes[0] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *DomainEventMessageProto) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*DomainEventMessageProto) ProtoMessage() {} - -func (x *DomainEventMessageProto) ProtoReflect() protoreflect.Message { - mi := &file_message_proto_msgTypes[0] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use DomainEventMessageProto.ProtoReflect.Descriptor instead. -func (*DomainEventMessageProto) Descriptor() ([]byte, []int) { - return file_message_proto_rawDescGZIP(), []int{0} -} - -func (x *DomainEventMessageProto) GetAggregateId() int64 { - if x != nil { - return x.AggregateId - } - return 0 -} - -func (x *DomainEventMessageProto) GetAggregateName() string { - if x != nil { - return x.AggregateName - } - return "" -} - -func (x *DomainEventMessageProto) GetEventName() string { - if x != nil { - return x.EventName - } - return "" -} - -func (x *DomainEventMessageProto) GetEventId() int64 { - if x != nil { - return x.EventId - } - return 0 -} - -func (x *DomainEventMessageProto) GetEventBody() []byte { - if x != nil { - return x.EventBody - } - return nil -} - -type AbstractEvent struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - AggregateId int64 `protobuf:"varint,1,opt,name=aggregateId,proto3" json:"aggregateId,omitempty"` - AggregateName string `protobuf:"bytes,2,opt,name=aggregateName,proto3" json:"aggregateName,omitempty"` - EventId int64 `protobuf:"varint,3,opt,name=eventId,proto3" json:"eventId,omitempty"` - EventName string `protobuf:"bytes,4,opt,name=eventName,proto3" json:"eventName,omitempty"` -} - -func (x *AbstractEvent) Reset() { - *x = AbstractEvent{} - if protoimpl.UnsafeEnabled { - mi := &file_message_proto_msgTypes[1] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *AbstractEvent) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*AbstractEvent) ProtoMessage() {} - -func (x *AbstractEvent) ProtoReflect() protoreflect.Message { - mi := &file_message_proto_msgTypes[1] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use AbstractEvent.ProtoReflect.Descriptor instead. -func (*AbstractEvent) Descriptor() ([]byte, []int) { - return file_message_proto_rawDescGZIP(), []int{1} -} - -func (x *AbstractEvent) GetAggregateId() int64 { - if x != nil { - return x.AggregateId - } - return 0 -} - -func (x *AbstractEvent) GetAggregateName() string { - if x != nil { - return x.AggregateName - } - return "" -} - -func (x *AbstractEvent) GetEventId() int64 { - if x != nil { - return x.EventId - } - return 0 -} - -func (x *AbstractEvent) GetEventName() string { - if x != nil { - return x.EventName - } - return "" -} - -type Extra struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - AggregateId int64 `protobuf:"varint,1,opt,name=aggregateId,proto3" json:"aggregateId,omitempty"` - AggregateName string `protobuf:"bytes,2,opt,name=aggregateName,proto3" json:"aggregateName,omitempty"` - EventId int64 `protobuf:"varint,3,opt,name=eventId,proto3" json:"eventId,omitempty"` - EventName string `protobuf:"bytes,4,opt,name=eventName,proto3" json:"eventName,omitempty"` -} - -func (x *Extra) Reset() { - *x = Extra{} - if protoimpl.UnsafeEnabled { - mi := &file_message_proto_msgTypes[2] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *Extra) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*Extra) ProtoMessage() {} - -func (x *Extra) ProtoReflect() protoreflect.Message { - mi := &file_message_proto_msgTypes[2] - if protoimpl.UnsafeEnabled && x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use Extra.ProtoReflect.Descriptor instead. -func (*Extra) Descriptor() ([]byte, []int) { - return file_message_proto_rawDescGZIP(), []int{2} -} - -func (x *Extra) GetAggregateId() int64 { - if x != nil { - return x.AggregateId - } - return 0 -} - -func (x *Extra) GetAggregateName() string { - if x != nil { - return x.AggregateName - } - return "" -} - -func (x *Extra) GetEventId() int64 { - if x != nil { - return x.EventId - } - return 0 -} - -func (x *Extra) GetEventName() string { - if x != nil { - return x.EventName - } - return "" -} - -var File_message_proto protoreflect.FileDescriptor - -var file_message_proto_rawDesc = []byte{ - 0x0a, 0x0d, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, - 0x05, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xb7, 0x01, 0x0a, 0x17, 0x44, 0x6f, 0x6d, 0x61, 0x69, - 0x6e, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x50, 0x72, 0x6f, - 0x74, 0x6f, 0x12, 0x20, 0x0a, 0x0b, 0x61, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x49, - 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x61, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, - 0x74, 0x65, 0x49, 0x64, 0x12, 0x24, 0x0a, 0x0d, 0x61, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, - 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x61, 0x67, 0x67, - 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x65, 0x76, - 0x65, 0x6e, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x65, - 0x76, 0x65, 0x6e, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x76, 0x65, 0x6e, - 0x74, 0x49, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x07, 0x65, 0x76, 0x65, 0x6e, 0x74, - 0x49, 0x64, 0x12, 0x1c, 0x0a, 0x09, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x42, 0x6f, 0x64, 0x79, 0x18, - 0x05, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x09, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x42, 0x6f, 0x64, 0x79, - 0x22, 0x8f, 0x01, 0x0a, 0x0d, 0x41, 0x62, 0x73, 0x74, 0x72, 0x61, 0x63, 0x74, 0x45, 0x76, 0x65, - 0x6e, 0x74, 0x12, 0x20, 0x0a, 0x0b, 0x61, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x49, - 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x61, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, - 0x74, 0x65, 0x49, 0x64, 0x12, 0x24, 0x0a, 0x0d, 0x61, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, - 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x61, 0x67, 0x67, - 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x76, - 0x65, 0x6e, 0x74, 0x49, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x07, 0x65, 0x76, 0x65, - 0x6e, 0x74, 0x49, 0x64, 0x12, 0x1c, 0x0a, 0x09, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x4e, 0x61, 0x6d, - 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x4e, 0x61, - 0x6d, 0x65, 0x22, 0x87, 0x01, 0x0a, 0x05, 0x45, 0x78, 0x74, 0x72, 0x61, 0x12, 0x20, 0x0a, 0x0b, - 0x61, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, - 0x03, 0x52, 0x0b, 0x61, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x49, 0x64, 0x12, 0x24, - 0x0a, 0x0d, 0x61, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x18, - 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x61, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, - 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x18, - 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x07, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x1c, - 0x0a, 0x09, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, - 0x09, 0x52, 0x09, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x42, 0x1e, 0x5a, 0x1c, - 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x77, 0x75, 0x79, 0x61, 0x7a, - 0x69, 0x2f, 0x67, 0x64, 0x64, 0x64, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, - 0x6f, 0x74, 0x6f, 0x33, -} - -var ( - file_message_proto_rawDescOnce sync.Once - file_message_proto_rawDescData = file_message_proto_rawDesc -) - -func file_message_proto_rawDescGZIP() []byte { - file_message_proto_rawDescOnce.Do(func() { - file_message_proto_rawDescData = protoimpl.X.CompressGZIP(file_message_proto_rawDescData) - }) - return file_message_proto_rawDescData -} - -var file_message_proto_msgTypes = make([]protoimpl.MessageInfo, 3) -var file_message_proto_goTypes = []interface{}{ - (*DomainEventMessageProto)(nil), // 0: proto.DomainEventMessageProto - (*AbstractEvent)(nil), // 1: proto.AbstractEvent - (*Extra)(nil), // 2: proto.Extra -} -var file_message_proto_depIdxs = []int32{ - 0, // [0:0] is the sub-list for method output_type - 0, // [0:0] is the sub-list for method input_type - 0, // [0:0] is the sub-list for extension type_name - 0, // [0:0] is the sub-list for extension extendee - 0, // [0:0] is the sub-list for field type_name -} - -func init() { file_message_proto_init() } -func file_message_proto_init() { - if File_message_proto != nil { - return - } - if !protoimpl.UnsafeEnabled { - file_message_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*DomainEventMessageProto); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_message_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*AbstractEvent); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_message_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*Extra); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - } - type x struct{} - out := protoimpl.TypeBuilder{ - File: protoimpl.DescBuilder{ - GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: file_message_proto_rawDesc, - NumEnums: 0, - NumMessages: 3, - NumExtensions: 0, - NumServices: 0, - }, - GoTypes: file_message_proto_goTypes, - DependencyIndexes: file_message_proto_depIdxs, - MessageInfos: file_message_proto_msgTypes, - }.Build() - File_message_proto = out.File - file_message_proto_rawDesc = nil - file_message_proto_goTypes = nil - file_message_proto_depIdxs = nil -}