db

package
v0.1.7 Latest Latest
Warning

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

 Go to latest Published: Jul 30, 2025 License: Apache-2.0 Imports: 9 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func OpErrorFromOpMsg 

func OpErrorFromOpMsg(om sfMediators.OpMsg) error

Types

type CMDBSyncClient 

type CMDBSyncClient struct {
	ShadowObjectCanBeRecevier bool
	// contains filtered or unexported fields
}

func NewCMDBSyncClient 

func NewCMDBSyncClient(NatsURL string, NatsRequestTimeoutSec int, HubDomainName string) (CMDBSyncClient, error)

func NewCMDBSyncClientFromRequestFunction 

func NewCMDBSyncClientFromRequestFunction(request sfp.SFRequestFunc) (CMDBSyncClient, error)

ctx.Request // or runtime.Request

func (CMDBSyncClient) ObjectCreate 

func (cmdb CMDBSyncClient) ObjectCreate(objectID, originType string, body ...easyjson.JSON) error

func (CMDBSyncClient) ObjectDelete 

func (cmdb CMDBSyncClient) ObjectDelete(id string) error

func (CMDBSyncClient) ObjectDeleteWithDetails 

func (cmdb CMDBSyncClient) ObjectDeleteWithDetails(id string) (easyjson.JSON, error)

func (CMDBSyncClient) ObjectRead 

func (cmdb CMDBSyncClient) ObjectRead(name string) (easyjson.JSON, error)

func (CMDBSyncClient) ObjectUpdate 

func (cmdb CMDBSyncClient) ObjectUpdate(objectID string, body easyjson.JSON, replace bool, originType4Upsert ...string) error

func (CMDBSyncClient) ObjectUpdateWithDetails 

func (cmdb CMDBSyncClient) ObjectUpdateWithDetails(objectID string, body easyjson.JSON, replace bool, originType4Upsert ...string) (easyjson.JSON, error)

func (CMDBSyncClient) ObjectsLinkCreate 

func (cmdb CMDBSyncClient) ObjectsLinkCreate(from, to, name string, tags []string, body ...easyjson.JSON) error

func (CMDBSyncClient) ObjectsLinkDelete 

func (cmdb CMDBSyncClient) ObjectsLinkDelete(from, to string) error

func (CMDBSyncClient) ObjectsLinkDeleteWithDetails 

func (cmdb CMDBSyncClient) ObjectsLinkDeleteWithDetails(from, to string) (easyjson.JSON, error)

func (CMDBSyncClient) ObjectsLinkRead 

func (cmdb CMDBSyncClient) ObjectsLinkRead(from, to string) (easyjson.JSON, error)

func (CMDBSyncClient) ObjectsLinkSuperTypeCreate added in v0.1.7 

func (cmdb CMDBSyncClient) ObjectsLinkSuperTypeCreate(from, to, fromClaimType, toClaimType, name string, tags []string, body ...easyjson.JSON) error

func (CMDBSyncClient) ObjectsLinkSuperTypeDelete added in v0.1.7 

func (cmdb CMDBSyncClient) ObjectsLinkSuperTypeDelete(from, to, fromClaimType, toClaimType string) error

func (CMDBSyncClient) ObjectsLinkUpdate 

func (cmdb CMDBSyncClient) ObjectsLinkUpdate(from, to string, tags []string, body easyjson.JSON, replace bool, name4Upsert ...string) error

func (CMDBSyncClient) ObjectsLinkUpdateWithDetails 

func (cmdb CMDBSyncClient) ObjectsLinkUpdateWithDetails(from, to string, tags []string, body easyjson.JSON, replace bool, name4Upsert ...string) (easyjson.JSON, error)

func (CMDBSyncClient) TriggerLinkDrop 

func (cmdb CMDBSyncClient) TriggerLinkDrop(fromTypeName, toTypeName string, triggerType TriggerType) error

func (CMDBSyncClient) TriggerLinkRemove 

func (cmdb CMDBSyncClient) TriggerLinkRemove(fromTypeName, toTypeName string, triggerType TriggerType, statefunName ...string) error

func (CMDBSyncClient) TriggerLinkSet 

func (cmdb CMDBSyncClient) TriggerLinkSet(fromTypeName, toTypeName string, triggerType TriggerType, statefunName ...string) error

func (CMDBSyncClient) TriggerObjectDelete 

func (cmdb CMDBSyncClient) TriggerObjectDelete(typeName string, triggerType TriggerType, statefunName ...string) error

func (CMDBSyncClient) TriggerObjectDrop 

func (cmdb CMDBSyncClient) TriggerObjectDrop(typeName string, triggerType TriggerType) error

func (CMDBSyncClient) TriggerObjectSet 

func (cmdb CMDBSyncClient) TriggerObjectSet(typeName string, triggerType TriggerType, statefunName ...string) error

func (CMDBSyncClient) TypeCreate 

func (cmdb CMDBSyncClient) TypeCreate(name string, body ...easyjson.JSON) error

func (CMDBSyncClient) TypeDelete 

func (cmdb CMDBSyncClient) TypeDelete(name string) error

func (CMDBSyncClient) TypeRead 

func (cmdb CMDBSyncClient) TypeRead(name string) (easyjson.JSON, error)

