tx

Documentation

Index

• Constants
• func Begin(_ sfplugins.StatefunExecutor, ...)
• func Commit(_ sfplugins.StatefunExecutor, ...)
• func CreateObject(_ sfplugins.StatefunExecutor, ...)
• func CreateObjectsLink(_ sfplugins.StatefunExecutor, ...)
• func CreateType(_ sfplugins.StatefunExecutor, ...)
• func CreateTypesLink(_ sfplugins.StatefunExecutor, ...)
• func DeleteObject(_ sfplugins.StatefunExecutor, ...)
• func DeleteObjectsLink(_ sfplugins.StatefunExecutor, ...)
• func DeleteType(_ sfplugins.StatefunExecutor, ...)
• func DeleteTypesLink(_ sfplugins.StatefunExecutor, ...)
• func Push(_ sfplugins.StatefunExecutor, ...)
• func RegisterAllFunctionTypes(runtime *statefun.Runtime)
• func UpdateObject(_ sfplugins.StatefunExecutor, ...)
• func UpdateObjectsLink(_ sfplugins.StatefunExecutor, ...)
• func UpdateType(_ sfplugins.StatefunExecutor, ...)
• func UpdateTypesLink(_ sfplugins.StatefunExecutor, ...)

Constants

const (
	OBJECTS_TYPELINK         = "__objects"
	TYPES_TYPELINK           = "__types"
	TYPE_TYPELINK            = "__type"
	OBJECT_TYPELINK          = "__object"
	OBJECT_2_OBJECT_TYPELINK = "obj"
	BUILT_IN_TYPES           = "types"
	BUILT_IN_OBJECTS         = "objects"
	BUILT_IN_ROOT            = "root"
	BUILT_IN_GROUP           = "group"
	BUILT_IN_NAV             = "nav"
	GROUP_TYPELINK           = "group"
)

Functions

func Begin

func Begin(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

payload:{
	"clone": "min" | "full" | "with_types", optional, default: full
	"types": map[string]beginTxType, only with "clone":"with_types"
}

func Commit

func Commit(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

payload:{
	"debug": bool, optional, default: "false"
	"mode": "merge" | "replace", optional, default: "merge"
}

exec on transaction

func CreateObject

func CreateObject(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

{
	"id": string,
	"origin_type": string,
	"body": json
}

create objects -> object link

create type -> object link

create object -> type link

func CreateObjectsLink

func CreateObjectsLink(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

{
	"from": string,
	"to": string,
	"body": json
}

create object -> object link

func CreateType

func CreateType(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

{
	"id": string,
	"body": json
}

create types -> type link

func CreateTypesLink

func CreateTypesLink(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

{
	"from": string,
	"to": string,
	"object_link_type": string
	"body": json
}

create type -> type link

func DeleteObject

func DeleteObject(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

{
	"id":string
}

TODO: mark for delete all link from/in object

func DeleteObjectsLink

func DeleteObjectsLink(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

{
	"from": string,
	"to": string,
}

func DeleteType

func DeleteType(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

{
	"id": string
}

func DeleteTypesLink

func DeleteTypesLink(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

{
	"from": string,
	"to": string,
}

func Push

func Push(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

payload:{
	"debug": bool, optional, default: "false"
	"mode": "merge" | "replace", optional, default: "merge"
}

func RegisterAllFunctionTypes

func RegisterAllFunctionTypes(runtime *statefun.Runtime)

func UpdateObject

func UpdateObject(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

{
	"id": string,
	"body": json
	"mode": "merge" | "replace", optional, default: "merge"
}

clone object from main graph if not exists

update object body

func UpdateObjectsLink

func UpdateObjectsLink(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

{
	"from": string,
	"to": string,
	"body": json, optional
}

func UpdateType

func UpdateType(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

{
	"id": string,
	"body": json
}

clone type from main graph if not exists

update type body

func UpdateTypesLink

func UpdateTypesLink(_ sfplugins.StatefunExecutor, contextProcessor *sfplugins.StatefunContextProcessor)

{
	"from": string,
	"to": string,
	"object_link_type": string, optional
	"body": json, optional
}