Skip to content
Snippets Groups Projects
Commit 7099fe2e authored by Pavel Antonov's avatar Pavel Antonov :asterisk:
Browse files

Merge branch 'feature/PRXS-1195-CollsUpdateTTL' into 'master'

Обновлен пакет Collections после добавления поля TTL

See merge request perxis/perxis-go!42
parents c47f4706 beb81087
No related branches found
No related tags found
No related merge requests found
Subproject commit d9fd1b7382944ef12019bcab1ad00334d9b90a88 Subproject commit dcb1e741b7515784c6125761d459c23e3b61805f
...@@ -61,6 +61,7 @@ type Collection struct { ...@@ -61,6 +61,7 @@ type Collection struct {
Hidden bool `json:"hidden" bson:"hidden"` // Коллекция скрыта в административном интерфейсе Hidden bool `json:"hidden" bson:"hidden"` // Коллекция скрыта в административном интерфейсе
Schema *schema.Schema `json:"schema" bson:"schema"` Schema *schema.Schema `json:"schema" bson:"schema"`
Access *Access `json:"access" bson:"-"` // Ограничения на доступ к элементам коллекции. Отсутствие объекта означает неограниченный доступ Access *Access `json:"access" bson:"-"` // Ограничения на доступ к элементам коллекции. Отсутствие объекта означает неограниченный доступ
TTL time.Duration `json:"ttl" bson:"ttl"` // Время хранения записи в коллекции
// StateInfo отображает состояние коллекции: // StateInfo отображает состояние коллекции:
// - State: идентификатор состояния коллекции (new/preparing/ready/error/changed) // - State: идентификатор состояния коллекции (new/preparing/ready/error/changed)
...@@ -132,6 +133,7 @@ func (c Collection) Clone() *Collection { ...@@ -132,6 +133,7 @@ func (c Collection) Clone() *Collection {
Name: c.Name, Name: c.Name,
NoData: c.NoData, NoData: c.NoData,
Hidden: c.Hidden, Hidden: c.Hidden,
TTL: c.TTL,
} }
if c.Single != nil { if c.Single != nil {
......
...@@ -13,6 +13,7 @@ import ( ...@@ -13,6 +13,7 @@ import (
pb "git.perx.ru/perxis/perxis-go/proto/collections" pb "git.perx.ru/perxis/perxis-go/proto/collections"
commonpb "git.perx.ru/perxis/perxis-go/proto/common" commonpb "git.perx.ru/perxis/perxis-go/proto/common"
jsoniter "github.com/json-iterator/go" jsoniter "github.com/json-iterator/go"
"google.golang.org/protobuf/types/known/durationpb"
"google.golang.org/protobuf/types/known/timestamppb" "google.golang.org/protobuf/types/known/timestamppb"
) )
...@@ -69,6 +70,7 @@ func PtrCollectionToProto(coll *service.Collection) (*pb.Collection, error) { ...@@ -69,6 +70,7 @@ func PtrCollectionToProto(coll *service.Collection) (*pb.Collection, error) {
Access: access, Access: access,
Hidden: coll.Hidden, Hidden: coll.Hidden,
Tags: coll.Tags, Tags: coll.Tags,
Ttl: durationpb.New(coll.TTL),
} }
if coll.StateInfo != nil { if coll.StateInfo != nil {
...@@ -127,6 +129,7 @@ func ProtoToPtrCollection(protoCollection *pb.Collection) (*service.Collection, ...@@ -127,6 +129,7 @@ func ProtoToPtrCollection(protoCollection *pb.Collection) (*service.Collection,
Access: access, Access: access,
Hidden: protoCollection.Hidden, Hidden: protoCollection.Hidden,
Tags: protoCollection.Tags, Tags: protoCollection.Tags,
TTL: protoCollection.Ttl.AsDuration(),
} }
if protoCollection.StateInfo != nil { if protoCollection.StateInfo != nil {
......
...@@ -21,6 +21,7 @@ import ( ...@@ -21,6 +21,7 @@ import (
itemspb "git.perx.ru/perxis/perxis-go/proto/items" itemspb "git.perx.ru/perxis/perxis-go/proto/items"
localespb "git.perx.ru/perxis/perxis-go/proto/locales" localespb "git.perx.ru/perxis/perxis-go/proto/locales"
"github.com/golang/protobuf/ptypes" "github.com/golang/protobuf/ptypes"
"google.golang.org/protobuf/types/known/durationpb"
"google.golang.org/protobuf/types/known/structpb" "google.golang.org/protobuf/types/known/structpb"
) )
...@@ -127,6 +128,7 @@ func PtrCollectionsCollectionToProto(collection *collections.Collection) (*colle ...@@ -127,6 +128,7 @@ func PtrCollectionsCollectionToProto(collection *collections.Collection) (*colle
Name: collection.Name, Name: collection.Name,
Single: collection.Single, Single: collection.Single,
System: collection.System, System: collection.System,
Ttl: durationpb.New(collection.TTL),
} }
if collection.Schema != nil { if collection.Schema != nil {
b, err := collection.Schema.MarshalJSON() b, err := collection.Schema.MarshalJSON()
...@@ -149,6 +151,7 @@ func ProtoToPtrCollectionsCollection(protoCollection *collectionspb.Collection) ...@@ -149,6 +151,7 @@ func ProtoToPtrCollectionsCollection(protoCollection *collectionspb.Collection)
Name: protoCollection.Name, Name: protoCollection.Name,
Single: protoCollection.Single, Single: protoCollection.Single,
System: protoCollection.System, System: protoCollection.System,
TTL: protoCollection.Ttl.AsDuration(),
} }
if protoCollection.Schema != "" { if protoCollection.Schema != "" {
sch := schema.New() sch := schema.New()
......
This diff is collapsed.
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment