object

Documentation

Index

• func SerializeUploadUnit(u interface{}) ([]byte, error)
• type BindingConfigPart
• type ClazzUploadUnit
  • func DeserializeClazzUploadUnit(data []byte) (*ClazzUploadUnit, error)
• type DriverType
• type ExecuteConfig
  • func DefaultExecuteConfig() ExecuteConfig
  • func (config *ExecuteConfig) ToJson() (string, error)
  • func (config *ExecuteConfig) ToMap() (map[string]any, error)
• type FunctionContextUploadUnit
  • func DeserializeFuncCtxUploadUnit(data []byte) (*FunctionContextUploadUnit, error)
• type FunctionUploadUnit
  • func DeserializeFuncUploadUnit(data []byte) (*FunctionUploadUnit, error)
• type FunctionWithSignature
• type QueueConfigPart
• type QueueType
• type ServerConfigPart
• type ServerType
• type WorkerConfigPart
• type WorkspaceConfig
  • func (wc *WorkspaceConfig) Key() (string, error)
  • func (wc *WorkspaceConfig) Verify() error

Functions

func SerializeUploadUnit

func SerializeUploadUnit(u interface{}) ([]byte, error)

Types

type BindingConfigPart

type BindingConfigPart struct {
	// binding
	DbType        DriverType `mapstructure:"dbType"`
	Neo4jUri      string     `mapstructure:"neo4JUri"`
	Neo4jUserName string     `mapstructure:"neo4JUserName"`
	Neo4jPassword string     `mapstructure:"neo4JPassword"`
	BadgerPath    string     `mapstructure:"badgerPath"`
	TikvAddrs     string     `mapstructure:"tikvAddrs"`
}

type ClazzUploadUnit

type ClazzUploadUnit struct {
	WorkspaceConfig *WorkspaceConfig           `json:"workspace"`
	ClazzFileResult *extractor.ClazzFileResult `json:"clazzFileResult"`
}

func DeserializeClazzUploadUnit

func DeserializeClazzUploadUnit(data []byte) (*ClazzUploadUnit, error)

type DriverType

type DriverType = string

const (
	DriverTypeNeo4j    DriverType = "NEO4J"
	DriverTypeInMemory DriverType = "INMEM"
	DriverTypeBadger   DriverType = "BADGER"
	DriverTypeTikv     DriverType = "TIKV"

	FlagWcKeySplit = "|,,|"
)

type ExecuteConfig

type ExecuteConfig struct {
	*ServerConfigPart  `mapstructure:"server"`
	*BindingConfigPart `mapstructure:"binding"`
	*WorkerConfigPart  `mapstructure:"worker"`
	*QueueConfigPart   `mapstructure:"queue"`
}

func DefaultExecuteConfig

func DefaultExecuteConfig() ExecuteConfig

func (*ExecuteConfig) ToJson

func (config *ExecuteConfig) ToJson() (string, error)

func (*ExecuteConfig) ToMap

func (config *ExecuteConfig) ToMap() (map[string]any, error)

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 QueueConfigPart

type QueueConfigPart struct {
	// queue
	QueueType                 QueueType `mapstructure:"queueType"`
	KafkaAddrs                string    `mapstructure:"kafkaAddrs"`
	KafkaFuncTopic            string    `mapstructure:"kafkaFuncTopic"`
	KafkaFuncConsumerGroup    string    `mapstructure:"kafkaFuncConsumerGroup"`
	KafkaFuncCtxTopic         string    `mapstructure:"kafkaFuncCtxTopic"`
	KafkaFuncCtxConsumerGroup string    `mapstructure:"kafkaFuncCtxConsumerGroup"`
	KafkaClazzTopic           string    `mapstructure:"kafkaClazzTopic"`
	KafkaClazzConsumerGroup   string    `mapstructure:"kafkaClazzConsumerGroup"`
}

type QueueType

type QueueType = string

const QueueTypeKafka QueueType = "KAFKA"

const QueueTypeMemory QueueType = "MEMORY"

type ServerConfigPart

type ServerConfigPart struct {
	// server
	Port int        `mapstructure:"port"`
	Mode ServerType `mapstructure:"mode"`
}

type ServerType

type ServerType = string

const (
	ServerTypeAll     ServerType = "ALL"
	ServerTypeWorker  ServerType = "WORKER"
	ServerTypeGateway ServerType = "GATEWAY"
)

type WorkerConfigPart

type WorkerConfigPart struct {
	// worker
	WorkerCount     int `mapstructure:"workerCount"`
	WorkerQueueSize int `mapstructure:"workerQueueSize"`
}

type WorkspaceConfig

type WorkspaceConfig struct {
	RepoId  string `json:"repoId"`
	RevHash string `json:"revHash"`
}

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