client

type DeleteGraphAssetRequestBody struct {
	Assets []knowledge.Asset `json:"assets"`
}

type DeleteGraphRelationRequestBody struct {
	Relations []knowledge.Relation `json:"relations"`
}

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

type GraphAPIOptions struct {
	// URL to GraphKB
	URL string
	// Auth token for this data source.
	AuthToken string
	// Skip verifying the certificate when using https
	SkipVerify bool

	// The level of parallelization for streaming updates, i.e., number of HTTP requests sent in parallel.
	Parallelization int

	// The size of a chunk of updates, i.e., number of assets or relations sent in one HTTP request to the streaming API.
	ChunkSize int

	// Max number of retries before giving up (default is 10)
	MaxRetries int
	// The base delay between retries (default is 5 seconds). This delay is multiplied by the backoff factor.
	RetryDelay time.Duration

	// The backoff factor (default is 1.01)
	RetryBackoffFactor float64

	// The API stores the lastly pushed graph in memory to avoid fetching the entire data at every run which can be heavy on
	// DB if importers run very incrementally. The anti entropy duration is a duration before forcing a synchronization against
	// the server even though the graph is still stored in memory.
	AntiEntropyDuration time.Duration
}

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

type GraphUpdateRequestBody struct {
	Updates *knowledge.GraphUpdatesBulk `json:"updates"`
	Schema  schema.SchemaGraph          `json:"schema"`
}

type PutGraphAssetRequestBody struct {
	Assets []knowledge.Asset `json:"assets"`
}

type PutGraphRelationRequestBody struct {
	Relations []knowledge.Relation `json:"relations"`
}

type PutGraphSchemaRequestBody struct {
	Schema schema.SchemaGraph `json:"schema"`
}

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