binding

package
v0.0.16 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 16, 2024 License: MIT Imports: 5 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewEntity 

func NewEntity(ctx context.Context, store data.Store, entityId string) data.EntityBinding

func NewField 

func NewField(store data.Store, entityId, fieldName string) data.FieldBinding

func NewMulti added in v0.0.9 

func NewMulti(store data.Store) data.MultiBinding

Types

type Entity 

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

func (*Entity) AppendChildId 

func (e *Entity) AppendChildId(id string)

func (*Entity) GetChildrenIds 

func (e *Entity) GetChildrenIds() []string

func (*Entity) GetField 

func (e *Entity) GetField(fieldName string) data.FieldBinding

func (*Entity) GetId 

func (e *Entity) GetId() string

func (*Entity) GetName 

func (e *Entity) GetName() string

func (*Entity) GetParentId 

func (e *Entity) GetParentId() string

func (*Entity) GetType 

func (e *Entity) GetType() string

func (*Entity) Impl added in v0.0.11 

func (e *Entity) Impl() any

func (*Entity) RemoveChildId 

func (e *Entity) RemoveChildId(id string)

func (*Entity) SetChildrenIds 

func (e *Entity) SetChildrenIds(ids []string)

func (*Entity) SetId 

func (e *Entity) SetId(id string)

func (*Entity) SetName 

func (e *Entity) SetName(n string)

func (*Entity) SetParentId 

func (e *Entity) SetParentId(p string)

func (*Entity) SetType 

func (e *Entity) SetType(t string)

type Field 

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

func (*Field) GetBinaryFile 

func (b *Field) GetBinaryFile() string

func (*Field) GetBool 

func (b *Field) GetBool() bool

func (*Field) GetEntityId 

func (b *Field) GetEntityId() string

func (*Field) GetEntityReference 

func (b *Field) GetEntityReference() string

func (*Field) GetFieldName 

func (b *Field) GetFieldName() string

func (*Field) GetFloat 

func (b *Field) GetFloat() float64

func (*Field) GetInt 

func (b *Field) GetInt() int64

func (*Field) GetString 

func (b *Field) GetString() string

func (*Field) GetTimestamp 

func (b *Field) GetTimestamp() time.Time

func (*Field) GetTransformation 

func (b *Field) GetTransformation() string

func (*Field) GetValue 

func (b *Field) GetValue() data.Value

func (*Field) GetWriteTime 

func (b *Field) GetWriteTime() time.Time

func (*Field) GetWriter 

func (b *Field) GetWriter() string

func (*Field) IsBinaryFile 

func (b *Field) IsBinaryFile() bool

func (*Field) IsBool 

func (b *Field) IsBool() bool

func (*Field) IsEntityReference 

func (b *Field) IsEntityReference() bool

func (*Field) IsFloat 

func (b *Field) IsFloat() bool

func (*Field) IsInt 

func (b *Field) IsInt() bool

func (*Field) IsString 

func (b *Field) IsString() bool

func (*Field) IsTimestamp 

func (b *Field) IsTimestamp() bool

func (*Field) IsTransformation 

func (b *Field) IsTransformation() bool

func (*Field) ReadBinaryFile 

func (b *Field) ReadBinaryFile(ctx context.Context) string

func (*Field) ReadBool 

func (b *Field) ReadBool(ctx context.Context) bool

func (*Field) ReadEntityReference 

func (b *Field) ReadEntityReference(ctx context.Context) string

func (*Field) ReadFloat 

func (b *Field) ReadFloat(ctx context.Context) float64

func (*Field) ReadInt 

func (b *Field) ReadInt(ctx context.Context) int64

func (*Field) ReadString 

func (b *Field) ReadString(ctx context.Context) string

func (*Field) ReadTimestamp 

func (b *Field) ReadTimestamp(ctx context.Context) time.Time

func (*Field) ReadTransformation 

func (b *Field) ReadTransformation(ctx context.Context) string

func (*Field) ReadValue 

func (b *Field) ReadValue(ctx context.Context) data.Value

func (*Field) SetValue added in v0.0.12 

func (b *Field) SetValue(v data.Value) data.FieldBinding

func (*Field) WriteBinaryFile 

func (b *Field) WriteBinaryFile(ctx context.Context, args ...interface{}) data.FieldBinding

func (*Field) WriteBool 

func (b *Field) WriteBool(ctx context.Context, args ...interface{}) data.FieldBinding

func (*Field) WriteEntityReference 

func (b *Field) WriteEntityReference(ctx context.Context, args ...interface{}) data.FieldBinding

func (*Field) WriteFloat 

func (b *Field) WriteFloat(ctx context.Context, args ...interface{}) data.FieldBinding

func (*Field) WriteInt 

func (b *Field) WriteInt(ctx context.Context, args ...interface{}) data.FieldBinding

func (*Field) WriteString 

func (b *Field) WriteString(ctx context.Context, args ...interface{}) data.FieldBinding

func (*Field) WriteTimestamp 

func (b *Field) WriteTimestamp(ctx context.Context, args ...interface{}) data.FieldBinding

func (*Field) WriteTransformation 

