store

package

Go to main page

Versions in this module

v1

v1.5.5

Jan 26, 2026

v1.5.4

Jan 5, 2026

v1.5.3

Dec 23, 2025

v1.5.2

Dec 20, 2025

v1.5.1

Dec 7, 2025

v1.5.0

Aug 19, 2025

v1.4.26

Nov 6, 2025

v1.4.25

Nov 6, 2025

v1.4.24

Oct 17, 2025

v1.4.23

Sep 26, 2025

v1.4.22

Sep 15, 2025

v1.4.21

Sep 15, 2025

v1.4.20

Sep 3, 2025

v1.4.19

Aug 26, 2025

v1.4.18

Aug 25, 2025

v1.4.17

Aug 19, 2025

v1.4.16

Aug 3, 2025

v1.4.15

Jul 26, 2025

v1.4.14

Jul 23, 2025

v1.4.13

Jul 9, 2025

v1.4.12

Jun 29, 2025

v1.4.11

Jun 27, 2025

v1.4.10

Jun 11, 2025

v1.4.9

May 25, 2025

v1.4.8

May 13, 2025

v1.4.7

May 13, 2025

Changes in this version

+ func StoreSetPipelineExec(pl *sling.Pipeline)

+ func StoreSetReplicationExec(t *sling.TaskExecution)

v1.4.6

Apr 27, 2025

v1.4.5

Apr 17, 2025

v1.4.4

Mar 15, 2025

v1.4.3

Feb 14, 2025

v1.4.2

Feb 3, 2025

v1.4.1

Feb 1, 2025

v1.4.0

Jan 22, 2025

v1.3.6

Jan 22, 2025

v1.3.5

Jan 15, 2025

v1.3.4

Dec 27, 2024

v1.3.3

Dec 16, 2024

Changes in this version

+ var Store = cmap.New[*Execution]()

+ func StoreSet(t *sling.TaskExecution)

v1.3.2

Dec 3, 2024

v1.3.1

Dec 1, 2024

v1.3.0

Dec 1, 2024

v1.2.25

Dec 1, 2024

v1.2.24

Nov 26, 2024

v1.2.23

Nov 24, 2024

v1.2.22

Oct 24, 2024

v1.2.21

Oct 21, 2024

v1.2.20

Sep 24, 2024

v1.2.19

Sep 22, 2024

v1.2.18

Aug 30, 2024

v1.2.17

Aug 28, 2024

v1.2.16

Aug 27, 2024

v1.2.15

Aug 14, 2024

Changes in this version

+ func GetMachineID() string

+ type Setting struct

+ Key string

+ Value string

v1.2.14

Jul 25, 2024

Changes in this version

type Execution

+ TaskExec *sling.TaskExecution

type Replication

+ ID *string

v1.2.13

Jun 29, 2024

v1.2.12

Jun 29, 2024

Changes in this version

type Execution

+ WorkPath *string

v1.2.11

Jun 4, 2024

v1.2.10

May 18, 2024

Changes in this version

type Replication

+ func (r *Replication) Scan(value interface{}) error

+ func (r Replication) Value() (driver.Value, error)

type Task

+ func (t *Task) Scan(value interface{}) error

+ func (t Task) Value() (driver.Value, error)

v1.2.9

Apr 28, 2024

v1.2.8

Apr 28, 2024

v1.2.7

Apr 28, 2024

Changes in this version

type Replication

+ Config sling.ReplicationConfig

type Task

+ Config sling.Config

v1.2.6

Apr 22, 2024

v1.2.5

Apr 15, 2024

v1.2.4

Apr 13, 2024

v1.2.3

Apr 5, 2024

v1.2.2

Mar 31, 2024

Changes in this version

type Execution

+ Replication *Replication

+ Task *Task

type Replication

+ Name string

+ ProjectID *string

type Task

+ ProjectID *string

v1.2.1

Mar 23, 2024

v1.2.0

Mar 23, 2024

v1.1.25

Mar 23, 2024

v1.1.24

Mar 23, 2024

v1.1.23

Mar 23, 2024

v1.1.22

Mar 23, 2024

v1.1.21

Mar 23, 2024

v1.1.20

Mar 23, 2024

v1.1.19

Mar 23, 2024

v1.1.18

Mar 23, 2024

v1.1.17

Mar 23, 2024

v1.1.16

Mar 23, 2024

v1.1.15

Mar 23, 2024

v1.1.14

Mar 14, 2024

Changes in this version

type Execution

+ Version string

v1.1.13

Mar 7, 2024

Changes in this version

type Execution

+ ExecID string

v1.1.12

Mar 1, 2024

v1.1.11

Feb 28, 2024

v1.1.10

Feb 28, 2024

v1.1.9

Feb 28, 2024

v1.1.8

Feb 26, 2024

v1.1.7

Feb 22, 2024

v1.1.6

Feb 19, 2024

v1.1.5

Feb 11, 2024

v1.1.4

Feb 11, 2024

v1.1.3

Feb 8, 2024

v1.1.2

Feb 8, 2024

v1.1.1

Feb 7, 2024

v1.1.0

Feb 7, 2024

v1.0.74

Feb 7, 2024

v1.0.73

Feb 3, 2024

v1.0.72

Jan 27, 2024

v1.0.71

Jan 20, 2024

v1.0.70

Jan 19, 2024

v1.0.69

Jan 12, 2024

v1.0.68

Jan 10, 2024

v1.0.67

Jan 3, 2024

v1.0.66

Dec 28, 2023

v1.0.65

Dec 16, 2023

v1.0.64

Dec 11, 2023

Changes in this version

type Execution

+ Pid int

v1.0.63

Dec 4, 2023

Changes in this version

+ var Conn database.Connection

+ var Db *gorm.DB

+ var Dbx *sqlx.DB

+ var DropAll = false

+ func InitDB()

+ func StoreInsert(t *sling.TaskExecution)

+ func StoreUpdate(t *sling.TaskExecution)

+ func ToConfigObject(t *sling.TaskExecution) (task *Task, replication *Replication)

+ type Execution struct

+ Bytes uint64

+ CreatedDt time.Time

+ EndTime *time.Time

+ Err *string

+ ExitCode int

+ FilePath *string

+ ID int64

+ Output string

+ ProjectID *string

+ ReplicationMD5 string

+ Rows uint64

+ StartTime *time.Time

+ Status sling.ExecStatus

+ StreamID string

+ TaskMD5 string

+ UpdatedDt time.Time

+ func ToExecutionObject(t *sling.TaskExecution) *Execution

+ type Replication struct

+ CreatedDt time.Time

+ MD5 string

+ Replication sling.ReplicationConfig

+ Type sling.JobType

+ UpdatedDt time.Time

+ type Task struct

+ CreatedDt time.Time

+ MD5 string

+ Task sling.Config

+ Type sling.JobType

+ UpdatedDt time.Time

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL