diff --git a/perxis-proto b/perxis-proto index 8606df02e0df6807e503bf22471a295020a47fba..f000812a1eef24093c0d0abf1318e3179b679773 160000 --- a/perxis-proto +++ b/perxis-proto @@ -1 +1 @@ -Subproject commit 8606df02e0df6807e503bf22471a295020a47fba +Subproject commit f000812a1eef24093c0d0abf1318e3179b679773 diff --git a/pkg/collections/collection.go b/pkg/collections/collection.go index 39b082ef134030ab39e5e3fdae7a5692cca47d73..dfe5d66ed4a5b96f4f99118a6842488a2bc94735 100644 --- a/pkg/collections/collection.go +++ b/pkg/collections/collection.go @@ -90,6 +90,7 @@ type StateInfo struct { State State `json:"state" bson:"state"` Info string `json:"info" bson:"info"` StartedAt time.Time `json:"started_at,omitempty" bson:"started_at,omitempty"` + DBVersion uint32 `json:"db_version" bson:"db_version"` } type State int diff --git a/pkg/content/content.go b/pkg/content/content.go index 22acaaa7227622781e93b0a9a019acae51e76873..3495c995852134bd150390b3b92626e26b271ee8 100644 --- a/pkg/content/content.go +++ b/pkg/content/content.go @@ -38,6 +38,10 @@ type Content struct { runners []Runnable } +const ( + DBVersion uint32 = 1 +) + func (c *Content) RegisterStart(svc interface{}) { if r, ok := svc.(Runnable); ok { c.runners = append(c.runners, r)