mongodb

type InsertDoc struct {
	Type      string                 `bson:"type"`
	Consumer  string                 `bson:"consumer"`
	Payload   map[string]interface{} `bson:"payload,inline,omitempty"`
	CreatedAt time.Time              `bson:"created_at"`
}

type Repo struct {
	// contains filtered or unexported fields
}