transformer

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Dec 11, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewTransformer 

func NewTransformer(s data.Store) data.Transformer

Types

type Job 

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

type JobQueue 

type JobQueue []*Job

func (JobQueue) Len 

func (pq JobQueue) Len() int

Len returns the length of the queue.

func (JobQueue) Less 

func (pq JobQueue) Less(i, j int) bool

Less compares two items based on their timestamps (earlier timestamp = higher priority).

func (*JobQueue) Pop 

func (pq *JobQueue) Pop() any

Pop removes the highest-priority element from the queue.

func (*JobQueue) Push 

func (pq *JobQueue) Push(x any)

Push adds an element to the queue.

func (JobQueue) Swap 

func (pq JobQueue) Swap(i, j int)

Swap swaps the elements at the specified indices.

func (*JobQueue) Update 

func (pq *JobQueue) Update(job *Job, task *tengo.UserFunction, deadline time.Time)

update modifies the timestamp and value of an Item in the queue.

type TengoEntity 

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

func NewTengoEntity 

func NewTengoEntity(s data.Store, e data.Entity) *TengoEntity

func (*TengoEntity) GetChildrenIds 

func (te *TengoEntity) GetChildrenIds(...tengo.Object) (tengo.Object, error)

func (*TengoEntity) GetField 

func (te *TengoEntity) GetField(args ...tengo.Object) (tengo.Object, error)

func (*TengoEntity) GetId 

func (te *TengoEntity) GetId(...tengo.Object) (tengo.Object, error)

func (*TengoEntity) GetParentId 

func (te *TengoEntity) GetParentId(...tengo.Object) (tengo.Object, error)

func (*TengoEntity) GetType 

func (te *TengoEntity) GetType(...tengo.Object) (tengo.Object, error)

func (*TengoEntity) ToTengoMap 

func (te *TengoEntity) ToTengoMap() tengo.Object

type TengoField 

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

func NewTengoField 

func NewTengoField(b data.FieldBinding) *TengoField

func (*TengoField) GetBinaryFile 

func (tf *TengoField) GetBinaryFile(...tengo.Object) (tengo.Object, error)

func (*TengoField) GetBool 

func (tf *TengoField) GetBool(...tengo.Object) (tengo.Object, error)

func (*TengoField) GetEntityId 

func (tf *TengoField) GetEntityId(...tengo.Object) (tengo.Object, error)

func (*TengoField) GetEntityReference 

func (tf *TengoField) GetEntityReference(...tengo.Object) (tengo.Object, error)

func (*TengoField) GetFieldName 

func (tf *TengoField) GetFieldName(...tengo.Object) (tengo.Object, error)

func (*TengoField) GetFloat 

func (tf *TengoField) GetFloat(...tengo.Object) (tengo.Object, error)

func (*TengoField) GetInt 

func (tf *TengoField) GetInt(...tengo.Object) (tengo.Object, error)

func (*TengoField) GetString 

func (tf *TengoField) GetString(...tengo.Object) (tengo.Object, error)

func (*TengoField) GetTimestamp 

func (tf *TengoField) GetTimestamp(...tengo.Object) (tengo.Object, error)

func (*TengoField) GetWriteTime 

func (tf *TengoField) GetWriteTime(...tengo.Object) (tengo.Object, error)

func (*TengoField) GetWriter 

func (tf *TengoField) GetWriter(...tengo.Object) (tengo.Object, error)

func (*TengoField) ReadBinaryFile 

func (tf *TengoField) ReadBinaryFile(...tengo.Object) (tengo.Object, error)

func (*TengoField) ReadBool 

func (tf *TengoField) ReadBool(...tengo.Object) (tengo.Object, error)

func (*TengoField) ReadEntityReference 

func (tf *TengoField) ReadEntityReference(...tengo.Object) (tengo.Object, error)

func (*TengoField) ReadFloat 

func (tf *TengoField) ReadFloat(...tengo.Object) (tengo.Object, error)

func (*TengoField) ReadInt 

func (tf *TengoField) ReadInt(...tengo.Object) (tengo.Object, error)

func (*TengoField) ReadString 

func (tf *TengoField) ReadString(...tengo.Object) (tengo.Object, error)

func (*TengoField) ReadTimestamp 

func (tf *TengoField) ReadTimestamp(...tengo.Object) (tengo.Object, error)

func (*TengoField) ToTengoMap 

func (tf *TengoField) ToTengoMap() tengo.Object

func (*TengoField) WriteBinaryFile 

func (tf *TengoField) WriteBinaryFile(args ...tengo.Object) (tengo.Object, error)

func (*TengoField) WriteBool 

func (tf *TengoField) WriteBool(args ...tengo.Object) (tengo.Object, error)

func (*TengoField) WriteEntityReference 

func (tf *TengoField) WriteEntityReference(args ...tengo.Object) (tengo.Object, error)

func (*TengoField) WriteFloat 

func (tf *TengoField) WriteFloat(args ...tengo.Object) (tengo.Object, error)

func (*TengoField) WriteInt 

func (tf *TengoField) WriteInt(args ...tengo.Object) (tengo.Object, error)

func (*TengoField) WriteString 

func (tf *TengoField) WriteString(args ...tengo.Object) (tengo.Object, error)

func (*TengoField) WriteTimestamp 

func (tf *TengoField) WriteTimestamp(args ...tengo.Object) (tengo.Object, error)

type TengoStore 

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

func NewTengoStore 

func NewTengoStore(s data.Store) *TengoStore

func (*TengoStore) GetEntity 

func (ts *TengoStore) GetEntity(args ...tengo.Object) (tengo.Object, error)

func (*TengoStore) PopAvailableJobs 

func (ts *TengoStore) PopAvailableJobs() []*Job

func (*TengoStore) Query 

func (ts *TengoStore) Query(args ...tengo.Object) (tengo.Object, error)

func (*TengoStore) Schedule 

func (ts *TengoStore) Schedule(args ...tengo.Object) (tengo.Object, error)

func (*TengoStore) ToTengoMap 

func (ts *TengoStore) ToTengoMap() tengo.Object

type Transformer 

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

func (*Transformer) ProcessPending 

func (t *Transformer) ProcessPending()

func (*Transformer) Transform 

func (t *Transformer) Transform(src string, req 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.