func (CMDBSyncClient) TypeRemoveSubType added in v0.1.7 

func (cmdb CMDBSyncClient) TypeRemoveSubType(baseType, childType string) error

func (CMDBSyncClient) TypeSetSubType added in v0.1.7 

func (cmdb CMDBSyncClient) TypeSetSubType(baseType, childType string) error

func (CMDBSyncClient) TypeUpdate 

func (cmdb CMDBSyncClient) TypeUpdate(name string, body easyjson.JSON, replace bool, upsert ...bool) error

func (CMDBSyncClient) TypesLinkCreate 

func (cmdb CMDBSyncClient) TypesLinkCreate(from, to, objectLinkType string, tags []string, body ...easyjson.JSON) error

func (CMDBSyncClient) TypesLinkDelete 

func (cmdb CMDBSyncClient) TypesLinkDelete(from, to string) error

func (CMDBSyncClient) TypesLinkRead 

func (cmdb CMDBSyncClient) TypesLinkRead(from, to string) (easyjson.JSON, error)

func (CMDBSyncClient) TypesLinkUpdate 

func (cmdb CMDBSyncClient) TypesLinkUpdate(from, to string, tags []string, body easyjson.JSON, replace bool, upsert ...bool) error

type DBSyncClient 

type DBSyncClient struct {
	Request sfp.SFRequestFunc
	Graph   GraphSyncClient
	CMDB    CMDBSyncClient
	Query   QuerySyncClient
}

func NewDBSyncClient 

func NewDBSyncClient(NatsURL string, NatsRequestTimeoutSec int, HubDomainName string) (DBSyncClient, error)

func NewDBSyncClientFromRequestFunction 

func NewDBSyncClientFromRequestFunction(request sfp.SFRequestFunc) (DBSyncClient, error)

ctx.Request // or runtime.Request

type GraphSyncClient 

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

func NewGraphSyncClient 

func NewGraphSyncClient(NatsURL string, NatsRequestTimeoutSec int, HubDomainName string) (GraphSyncClient, error)

func NewGraphSyncClientFromRequestFunction 

func NewGraphSyncClientFromRequestFunction(request sfp.SFRequestFunc) (GraphSyncClient, error)

ctx.Request // or runtime.Request

func (GraphSyncClient) VertexCreate 

func (gc GraphSyncClient) VertexCreate(id string, body ...easyjson.JSON) error

func (GraphSyncClient) VertexDelete 

func (gc GraphSyncClient) VertexDelete(id string) error

func (GraphSyncClient) VertexRead 

func (gc GraphSyncClient) VertexRead(id string, details ...bool) (easyjson.JSON, error)

func (GraphSyncClient) VertexUpdate 

func (gc GraphSyncClient) VertexUpdate(id string, body easyjson.JSON, replace bool, upsert ...bool) error

func (GraphSyncClient) VerticesLinkCreate 

func (gc GraphSyncClient) VerticesLinkCreate(from, to, linkName, linkType string, tags []string, body ...easyjson.JSON) error

func (GraphSyncClient) VerticesLinkDelete 

func (gc GraphSyncClient) VerticesLinkDelete(from, linkName string) error

func (GraphSyncClient) VerticesLinkDeleteByToAndType 

func (gc GraphSyncClient) VerticesLinkDeleteByToAndType(from, to, linkType string) error

func (GraphSyncClient) VerticesLinkRead 

func (gc GraphSyncClient) VerticesLinkRead(from, linkName string, details ...bool) (easyjson.JSON, error)

func (GraphSyncClient) VerticesLinkReadByToAndType 

func (gc GraphSyncClient) VerticesLinkReadByToAndType(from, to, linkType string, details ...bool) (easyjson.JSON, error)

func (GraphSyncClient) VerticesLinkUpdate 

func (gc GraphSyncClient) VerticesLinkUpdate(from, linkName string, tags []string, body easyjson.JSON, replace bool, toAndType4Upsert ...string) error

func (GraphSyncClient) VerticesLinkUpdateByToAndType 

func (gc GraphSyncClient) VerticesLinkUpdateByToAndType(from, to, linkType string, tags []string, body easyjson.JSON, replace bool, name4Upsert ...string) error

type OpError 

type OpError struct {
	StatusCode int
	Details    string
}

func (*OpError) Error 

func (oe *OpError) Error() string

type QuerySyncClient 

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

func NewQuerySyncClient 

func NewQuerySyncClient(NatsURL string, NatsRequestTimeoutSec int, HubDomainName string) (QuerySyncClient, error)

func NewQuerySyncClientFromRequestFunction 

func NewQuerySyncClientFromRequestFunction(request sfp.SFRequestFunc) (QuerySyncClient, error)

ctx.Request // or runtime.Request

func (QuerySyncClient) FPLQuery 

func (qc QuerySyncClient) FPLQuery(id, queryStringOfJSON string) (easyjson.JSON, error)

func (QuerySyncClient) JPGQLCtraQuery 

func (qc QuerySyncClient) JPGQLCtraQuery(id, query string) ([]string, error)

type TriggerType 

type TriggerType = string
const (
	CreateTrigger TriggerType = "create"
	UpdateTrigger TriggerType = "update"
	DeleteTrigger TriggerType = "delete"
	ReadTrigger   TriggerType = "read"
)

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.