func (b *Field) WriteTransformation(ctx context.Context, args ...interface{}) data.FieldBinding

func (*Field) WriteValue 

func (b *Field) WriteValue(ctx context.Context, 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(ctx context.Context)

func (*MultiBinding) Connect added in v0.0.9 

func (m *MultiBinding) Connect(ctx context.Context)

Implement Store interface by proxying to impl

func (*MultiBinding) CreateEntity added in v0.0.9 

func (m *MultiBinding) CreateEntity(ctx context.Context, entityType, parentId, name string)

func (*MultiBinding) CreateSnapshot added in v0.0.9 

func (m *MultiBinding) CreateSnapshot(ctx context.Context) data.Snapshot

func (*MultiBinding) DeleteEntity added in v0.0.9 

func (m *MultiBinding) DeleteEntity(ctx context.Context, entityId string)

func (*MultiBinding) Disconnect added in v0.0.9 

func (m *MultiBinding) Disconnect(ctx context.Context)

func (*MultiBinding) EntityExists added in v0.0.9 

func (m *MultiBinding) EntityExists(ctx context.Context, entityId string) bool

func (*MultiBinding) FieldExists added in v0.0.9 

func (m *MultiBinding) FieldExists(ctx context.Context, fieldName, entityType string) bool

func (*MultiBinding) FindEntities added in v0.0.9 

func (m *MultiBinding) FindEntities(ctx context.Context, entityType string) []string

func (*MultiBinding) GetEntity added in v0.0.9 

func (m *MultiBinding) GetEntity(ctx context.Context, entityId string) data.Entity

func (*MultiBinding) GetEntityById added in v0.0.9 

func (m *MultiBinding) GetEntityById(ctx context.Context, entityId string) data.EntityBinding

MultiBinding specific methods

func (*MultiBinding) GetEntitySchema added in v0.0.9 

func (m *MultiBinding) GetEntitySchema(ctx context.Context, entityType string) data.EntitySchema

func (*MultiBinding) GetEntityTypes added in v0.0.9 

func (m *MultiBinding) GetEntityTypes(ctx context.Context) []string

func (*MultiBinding) IsConnected added in v0.0.9 

func (m *MultiBinding) IsConnected(ctx context.Context) bool

func (*MultiBinding) Notify added in v0.0.9 

func (m *MultiBinding) Notify(ctx context.Context, config data.NotificationConfig, callback data.NotificationCallback) data.NotificationToken

func (*MultiBinding) ProcessNotifications added in v0.0.9 

func (m *MultiBinding) ProcessNotifications(ctx context.Context)

func (*MultiBinding) Read added in v0.0.9 

func (m *MultiBinding) Read(ctx context.Context, reqs ...data.Request)

Queue reads and writes instead of executing immediately

func (*MultiBinding) RestoreSnapshot added in v0.0.9 

func (m *MultiBinding) RestoreSnapshot(ctx context.Context, s data.Snapshot)

func (*MultiBinding) SetEntity added in v0.0.9 

func (m *MultiBinding) SetEntity(ctx context.Context, value data.Entity)

func (*MultiBinding) SetEntitySchema added in v0.0.9 

func (m *MultiBinding) SetEntitySchema(ctx context.Context, schema data.EntitySchema)

func (*MultiBinding) SortedSetAdd added in v0.0.9 

func (m *MultiBinding) SortedSetAdd(ctx context.Context, key string, member string, score float64) int64

func (*MultiBinding) SortedSetRangeByScoreWithScores added in v0.0.9 

func (m *MultiBinding) SortedSetRangeByScoreWithScores(ctx context.Context, key string, min, max string) []data.SortedSetMember

func (*MultiBinding) SortedSetRemove added in v0.0.9 

func (m *MultiBinding) SortedSetRemove(ctx context.Context, key string, member string) int64

func (*MultiBinding) SortedSetRemoveRangeByRank added in v0.0.9 

func (m *MultiBinding) SortedSetRemoveRangeByRank(ctx context.Context, key string, start, stop int64) int64

func (*MultiBinding) TempDel added in v0.0.9 

func (m *MultiBinding) TempDel(ctx context.Context, key string)

func (*MultiBinding) TempExpire added in v0.0.9 

func (m *MultiBinding) TempExpire(ctx context.Context, key string, expiration time.Duration)

func (*MultiBinding) TempGet added in v0.0.9 

func (m *MultiBinding) TempGet(ctx context.Context, key string) string

func (*MultiBinding) TempSet added in v0.0.9 

func (m *MultiBinding) TempSet(ctx context.Context, key string, value string, expiration time.Duration) bool

func (*MultiBinding) Unnotify added in v0.0.9 

func (m *MultiBinding) Unnotify(ctx context.Context, subscriptionId string)

func (*MultiBinding) UnnotifyCallback added in v0.0.9 

func (m *MultiBinding) UnnotifyCallback(ctx context.Context, subscriptionId string, callback data.NotificationCallback)

func (*MultiBinding) Write added in v0.0.9 

func (m *MultiBinding) Write(ctx context.Context, reqs ...data.Request)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.