Documentation
¶
Index ¶
Constants ¶
View Source
const FlagWcKeySplit = "|,,|"
Variables ¶
This section is empty.
Functions ¶
func SerializeUploadUnit ¶
Types ¶
type DriverType ¶
type DriverType string
const DtInMemory DriverType = "IN_MEMORY"
const DtNeo4j DriverType = "NEO4J"
type ExecuteConfig ¶
type ExecuteConfig struct {
Port int `json:"port"`
// binding
DbType DriverType `json:"dbType"`
Neo4jUri string `json:"neo4JUri"`
Neo4jUserName string `json:"neo4JUserName"`
Neo4jPassword string `json:"neo4JPassword"`
// worker
WorkerCount int `json:"workerCount"`
WorkerQueueSize int `json:"workerQueueSize"`
// queue
QueueType QueueType `json:"queueType"`
KafkaAddrs string `json:"kafkaAddrs"`
KafkaFuncTopic string `json:"kafkaFuncTopic"`
KafkaFuncConsumerGroup string `json:"kafkaFuncConsumerGroup"`
KafkaFuncCtxTopic string `json:"kafkaFuncCtxTopic"`
KafkaFuncCtxConsumerGroup string `json:"kafkaFuncCtxConsumerGroup"`
}
func DefaultExecuteConfig ¶
func DefaultExecuteConfig() ExecuteConfig
type FunctionContextUploadUnit ¶
type FunctionContextUploadUnit struct {
WorkspaceConfig *WorkspaceConfig `json:"workspace"`
FunctionContexts []*sibyl2.FunctionContext `json:"functionContext"`
}
func DeserializeFuncCtxUploadUnit ¶
func DeserializeFuncCtxUploadUnit(data []byte) (*FunctionContextUploadUnit, error)
type FunctionUploadUnit ¶
type FunctionUploadUnit struct {
WorkspaceConfig *WorkspaceConfig `json:"workspace"`
FunctionResult *extractor.FunctionFileResult `json:"funcResult"`
}
func DeserializeFuncUploadUnit ¶
func DeserializeFuncUploadUnit(data []byte) (*FunctionUploadUnit, error)
type FunctionWithSignature ¶
type FunctionWithSignature struct {
*sibyl2.FunctionWithPath
Signature string `json:"signature"`
}
type QueueType ¶
type QueueType = string
const QueueTypeKafka QueueType = "KAFKA"
const QueueTypeMemory QueueType = "MEMORY"
type WorkspaceConfig ¶
WorkspaceConfig
as an infra lib, it will not assume what kind of repo you used.
just two fields: - repoId: unique id of your repo, no matter git or svn, even appId. - revHash: unique id of your version.
func (*WorkspaceConfig) Key ¶
func (wc *WorkspaceConfig) Key() (string, error)
func (*WorkspaceConfig) Verify ¶
func (wc *WorkspaceConfig) Verify() error
Click to show internal directories.
Click to hide internal directories.