Documentation ¶
Index ¶
- func NewEntity(store data.Store, entityId string) data.EntityBinding
- func NewField(store data.Store, entityId, fieldName string) data.FieldBinding
- func NewMulti(store data.Store) data.MultiBinding
- type Entity
- func (e *Entity) AppendChildId(id string)
- func (e *Entity) GetChildrenIds() []string
- func (e *Entity) GetField(fieldName string) data.FieldBinding
- func (e *Entity) GetId() string
- func (e *Entity) GetName() string
- func (e *Entity) GetParentId() string
- func (e *Entity) GetType() string
- func (e *Entity) Impl() any
- func (e *Entity) RemoveChildId(id string)
- func (e *Entity) SetChildrenIds(ids []string)
- func (e *Entity) SetId(id string)
- func (e *Entity) SetName(n string)
- func (e *Entity) SetParentId(p string)
- func (e *Entity) SetType(t string)
- type Field
- func (b *Field) GetBinaryFile() string
- func (b *Field) GetBool() bool
- func (b *Field) GetEntityId() string
- func (b *Field) GetEntityReference() string
- func (b *Field) GetFieldName() string
- func (b *Field) GetFloat() float64
- func (b *Field) GetInt() int64
- func (b *Field) GetString() string
- func (b *Field) GetTimestamp() time.Time
- func (b *Field) GetTransformation() string
- func (b *Field) GetValue() data.Value
- func (b *Field) GetWriteTime() time.Time
- func (b *Field) GetWriter() string
- func (b *Field) IsBinaryFile() bool
- func (b *Field) IsBool() bool
- func (b *Field) IsEntityReference() bool
- func (b *Field) IsFloat() bool
- func (b *Field) IsInt() bool
- func (b *Field) IsString() bool
- func (b *Field) IsTimestamp() bool
- func (b *Field) IsTransformation() bool
- func (b *Field) ReadBinaryFile() string
- func (b *Field) ReadBool() bool
- func (b *Field) ReadEntityReference() string
- func (b *Field) ReadFloat() float64
- func (b *Field) ReadInt() int64
- func (b *Field) ReadString() string
- func (b *Field) ReadTimestamp() time.Time
- func (b *Field) ReadTransformation() string
- func (b *Field) ReadValue() data.Value
- func (b *Field) SetValue(v data.Value) data.FieldBinding
- func (b *Field) WriteBinaryFile(args ...interface{}) data.FieldBinding
- func (b *Field) WriteBool(args ...interface{}) data.FieldBinding
- func (b *Field) WriteEntityReference(args ...interface{}) data.FieldBinding
- func (b *Field) WriteFloat(args ...interface{}) data.FieldBinding
- func (b *Field) WriteInt(args ...interface{}) data.FieldBinding
- func (b *Field) WriteString(args ...interface{}) data.FieldBinding
- func (b *Field) WriteTimestamp(args ...interface{}) data.FieldBinding
- func (b *Field) WriteTransformation(args ...interface{}) data.FieldBinding
- func (b *Field) WriteValue(v data.Value) data.FieldBinding
- type MultiBinding
- func (m *MultiBinding) Commit()
- func (m *MultiBinding) Connect()
- func (m *MultiBinding) CreateEntity(entityType, parentId, name string)
- func (m *MultiBinding) CreateSnapshot() data.Snapshot
- func (m *MultiBinding) DeleteEntity(entityId string)
- func (m *MultiBinding) Disconnect()
- func (m *MultiBinding) EntityExists(entityId string) bool
- func (m *MultiBinding) FieldExists(fieldName, entityType string) bool
- func (m *MultiBinding) FindEntities(entityType string) []string
- func (m *MultiBinding) GetEntity(entityId string) data.Entity
- func (m *MultiBinding) GetEntityById(entityId string) data.EntityBinding
- func (m *MultiBinding) GetEntitySchema(entityType string) data.EntitySchema
- func (m *MultiBinding) GetEntityTypes() []string
- func (m *MultiBinding) IsConnected() bool
- func (m *MultiBinding) Notify(config data.NotificationConfig, callback data.NotificationCallback) data.NotificationToken
- func (m *MultiBinding) ProcessNotifications()
- func (m *MultiBinding) Read(reqs ...data.Request)
- func (m *MultiBinding) RestoreSnapshot(s data.Snapshot)
- func (m *MultiBinding) SetEntity(value data.Entity)
- func (m *MultiBinding) SetEntitySchema(schema data.EntitySchema)
- func (m *MultiBinding) SortedSetAdd(key string, member string, score float64) int64
- func (m *MultiBinding) SortedSetRangeByScoreWithScores(key string, min, max string) []data.SortedSetMember
- func (m *MultiBinding) SortedSetRemove(key string, member string) int64
- func (m *MultiBinding) SortedSetRemoveRangeByRank(key string, start, stop int64) int64
- func (m *MultiBinding) TempDel(key string)
- func (m *MultiBinding) TempExpire(key string, expiration time.Duration)
- func (m *MultiBinding) TempGet(key string) string
- func (m *MultiBinding) TempSet(key string, value string, expiration time.Duration) bool
- func (m *MultiBinding) Unnotify(subscriptionId string)
- func (m *MultiBinding) UnnotifyCallback(subscriptionId string, callback data.NotificationCallback)
- func (m *MultiBinding) Write(reqs ...data.Request)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Entity ¶
type Entity struct {
// contains filtered or unexported fields
}
func (*Entity) AppendChildId ¶
func (*Entity) GetChildrenIds ¶
func (*Entity) GetParentId ¶
func (*Entity) RemoveChildId ¶
func (*Entity) SetChildrenIds ¶
func (*Entity) SetParentId ¶
type Field ¶
type Field struct {
// contains filtered or unexported fields
}
func (*Field) GetBinaryFile ¶
func (*Field) GetEntityId ¶
func (*Field) GetEntityReference ¶
func (*Field) GetFieldName ¶
func (*Field) GetTimestamp ¶
func (*Field) GetTransformation ¶
func (*Field) GetWriteTime ¶
func (*Field) IsBinaryFile ¶
func (*Field) IsEntityReference ¶
func (*Field) IsTimestamp ¶
func (*Field) IsTransformation ¶
func (*Field) ReadBinaryFile ¶
func (*Field) ReadEntityReference ¶
func (*Field) ReadString ¶
func (*Field) ReadTimestamp ¶
func (*Field) ReadTransformation ¶
func (*Field) WriteBinaryFile ¶
func (b *Field) WriteBinaryFile(args ...interface{}) data.FieldBinding
func (*Field) WriteBool ¶
func (b *Field) WriteBool(args ...interface{}) data.FieldBinding
func (*Field) WriteEntityReference ¶
func (b *Field) WriteEntityReference(args ...interface{}) data.FieldBinding
func (*Field) WriteFloat ¶
func (b *Field) WriteFloat(args ...interface{}) data.FieldBinding
func (*Field) WriteInt ¶
func (b *Field) WriteInt(args ...interface{}) data.FieldBinding
func (*Field) WriteString ¶
func (b *Field) WriteString(args ...interface{}) data.FieldBinding
func (*Field) WriteTimestamp ¶
func (b *Field) WriteTimestamp(args ...interface{}) data.FieldBinding
func (*Field) WriteTransformation ¶
func (b *Field) WriteTransformation(args ...interface{}) data.FieldBinding
func (*Field) WriteValue ¶
func (b *Field) WriteValue(v data.Value) data.FieldBinding
type MultiBinding ¶ added in v0.0.9
type MultiBinding struct {
// contains filtered or unexported fields
}
func (*MultiBinding) Commit ¶ added in v0.0.9
func (m *MultiBinding) Commit()
func (*MultiBinding) Connect ¶ added in v0.0.9
func (m *MultiBinding) Connect()
Implement Store interface by proxying to impl
func (*MultiBinding) CreateEntity ¶ added in v0.0.9
func (m *MultiBinding) CreateEntity(entityType, parentId, name string)
func (*MultiBinding) CreateSnapshot ¶ added in v0.0.9
func (m *MultiBinding) CreateSnapshot() data.Snapshot
func (*MultiBinding) DeleteEntity ¶ added in v0.0.9
func (m *MultiBinding) DeleteEntity(entityId string)
func (*MultiBinding) Disconnect ¶ added in v0.0.9
func (m *MultiBinding) Disconnect()
func (*MultiBinding) EntityExists ¶ added in v0.0.9
func (m *MultiBinding) EntityExists(entityId string) bool
func (*MultiBinding) FieldExists ¶ added in v0.0.9
func (m *MultiBinding) FieldExists(fieldName, entityType string) bool
func (*MultiBinding) FindEntities ¶ added in v0.0.9
func (m *MultiBinding) FindEntities(entityType string) []string
func (*MultiBinding) GetEntity ¶ added in v0.0.9
func (m *MultiBinding) GetEntity(entityId string) data.Entity
func (*MultiBinding) GetEntityById ¶ added in v0.0.9
func (m *MultiBinding) GetEntityById(entityId string) data.EntityBinding
MultiBinding specific methods
func (*MultiBinding) GetEntitySchema ¶ added in v0.0.9
func (m *MultiBinding) GetEntitySchema(entityType string) data.EntitySchema
func (*MultiBinding) GetEntityTypes ¶ added in v0.0.9
func (m *MultiBinding) GetEntityTypes() []string
func (*MultiBinding) IsConnected ¶ added in v0.0.9
func (m *MultiBinding) IsConnected() bool
func (*MultiBinding) Notify ¶ added in v0.0.9
func (m *MultiBinding) Notify(config data.NotificationConfig, callback data.NotificationCallback) data.NotificationToken
func (*MultiBinding) ProcessNotifications ¶ added in v0.0.9
func (m *MultiBinding) ProcessNotifications()
func (*MultiBinding) Read ¶ added in v0.0.9
func (m *MultiBinding) Read(reqs ...data.Request)
Queue reads and writes instead of executing immediately
func (*MultiBinding) RestoreSnapshot ¶ added in v0.0.9
func (m *MultiBinding) RestoreSnapshot(s data.Snapshot)
func (*MultiBinding) SetEntity ¶ added in v0.0.9
func (m *MultiBinding) SetEntity(value data.Entity)
func (*MultiBinding) SetEntitySchema ¶ added in v0.0.9
func (m *MultiBinding) SetEntitySchema(schema data.EntitySchema)
func (*MultiBinding) SortedSetAdd ¶ added in v0.0.9
func (m *MultiBinding) SortedSetAdd(key string, member string, score float64) int64
func (*MultiBinding) SortedSetRangeByScoreWithScores ¶ added in v0.0.9
func (m *MultiBinding) SortedSetRangeByScoreWithScores(key string, min, max string) []data.SortedSetMember
func (*MultiBinding) SortedSetRemove ¶ added in v0.0.9
func (m *MultiBinding) SortedSetRemove(key string, member string) int64
func (*MultiBinding) SortedSetRemoveRangeByRank ¶ added in v0.0.9
func (m *MultiBinding) SortedSetRemoveRangeByRank(key string, start, stop int64) int64
func (*MultiBinding) TempDel ¶ added in v0.0.9
func (m *MultiBinding) TempDel(key string)
func (*MultiBinding) TempExpire ¶ added in v0.0.9
func (m *MultiBinding) TempExpire(key string, expiration time.Duration)
func (*MultiBinding) TempGet ¶ added in v0.0.9
func (m *MultiBinding) TempGet(key string) string
func (*MultiBinding) Unnotify ¶ added in v0.0.9
func (m *MultiBinding) Unnotify(subscriptionId string)
func (*MultiBinding) UnnotifyCallback ¶ added in v0.0.9
func (m *MultiBinding) UnnotifyCallback(subscriptionId string, callback data.NotificationCallback)
func (*MultiBinding) Write ¶ added in v0.0.9
func (m *MultiBinding) Write(reqs ...data.Request)
Click to show internal directories.
Click to hide internal directories.