yakgrpc

package
v1.4.4-alpha1202-diff-... Latest Latest
Warning

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

 Go to latest Published: Dec 2, 2025 License: AGPL-3.0 Imports: 186 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	AnalyzeHTTPFlowSourceDatabase  = "database"
	AnalyzeHTTPFlowSourceRawPacket = "rawpacket"
)
View Source 
const (
	OneKB   = 1 * 1024
	EightKB = 8 * 1024
	FiftyKB = 50 * 1024
	OneMB   = 1 * 1024 * 1024 // 1 MB in bytes
	FiveMB  = 5 * 1024 * 1024 // 5 MB in bytes
)
View Source 
const (
	SPACE_ENGINE_ZOOMEYE = "zoomeye"
	SPACE_ENGINE_FOFA    = "fofa"
	SPACE_ENGINE_SHODAN  = "shodan"
	SPACE_ENGINE_HUNTER  = "hunter"
	SPACE_ENGINE_QUAKE   = "quake"

	SPACE_ENGINE_STATUS_NORMAL          = "normal"
	SPACE_ENGINE_STATUS_ERROR           = "error"
	SPACE_ENGINE_STATUS_INVALID_ACCOUNT = "invalid_account"
	SPACE_ENGINE_STATUS_EMPTY_KEY       = "empty_key"
	SPACE_ENGINE_STATUS_INVALID_TYPE    = "invalid_type"
)
View Source 
const (
	SUCCESS msgType = "success"
	WARNING msgType = "warning"
	ERROR   msgType = "error"
	INFO    msgType = "info"
	DATA    msgType = "data"
)
View Source 
const (
	COMPLETION = "completion"
	HOVER      = "hover"
	SIGNATURE  = "signature"
	DEFINITION = "definition"
	REFERENCES = "reference"
)
View Source 
const (
	KEY_ProgressManager     = "JznQXuFDSepeNWHbiLGEwONiaBxhvj_PROGRESS_MANAGER"
	KEY_SimpleDetectManager = "JznQXuFDSepeNWHbiLGEwONiaBxhvj_SIMPLE_DETECT_MANAGER"
)
View Source 
const (
	DbOperationCreate         = "create"
	DbOperationDelete         = "delete"
	DbOperationUpdate         = "update"
	DbOperationQuery          = "query"
	DbOperationCreateOrUpdate = "create_or_update"
)
View Source 
const EXECUTEPACKET_CODE = `` /* 1081-byte string literal not displayed */
View Source 
const (
	MAX_PHI_LEVEL = 5
)
View Source 
const PORTSCAN_PLUGIN_TRIGGER_CODE = `` /* 1260-byte string literal not displayed */
View Source 
const (
	YAK_ENGINE_DEFAULT_SCAN_PROXY = "YAK_ENGINE_DEFAULT_SCAN_PROXY"
)

Variables

View Source 
var (
	Triage_Event_Log        string = "triage_log"
	Triage_Event_Forge_List string = "triage_forge_list"
	Triage_Event_Finish     string = "triage_finish"
)
View Source 
var (
	DatabaseNameProject = "Project"
	DatabaseNameProfile = "Profile"
	DatabaseNameSSA     = "SSA"
)
View Source 
var (
	Action_Retain  = "retain"
	Action_Discard = "discard"
)
View Source 
var (
	CompletionKindField    = "Field"
	CompletionKindKeyword  = "Keyword"
	CompletionKindConstant = "Constant"
	CompletionKindVariable = "Variable"
	CompletionKindFunction = "Function"
	CompletionKindMethod   = "Method"
	CompletionKindClass    = "Class"
	CompletionKindModule   = "Module"
)
View Source 
var (
	Hijack_List_Add    = "add"
	Hijack_List_Delete = "delete"
	Hijack_List_Update = "update"
	Hijack_List_Reload = "reload"
)
View Source 
var (
	Hijack_Status_Request  = "hijacking request"
	Hijack_Status_Response = "hijacking response"
	Hijack_Status_Waiting  = "wait hijack"
	Hijack_Status_WS       = "hijacking ws"
)
View Source 
var BatchPoCTemplate, _ = template.New("BatchPoCTemplate").Parse(`

isHttps = cli.Have("https", cli.setDefault({{ .https }}))
target = cli.String("target", cli.setDefault("{{ .target }}"))
concurrent = cli.Int("concurrent", cli.setDefault(10))

packet = ` + "`" + `{{ .packetTemplate }}` + "`" + `

debug = cli.Have("debug", cli.setDefault(true))

if debug {
    loglevel("debug")
}

batchPacket = func(target) {
    return httpool.Pool(
        packet, 
        # httpool.proxy("http://127.0.0.1:8083"),
        # httpool.proxy("http://127.0.0.1:7890"),
        httpool.rawMode(true),
        httpool.size(concurrent), 
        httpool.redirectTimes(5),
        httpool.perRequestTimeout(10),
        httpool.fuzz(true),
        httpool.fuzzParams({
            "target": target,
        }),
    )
}

if YAK_MAIN {
    res, err = batchPacket(target)
    if err != nil {
        log.error("send packet error: %s", err)
        return
    }

    for result = range res {

        if result.Error != nil {
            yakit.Error("Request[%v] Payload: %v Failed: %v", result.Url, result.Payloads, result.Error)
            continue
        }

        yakit.Info("[%v] Request Result Received! payloads: %v", result.Url, result.Payloads)

        reqBytes := result.RequestRaw
        rspBytes := result.ResponseRaw

        if debug {
            println(string(reqBytes))
            println("---------------------------------")
            println(string(rspBytes))
        }

        // 处理结果
        riskTarget = target
        if str.MatchAllOfRegexp(rspBytes, ` + "`" + `(?i)foundtextinRsp!` + "`" + `) || str.MatchAllOfSubString(rspBytes, "FoundTextInResponse") {
            urlIns, _ = str.ExtractURLFromHTTPRequestRaw(reqBytes, isHttps)
            if urlIns == nil {
                riskTarget = urlIns.String()
            }
            yakit.Info("Matched for %v", target)
            # Save to RiskTable
            risk.NewRisk(
                riskTarget, risk.severity("high"), risk.type("poc"),
                risk.title("English Title"),            ## English Title for Risk
                risk.titleVerbose("中文标题"),           ##  中文标题
                risk.details({
                    "target": riskTarget,
                    "request": reqBytes,
                    "response": rspBytes,
                }),
            )
        }
    }
}

/*
type palm/common/mutate.(_httpResult) struct {
  Fields(可用字段): 
      Url: string  
      Request: *http.Request  
      Error: error  
      RequestRaw: []uint8  
      ResponseRaw: []uint8  
      Response: *http.Response  
      DurationMs: int64  
      Timestamp: int64  
      Payloads: []string  
  StructMethods(结构方法/函数): 
  PtrStructMethods(指针结构方法/函数): 
}
*/


`)
View Source 
var BuildInBruteTypeTree = GetBuildinAvailableBruteTypeTree(bruteutils.AuthFunctionMap)
View Source 
var CallHookMap = sync.Map{}
View Source 
var CtrlCBytes = []byte("^C")
View Source 
var OrdinaryPoCTemplate, _ = template.New("OrdinaryPoCTemplate").Parse(`
isHttps = cli.Have("https", cli.setDefault({{ .https }}))
target = cli.String("target", cli.setDefault("{{ .target }}"))

packet = ` + "`" + `
{{ .packetTemplate }}` + "`" + `

debug = cli.Have("debug", cli.setDefault(true))

if debug {
    loglevel("debug")
}

sendPacket = func(target) {
    return poc.HTTP(
        packet, 
        poc.timeout(10),
        # poc.proxy("http://127.0.0.1:8083"),
        # poc.proxy("http://127.0.0.1:7890"),
        poc.redirectTimes(3),  # 重定向次数
        poc.https(isHttps),
        poc.params({
            "target": target,
        },
    ))
}

if YAK_MAIN {
    rspBytes, reqBytes, err = sendPacket(target)
    if err != nil {
        log.error("send packet error: %s", err)
        return
    }

    if debug {
        println(string(reqBytes))
        println("---------------------------------")
        println(string(rspBytes))
    }

    riskTarget = target
    if str.MatchAllOfRegexp(rspBytes, ` + "`" + `(?i)foundtextinRsp!` + "`" + `) || str.MatchAllOfSubString(rspBytes, "FoundTextInResponse") {
        urlIns, _ = str.ExtractURLFromHTTPRequestRaw(reqBytes, isHttps)
        if urlIns == nil {
            riskTarget = urlIns.String()
        }
        yakit.Info("Matched for %v", target)
        # Save to RiskTable
        risk.NewRisk(
            riskTarget, risk.severity("high"), risk.type("poc"),
            risk.title("English Title"),            ## English Title for Risk
            risk.titleVerbose("中文标题"),           ##  中文标题
            risk.details({
                "target": riskTarget,
                "request": reqBytes,
                "response": rspBytes,
            }),
        )
    }
}
















`)
View Source 
var (
	OriginRiskStats *ypb.RiskTableStats
)
View Source 
var RedirectForge = "redirect_forge"
View Source 
var USER_CUSTOM_LOCAL_MODEL_KEY = "USER_CUSTOM_LOCAL_MODEL"
View Source 
var VerifySystemCertificateCD = utils.NewCoolDown(10 * time.Second)
View Source 
var YakitAllTables = schema.ProjectTables
View Source 
var YakitProfileTables = schema.ProfileTables

Functions

func AddExecBatchTask added in v1.3.3 

func AddExecBatchTask(runtimeId string, percent float64, yakScriptOnlineGroup, taskName string, req *ypb.ExecBatchYakScriptRequest)

func AddSimpleDetectTask added in v1.3.3 

func AddSimpleDetectTask(runtimeId string, req *ypb.RecordPortScanRequest)

func AfterAndBeforeIsExit added in v1.2.2 

func AfterAndBeforeIsExit(id int64) (before, after bool)

func AvailableRiskIP 

func AvailableRiskIP(db *gorm.DB) ([]*ypb.FieldGroup, error)

func AvailableRiskLevel 

func AvailableRiskLevel(db *gorm.DB) (map[string]*ypb.FieldName, error)

func AvailableRiskType 

func AvailableRiskType(db *gorm.DB) (map[string]*ypb.FieldName, error)

func BuildHttpRequestPacket added in v1.3.2 

func BuildHttpRequestPacket(db *gorm.DB, baseBuilderParams *ypb.HTTPRequestBuilderParams, targetInput string) (chan *HTTPRequestBuilderRes, error)

func BuildPluginTestingJunkData 

func BuildPluginTestingJunkData() []byte

func Chardet 

func Chardet(raw []byte) string

func CheckDefault 

func CheckDefault(ProjectName, Type string, FolderId, ChildFolderId int64) bool

func CheckShouldDiscard 

func CheckShouldDiscard(action string, matchRes bool) bool

func CompareParameter added in v1.3.0 

func CompareParameter(p1, p2 *ypb.YakScriptParam) bool

CompareParameter p1 and p2 all field if return true, p2 information is more than p1

func ConvertLowhttpResponseToFuzzerResponseBase added in v1.2.4 

func ConvertLowhttpResponseToFuzzerResponseBase(r *lowhttp.LowhttpResponse) *ypb.FuzzerResponse

func ConvertYPBAIStartParamsToReActConfig 

func ConvertYPBAIStartParamsToReActConfig(i *ypb.AIStartParams) []aicommon.ConfigOption

func ConvertYakScriptToExecRequest 

func ConvertYakScriptToExecRequest(req *ypb.ExecRequest, script *schema.YakScript, batchMode bool) (*ypb.ExecRequest, []func(), error)

func DeleteBatchYakScriptRequestByRuntimeId added in v1.3.3 

func DeleteBatchYakScriptRequestByRuntimeId(db *gorm.DB, runtimeId string) (*ypb.ExecBatchYakScriptRequest, error)

func DeleteSimpleDetectUnfinishedTaskByUid added in v1.3.3 

func DeleteSimpleDetectUnfinishedTaskByUid(db *gorm.DB, runtimeId string) (*ypb.RecordPortScanRequest, error)

func ExecScriptWithParam 

func ExecScriptWithParam(
	ctx context.Context,
	pluginName string,
	para map[string]string,
	input string,
	handler func(result *ypb.ExecResult) error,
) error

func ExtractAndReplaceFuzzTagFromStrings 

func ExtractAndReplaceFuzzTagFromStrings(s string, index int) (replaced string, varToFuzztagMap map[string]string)

func FieldGroup2FiledGroupName 

func FieldGroup2FiledGroupName(fgs []*ypb.FieldGroup, verbose func(string) string) []*ypb.FieldName

func FilterDataToMatchers 

func FilterDataToMatchers(data []*ypb.FilterDataItem) *httptpl.YakMatcher

func FuzztagServer 

func FuzztagServer(req *ypb.YaklangLanguageSuggestionRequest) (*ypb.YaklangLanguageSuggestionResponse, bool)

func GRPCYakScriptToYakitScript 

func GRPCYakScriptToYakitScript(script *ypb.YakScript) *schema.YakScript

func GenerateYsoPayload added in v1.3.2 

func GenerateYsoPayload(req *ypb.YsoOptionsRequerstWithVerbose) (string, func(opts ...yso.MarshalOptionFun) ([]byte, error), error)

GenerateYsoPayload a utils for generate yso payload, return value is: token(className),Gadget or Class Instance,payload toByte fun,error

func GetBatchYakScriptRequestByRuntimeId added in v1.3.3 

func GetBatchYakScriptRequestByRuntimeId(db *gorm.DB, runtimeId string) (*ypb.ExecBatchYakScriptRequest, error)

func GetBuildinAvailableBruteTypeTree added in v1.3.2 

func GetBuildinAvailableBruteTypeTree(typeMap []struct {
	Name string
	Data string
}) []*ypb.Tree

func GetPayloadFile 

func GetPayloadFile(ctx context.Context, fileName string) ([]byte, bool, error)

func GetSimpleDetectUnfinishedTaskByUid added in v1.3.3 

func GetSimpleDetectUnfinishedTaskByUid(db *gorm.DB, runtimeId string) (*ypb.RecordPortScanRequest, error)

func GrpcRangeToSSARange added in v1.3.3 

func GrpcRangeToSSARange(sourceCode string, r *ypb.Range) *memedit.Range

func IsContain 

func IsContain(items []*ypb.MenuItemGroup, item string) bool

func IsContainNavigation added in v1.2.3 

func IsContainNavigation(items []*ypb.NavigationList, item string) bool

func IsExtOption added in v1.3.2 

func IsExtOption(key string) bool

func IsValueInSortedSlice added in v1.2.2 

func IsValueInSortedSlice(value string, slice []string) bool

func KVPairToParamItem added in v1.3.2 

func KVPairToParamItem(params []*ypb.KVPair) []*ypb.ExecParamItem

func KnowledgeBaseEntryListToGrpcModel 

func KnowledgeBaseEntryListToGrpcModel(entries []*schema.KnowledgeBaseEntry) []*ypb.KnowledgeBaseEntry

func KnowledgeBaseEntryToGrpcModel 

func KnowledgeBaseEntryToGrpcModel(entry *schema.KnowledgeBaseEntry) *ypb.KnowledgeBaseEntry

func LegacyFilter2FilterMatcherData 

func LegacyFilter2FilterMatcherData(m *MITMFilterManager) *ypb.MITMFilterData

func LegacyGRPCSaveNewYakScriptRequestGetYakScript 

func LegacyGRPCSaveNewYakScriptRequestGetYakScript(request *ypb.SaveNewYakScriptRequest) *ypb.YakScript

func MarshalYakTemplateToYaml added in v1.2.7 

func MarshalYakTemplateToYaml(y *httptpl.YakTemplate) (string, error)

func MatchColor 

func MatchColor(m []*YakFuzzerMatcher, rsp *httptpl.RespForMatch, vars map[string]interface{}, suf ...string) (matched bool, hitColor []string, discard bool)

func MockPluginTestingFpResult 

func MockPluginTestingFpResult(testDomain string, pluginTestingServer *PluginTestingEchoServer) *fp.MatchResult

func NewFakeStream added in v1.2.3 

func NewFakeStream(ctx context.Context, handler func(result *ypb.ExecResult) error) *fakeStreamInstance

func NewFuzzerSequenceFlow added in v1.2.4 

func NewFuzzerSequenceFlow(request *ypb.FuzzerRequest) *fuzzerSequenceFlow

func NewGrpcProgressCallback 

func NewGrpcProgressCallback(stream ypb.Yak_InstallThirdPartyBinaryServer) thirdparty_bin.ProgressCallback

func NewLocalClient added in v1.2.8 

func NewLocalClient(locals ...bool) (ypb.YakClient, error)

func NewLocalClientForceNew 

func NewLocalClientForceNew() (ypb.YakClient, error)

func NewLocalClientWithTempDatabase 

func NewLocalClientWithTempDatabase(t *testing.T) (ypb.YakClient, error)

func NewPagingFromGRPCModel 

func NewPagingFromGRPCModel(pag *ypb.Paging) *yakit.Paging

func NewRiskGRPCModel 

func NewRiskGRPCModel(p *schema.Risk) *ypb.NewRisk

func OnCompletion added in v1.2.9 

func OnCompletion(
	prog *ssaapi.Program, word string, containPoint bool, pointSuffix bool,
	rng *memedit.Range, scriptType string, v *ssaapi.Value,
) (ret []*ypb.SuggestionDescription)

func OnFindDefinition added in v1.3.3 

func OnFindDefinition(prog *ssaapi.Program, word string, containPoint bool, ssaRange *memedit.Range, v *ssaapi.Value) []*memedit.Range

func OnFindReferences added in v1.3.3 

func OnFindReferences(prog *ssaapi.Program, word string, containPoint bool, ssaRange *memedit.Range, v *ssaapi.Value) []*memedit.Range

func OnHover added in v1.2.9 

func OnHover(prog *ssaapi.Program, word string, containPoint bool, rng *memedit.Range, v *ssaapi.Value) (ret []*ypb.SuggestionDescription)

func OnSignature added in v1.2.9 

func OnSignature(prog *ssaapi.Program, word string, containPoint bool, rng *memedit.Range, v *ssaapi.Value) (ret []*ypb.SuggestionDescription)

func ParamItemToKVPair added in v1.3.2 

func ParamItemToKVPair(params []*ypb.ExecParamItem) []*ypb.KVPair

func ParseReassembledTraffic added in v1.3.0 

func ParseReassembledTraffic(data []byte) ([]any, error)

func ParseTraffic added in v1.3.0 

func ParseTraffic(data []byte, rule string) ([]any, error)

func PortsServiceTypeGroup added in v1.2.2 

func PortsServiceTypeGroup(data []*yakit.PortsTypeGroup) ypb.QueryPortsGroupResponse

func QueryYakScriptByNames 

func QueryYakScriptByNames(db *gorm.DB, req []string) []*ypb.DownloadOnlinePluginByScriptName

func RangeIfToGrpcRange added in v1.3.3 

func RangeIfToGrpcRange(rng *memedit.Range) *ypb.Range

func RegisterMockAIChat 

func RegisterMockAIChat(c aiChatType)

func RegisterVulinboxAgent added in v1.2.3 

func RegisterVulinboxAgent(addr string, agent *VulinboxAgentFacade)

func RemoveHybridTask added in v1.2.9 

func RemoveHybridTask(id string)

func ReplaceString 

func ReplaceString(s string) string

func SSAProjectToGRPCModel 

func SSAProjectToGRPCModel(p *schema.SSAProject) *ypb.SSAProject

func SaveFromYakitLog 

func SaveFromYakitLog(l *yaklib.YakitLog, db *gorm.DB)

func ScanHybridTargetWithPlugin added in v1.3.2 

func ScanHybridTargetWithPlugin(
	runtimeId string, ctx context.Context, target *HybridScanTarget, plugin *schema.YakScript, proxy string, feedbackClient *yaklib.YakitClient, callerFilter filter.Filterable,
) error

func SetFuzzerRespTraceInfo 

func SetFuzzerRespTraceInfo(resp *ypb.FuzzerResponse, traceInfo *lowhttp.LowhttpTraceInfo)

func SyntaxFlowServer 

func SyntaxFlowServer(req *ypb.YaklangLanguageSuggestionRequest) (*ypb.YaklangLanguageSuggestionResponse, bool)

func TargetGenerator added in v1.3.2 

func TargetGenerator(ctx context.Context, db *gorm.DB, targetConfig *ypb.HybridScanInputTarget) (chan *HybridScanTarget, error)

func ToGrpcPort 

func ToGrpcPort(r *schema.Port) *ypb.Port

func WatchDatabaseTableMeta added in v1.3.2 

func WatchDatabaseTableMeta(db *gorm.DB, last int64, streamCtx context.Context, tableName string) (_ int64, changed bool)

Types

type AnalyzeHTTPFlowSource 

type AnalyzeHTTPFlowSource string
type BuildInVectorDBLink struct {
	Description string
	DownloadURL string
}

type Client 

type Client struct {
	ypb.YakClient
	// contains filtered or unexported fields
}

func (*Client) GetProfileDatabase 

func (c *Client) GetProfileDatabase() *gorm.DB

func (*Client) GetProjectDatabase 

func (c *Client) GetProjectDatabase() *gorm.DB

type CustomLocalModel 

type CustomLocalModel struct {
	Name        string `json:"name"`
	ModelType   string `json:"model_type"`
	Description string `json:"description"`
	Path        string `json:"path"`
}

CustomLocalModel 自定义本地模型结构

type DownloadStream added in v1.2.3 

type DownloadStream interface {
	Send(result *ypb.ExecResult) error
	grpc.ServerStream
}

type FilterMatcher 

type FilterMatcher struct {
	IncludeSuffixMatcher *httptpl.YakMatcher
	ExcludeSuffixMatcher *httptpl.YakMatcher

	IncludeHostnamesMatcher *httptpl.YakMatcher
	ExcludeHostnamesMatcher *httptpl.YakMatcher

	IncludeUriMatcher *httptpl.YakMatcher
	ExcludeUriMatcher *httptpl.YakMatcher

	ExcludeMethodsMatcher *httptpl.YakMatcher
	ExcludeMIMEMatcher    *httptpl.YakMatcher
}

type GrpcStreamWriter 

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

func NewGrpcStreamWriter 

func NewGrpcStreamWriter(stream grpc.ServerStreamingServer[ypb.ExecResult]) *GrpcStreamWriter

func (*GrpcStreamWriter) Close 

func (s *GrpcStreamWriter) Close() (err error)

func (*GrpcStreamWriter) Write 

func (s *GrpcStreamWriter) Write(b []byte) (int, error)

type HTTPFlowAnalyzeManger 

type HTTPFlowAnalyzeManger struct {
	*yakit.MitmReplacer
	// contains filtered or unexported fields
}

func NewHTTPFlowAnalyzeManger 

func NewHTTPFlowAnalyzeManger(
	MITMReplacerConfigDb *gorm.DB,
	ctx context.Context,
	analyzeId string,
	client *yaklib.YakitClient,
	stream HTTPFlowAnalyzeRequestStream,
	opts ...HTTPFlowAnalyzeMangerOption,
) (*HTTPFlowAnalyzeManger, error)

func (*HTTPFlowAnalyzeManger) AnalyzeHTTPFlow 

func (m *HTTPFlowAnalyzeManger) AnalyzeHTTPFlow(db *gorm.DB) (errs error)

func (*HTTPFlowAnalyzeManger) AnalyzeHTTPFlowFromDb 

func (m *HTTPFlowAnalyzeManger) AnalyzeHTTPFlowFromDb(db *gorm.DB)

func (*HTTPFlowAnalyzeManger) AnalyzeHTTPFlowFromRawPacket 

func (m *HTTPFlowAnalyzeManger) AnalyzeHTTPFlowFromRawPacket(db *gorm.DB) error

func (*HTTPFlowAnalyzeManger) ExecHotPatch 

func (m *HTTPFlowAnalyzeManger) ExecHotPatch(db *gorm.DB, flow *schema.HTTPFlow)

func (*HTTPFlowAnalyzeManger) ExecReplacerRule 

func (m *HTTPFlowAnalyzeManger) ExecReplacerRule(db *gorm.DB, flow *schema.HTTPFlow) error

func (*HTTPFlowAnalyzeManger) OnFinish 

func (m *HTTPFlowAnalyzeManger) OnFinish()

type HTTPFlowAnalyzeMangerOption 

type HTTPFlowAnalyzeMangerOption func(*HTTPFlowAnalyzeManger)

func WithConcurrency 

func WithConcurrency(concurrency int) HTTPFlowAnalyzeMangerOption

func WithDataSource 

func WithDataSource(source *ypb.AnalyzedDataSource) HTTPFlowAnalyzeMangerOption

func WithDedup 

func WithDedup(dedup bool) HTTPFlowAnalyzeMangerOption

func WithMatchers 

func WithMatchers(matchers []*ypb.HTTPResponseMatcher) HTTPFlowAnalyzeMangerOption

func WithRules 

func WithRules(rules ...*ypb.MITMContentReplacer) HTTPFlowAnalyzeMangerOption

type HTTPFlowAnalyzeRequestStream 

type HTTPFlowAnalyzeRequestStream interface {
	Send(response *ypb.AnalyzeHTTPFlowResponse) error
	Context() context.Context
}

type HTTPFlowShare added in v1.3.3 

type HTTPFlowShare struct {
	*schema.HTTPFlow
	ExtractedList         []*schema.ExtractedData
	WebsocketFlowsList    []*schema.WebsocketFlow
	ProjectGeneralStorage []*schema.ProjectGeneralStorage
}

type HTTPRequestBuilderRes added in v1.3.2 

type HTTPRequestBuilderRes struct {
	IsHttps bool
	Request []byte
	Url     string
}

type HybridScanRequestStream added in v1.2.9 

type HybridScanRequestStream interface {
	Send(response *ypb.HybridScanResponse) error
	Recv() (*ypb.HybridScanRequest, error)
	Context() context.Context
}

type HybridScanStatusManager added in v1.2.9 

type HybridScanStatusManager struct {
	// 任务的总量
	TargetTotal    int64
	PluginTotal    int64
	TotalTaskCount int64

	// 完成的任务
	TargetFinished int64
	TaskFinished   int64

	// dynamic
	ActiveTask    int64
	ActiveTarget  int64
	ActiveTaskMap *sync.Map

	TaskId string

	// Task 计数器，作为索引
	TaskCount int64

	// 任务状态
	Status string

	ManagerMutex *sync.Mutex
	// contains filtered or unexported fields
}

func (*HybridScanStatusManager) DoActiveTarget added in v1.2.9 

func (h *HybridScanStatusManager) DoActiveTarget() int64

func (*HybridScanStatusManager) DoActiveTask added in v1.2.9 

func (h *HybridScanStatusManager) DoActiveTask(task ...*schema.HybridScanTask) int64

DoActiveTask returns index of task

func (*HybridScanStatusManager) DoneFailureTarget 

func (h *HybridScanStatusManager) DoneFailureTarget()

func (*HybridScanStatusManager) DoneTarget added in v1.2.9 

func (h *HybridScanStatusManager) DoneTarget()

func (*HybridScanStatusManager) DoneTask added in v1.2.9 

func (h *HybridScanStatusManager) DoneTask(index int64, task ...*schema.HybridScanTask)

func (*HybridScanStatusManager) Feedback added in v1.2.9 

func (h *HybridScanStatusManager) Feedback(stream HybridScanRequestStream) error

func (*HybridScanStatusManager) GetCurrentActiveTaskIndexes added in v1.2.9 

func (h *HybridScanStatusManager) GetCurrentActiveTaskIndexes() []string

func (*HybridScanStatusManager) GetStatus added in v1.2.9 

func (h *HybridScanStatusManager) GetStatus(r ...*schema.HybridScanTask) *ypb.HybridScanResponse

func (*HybridScanStatusManager) PushActiveTask added in v1.2.9 

func (h *HybridScanStatusManager) PushActiveTask(index int64, t *HybridScanTarget, pluginName string, stream HybridScanRequestStream)

func (*HybridScanStatusManager) RemoveActiveTask added in v1.2.9 

func (h *HybridScanStatusManager) RemoveActiveTask(index int64, t *HybridScanTarget, pluginName string, stream HybridScanRequestStream)

func (*HybridScanStatusManager) SetCurrentTaskIndex added in v1.2.9 

func (h *HybridScanStatusManager) SetCurrentTaskIndex(i int64)

type HybridScanTarget added in v1.2.9 

type HybridScanTarget struct {
	IsHttps  bool
	Request  []byte
	Response []byte
	Url      string
	Vars     map[string]any
}

type HybridScanTaskManager added in v1.2.9 

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

func CreateHybridTask added in v1.2.9 

func CreateHybridTask(id string, ctx context.Context) (*HybridScanTaskManager, error)

func GetHybridTask added in v1.2.9 

func GetHybridTask(id string) (*HybridScanTaskManager, error)

func (*HybridScanTaskManager) Checkpoint added in v1.2.9 

func (h *HybridScanTaskManager) Checkpoint(hs ...func())

func (*HybridScanTaskManager) Context added in v1.2.9 

func (h *HybridScanTaskManager) Context() context.Context

func (*HybridScanTaskManager) IsPaused added in v1.2.9 

func (h *HybridScanTaskManager) IsPaused() bool

func (*HybridScanTaskManager) IsStop added in v1.3.2 

func (h *HybridScanTaskManager) IsStop() bool

func (*HybridScanTaskManager) Pause added in v1.2.9 

func (h *HybridScanTaskManager) Pause()

func (*HybridScanTaskManager) PauseEffect added in v1.2.9 

func (h *HybridScanTaskManager) PauseEffect()

func (*HybridScanTaskManager) Resume added in v1.2.9 

func (h *HybridScanTaskManager) Resume()

func (*HybridScanTaskManager) Stop added in v1.2.9 

func (h *HybridScanTaskManager) Stop()

func (*HybridScanTaskManager) TaskId added in v1.2.9 

func (h *HybridScanTaskManager) TaskId() string

func (*HybridScanTaskManager) WaitCount added in v1.2.9 

func (h *HybridScanTaskManager) WaitCount() int64

type JavaBytesCodeType 

type JavaBytesCodeType string

type JavaClassGeneraterOption 

type JavaClassGeneraterOption string
const (
	JavaClassGeneraterOption_ClassName     JavaClassGeneraterOption = "className"
	JavaClassGeneraterOption_IsObfuscation JavaClassGeneraterOption = "isObfuscation"
	JavaClassGeneraterOption_Version       JavaClassGeneraterOption = "version"
	JavaClassGeneraterOption_DirtyData     JavaClassGeneraterOption = "dirtyData"
	JavaClassGeneraterOption_twoByteChar   JavaClassGeneraterOption = "two byte char"
)

type JavaClassGeneraterOptionTypeVerbose 

type JavaClassGeneraterOptionTypeVerbose string
const (
	String      JavaClassGeneraterOptionTypeVerbose = "String"
	Base64Bytes JavaClassGeneraterOptionTypeVerbose = "Base64Bytes"
	StringBool  JavaClassGeneraterOptionTypeVerbose = "StringBool"
	StringPort  JavaClassGeneraterOptionTypeVerbose = "StringPort"
)

type LanguageServerAnalyzerResult added in v1.3.3 

type LanguageServerAnalyzerResult struct {
	Program      *ssaapi.Program
	Range        *memedit.Range
	Value        *ssaapi.Value
	Editor       *memedit.MemEditor
	Word         string
	ContainPoint bool
	PointSuffix  bool
}

func LanguageServerAnalyzeProgram added in v1.3.3 

func LanguageServerAnalyzeProgram(req *ypb.YaklangLanguageSuggestionRequest) (*LanguageServerAnalyzerResult, error)

func (*LanguageServerAnalyzerResult) Clone 

func (r *LanguageServerAnalyzerResult) Clone() *LanguageServerAnalyzerResult

type MITMFilter 

type MITMFilter struct {
	Data    *ypb.MITMFilterData
	Filters *FilterMatcher
	// contains filtered or unexported fields
}

func GetMITMFilterManager 

func GetMITMFilterManager(projectDB, profileDB *gorm.DB) *MITMFilter

func GetMITMHijackFilterManager 

func GetMITMHijackFilterManager(projectDB *gorm.DB) *MITMFilter

func NewMITMFilter 

func NewMITMFilter(data *ypb.MITMFilterData) *MITMFilter

func (*MITMFilter) IsEmpty 

func (m *MITMFilter) IsEmpty() bool

func (*MITMFilter) IsMIMEPassed 

func (m *MITMFilter) IsMIMEPassed(ct string) bool

func (*MITMFilter) IsPassed 

func (m *MITMFilter) IsPassed(method string, hostport, urlStr string, ext string) bool

IsPassed return true if passed, false if filtered out

func (*MITMFilter) Recover 

func (m *MITMFilter) Recover()

func (*MITMFilter) RecoverHijackFIlter 

func (m *MITMFilter) RecoverHijackFIlter()

func (*MITMFilter) Save 

func (m *MITMFilter) Save(keys ...string)

func (*MITMFilter) SaveToDb 

func (m *MITMFilter) SaveToDb(keys ...string) error

func (*MITMFilter) Update 

func (m *MITMFilter) Update(data *ypb.MITMFilterData)

type MITMFilterManager 

type MITMFilterManager struct {
	IncludeHostnames []string `json:"includeHostnames"`
	ExcludeHostnames []string `json:"excludeHostnames"`

	IncludeSuffix []string `json:"includeSuffix"`
	ExcludeSuffix []string `json:"excludeSuffix"`

	IncludeUri []string `json:"includeUri"`
	ExcludeUri []string `json:"excludeUri"`

	ExcludeMethods []string `json:"excludeMethods"`
	ExcludeMIME    []string `json:"excludeMIME"`
	// contains filtered or unexported fields
}

type OpenPortServerStreamerHelperRWC 

type OpenPortServerStreamerHelperRWC struct {
	io.ReadWriteCloser

	LocalAddr  string
	RemoveAddr string
	// contains filtered or unexported fields
}

OpenPortServerStreamerHelperRWC

func (*OpenPortServerStreamerHelperRWC) Close 

func (s *OpenPortServerStreamerHelperRWC) Close() (err error)

func (*OpenPortServerStreamerHelperRWC) Read 

func (c *OpenPortServerStreamerHelperRWC) Read(b []byte) (n int, _ error)

func (*OpenPortServerStreamerHelperRWC) Write 

func (s *OpenPortServerStreamerHelperRWC) Write(b []byte) (int, error)

type PluginTestingEchoServer 

type PluginTestingEchoServer struct {
	Host                string
	Port                int
	RequestsHistory     []byte
	RequestHistoryMutex *sync.Mutex
	RawHeader           []byte

	JunkData []byte
	Ctx      context.Context
}

func NewPluginTestingEchoServer 

func NewPluginTestingEchoServer(ctx context.Context) *PluginTestingEchoServer

func (*PluginTestingEchoServer) ClearRequestsHistory 

func (s *PluginTestingEchoServer) ClearRequestsHistory()

type ProgressStream 

type ProgressStream interface {
	Send(*ypb.SyntaxFlowRuleOnlineProgress) error
}

type SSARiskDiffRequestStream 

type SSARiskDiffRequestStream interface {
	Send(response *ypb.SSARiskDiffResponse) error
	Context() context.Context
}

type Server 

type Server struct {
	ypb.YakServer
	// contains filtered or unexported fields
}

func NewServer 

func NewServer(opts ...ServerOpts) (*Server, error)

func NewServerWithLogCache added in v1.2.2 

func NewServerWithLogCache(opts ...ServerOpts) (*Server, error)

func NewTestServer added in v1.3.3 

func NewTestServer() (*Server, error)

func (*Server) AIToolGenerateMetadata 

func (s *Server) AIToolGenerateMetadata(ctx context.Context, req *ypb.AIToolGenerateMetadataRequest) (*ypb.AIToolGenerateMetadataResponse, error)

func (*Server) AddLocalModel 

func (s *Server) AddLocalModel(ctx context.Context, req *ypb.AddLocalModelRequest) (*ypb.GeneralResponse, error)

func (*Server) AddMCPServer 

func (s *Server) AddMCPServer(ctx context.Context, req *ypb.AddMCPServerRequest) (*ypb.GeneralResponse, error)

AddMCPServer 添加MCP服务器

func (*Server) AddMenus 

func (s *Server) AddMenus(ctx context.Context, req *ypb.AddMenuRequest) (*ypb.Empty, error)

func (*Server) AddOneNavigation added in v1.2.3 

func (s *Server) AddOneNavigation(ctx context.Context, req *ypb.AddOneNavigationRequest) (*ypb.Empty, error)

func (*Server) AddToMenu 

func (s *Server) AddToMenu(ctx context.Context, req *ypb.AddToMenuRequest) (*ypb.Empty, error)

func (*Server) AddToNavigation added in v1.2.3 

func (s *Server) AddToNavigation(ctx context.Context, req *ypb.AddToNavigationRequest) (*ypb.Empty, error)

func (*Server) AnalyzeHTTPFlow 

func (s *Server) AnalyzeHTTPFlow(request *ypb.AnalyzeHTTPFlowRequest, stream ypb.Yak_AnalyzeHTTPFlowServer) error

func (*Server) ApplyClassToFacades 

func (s *Server) ApplyClassToFacades(ctx context.Context, req *ypb.ApplyClassToFacadesParamsWithVerbose) (*ypb.Empty, error)

func (*Server) ApplySyntaxFlowRuleUpdate 

func (s *Server) ApplySyntaxFlowRuleUpdate(req *ypb.ApplySyntaxFlowRuleUpdateRequest, stream ypb.Yak_ApplySyntaxFlowRuleUpdateServer) error

func (*Server) AttachCombinedOutput 

func (s *Server) AttachCombinedOutput(req *ypb.AttachCombinedOutputRequest, server ypb.Yak_AttachCombinedOutputServer) error

func (*Server) AutoDecode 

func (s *Server) AutoDecode(ctx context.Context, req *ypb.AutoDecodeRequest) (*ypb.AutoDecodeResponse, error)

func (*Server) AutoUpdateYakModule 

func (s *Server) AutoUpdateYakModule(_ *ypb.Empty, stream ypb.Yak_AutoUpdateYakModuleServer) error

func (*Server) AvailableLocalAddr 

func (s *Server) AvailableLocalAddr(ctx context.Context, empty *ypb.Empty) (*ypb.AvailableLocalAddrResponse, error)

func (*Server) BackUpOrCopyPayloads added in v1.2.9 

func (s *Server) BackUpOrCopyPayloads(ctx context.Context, req *ypb.BackUpOrCopyPayloadsRequest) (*ypb.Empty, error)

func (*Server) BatchUpdateFingerprintToGroup 

func (s *Server) BatchUpdateFingerprintToGroup(ctx context.Context, req *ypb.BatchUpdateFingerprintToGroupRequest) (*ypb.DbOperateMessage, error)

func (*Server) BuildVectorIndexForKnowledgeBase 

func (s *Server) BuildVectorIndexForKnowledgeBase(ctx context.Context, req *ypb.BuildVectorIndexForKnowledgeBaseRequest) (*ypb.GeneralResponse, error)

func (*Server) BuildVectorIndexForKnowledgeBaseEntry 

func (s *Server) BuildVectorIndexForKnowledgeBaseEntry(ctx context.Context, req *ypb.BuildVectorIndexForKnowledgeBaseEntryRequest) (*ypb.GeneralResponse, error)

func (*Server) BytesToBase64 

func (s *Server) BytesToBase64(ctx context.Context, req *ypb.BytesToBase64Request) (*ypb.BytesToBase64Response, error)

func (*Server) CheckHahValidAiConfig 

func (s *Server) CheckHahValidAiConfig(context.Context, *ypb.Empty) (*ypb.GeneralResponse, error)

func (*Server) CheckLicense 

func (s *Server) CheckLicense(ctx context.Context, r *ypb.CheckLicenseRequest) (_ *ypb.Empty, unexpectedError error)

func (*Server) CheckSyntaxFlowRuleUpdate 

func (s *Server) CheckSyntaxFlowRuleUpdate(ctx context.Context, req *ypb.CheckSyntaxFlowRuleUpdateRequest) (*ypb.CheckSyntaxFlowRuleUpdateResponse, error)

func (*Server) ClearAllModels 

func (s *Server) ClearAllModels(ctx context.Context, req *ypb.ClearAllModelsRequest) (*ypb.GeneralResponse, error)

清除所有本地模型

func (*Server) Codec 

func (s *Server) Codec(ctx context.Context, req *ypb.CodecRequest) (*ypb.CodecResponse, error)

func (*Server) ConfigGlobalReverse 

func (s *Server) ConfigGlobalReverse(req *ypb.ConfigGlobalReverseParams, stream ypb.Yak_ConfigGlobalReverseServer) error

func (*Server) ConnectVulinboxAgent added in v1.2.3 

func (s *Server) ConnectVulinboxAgent(ctx context.Context, req *ypb.IsRemoteAddrAvailableRequest) (*ypb.IsRemoteAddrAvailableResponse, error)

func (*Server) ConvertFuzzerResponseToHTTPFlow 

func (s *Server) ConvertFuzzerResponseToHTTPFlow(ctx context.Context, in *ypb.FuzzerResponse) (*ypb.HTTPFlow, error)

func (*Server) ConvertPayloadGroupToDatabase added in v1.3.0 

func (s *Server) ConvertPayloadGroupToDatabase(req *ypb.NameRequest, stream ypb.Yak_ConvertPayloadGroupToDatabaseServer) error

func (*Server) CreateAIForge 

func (s *Server) CreateAIForge(ctx context.Context, req *ypb.AIForge) (*ypb.DbOperateMessage, error)

func (*Server) CreateEntity 

func (s *Server) CreateEntity(ctx context.Context, req *ypb.Entity) (*ypb.DbOperateMessage, error)

CreateEntity 创建实体，如果 req.ID 提供则会尝试更新

func (*Server) CreateFingerprint 

func (s *Server) CreateFingerprint(ctx context.Context, req *ypb.CreateFingerprintRequest) (*ypb.DbOperateMessage, error)

func (*Server) CreateFingerprintGroup 

func (s *Server) CreateFingerprintGroup(ctx context.Context, req *ypb.FingerprintGroup) (*ypb.DbOperateMessage, error)

func (*Server) CreateHotPatchTemplate 

func (s *Server) CreateHotPatchTemplate(ctx context.Context, req *ypb.HotPatchTemplate) (*ypb.CreateHotPatchTemplateResponse, error)

func (*Server) CreateKnowledgeBase 

func (s *Server) CreateKnowledgeBase(ctx context.Context, req *ypb.CreateKnowledgeBaseRequest) (*ypb.GeneralResponse, error)

func (*Server) CreateKnowledgeBaseEntry 

func (s *Server) CreateKnowledgeBaseEntry(ctx context.Context, req *ypb.CreateKnowledgeBaseEntryRequest) (*ypb.GeneralResponse, error)

func (*Server) CreateKnowledgeBaseV2 

func (s *Server) CreateKnowledgeBaseV2(ctx context.Context, req *ypb.CreateKnowledgeBaseV2Request) (*ypb.CreateKnowledgeBaseV2Response, error)

func (*Server) CreateNote 

func (s *Server) CreateNote(ctx context.Context, req *ypb.CreateNoteRequest) (*ypb.CreateNoteResponse, error)

func (*Server) CreatePayloadFolder added in v1.2.9 

func (s *Server) CreatePayloadFolder(ctx context.Context, req *ypb.NameRequest) (*ypb.Empty, error)

func (*Server) CreatePluginEnv 

func (s *Server) CreatePluginEnv(ctx context.Context, request *ypb.PluginEnvData) (*ypb.Empty, error)

func (*Server) CreateRelationship 

func (s *Server) CreateRelationship(ctx context.Context, req *ypb.Relationship) (*ypb.DbOperateMessage, error)

CreateRelationship 创建关系，如果 req.ID 提供则会尝试更新

func (*Server) CreateSSAProject 

func (s *Server) CreateSSAProject(ctx context.Context, req *ypb.CreateSSAProjectRequest) (*ypb.CreateSSAProjectResponse, error)

func (*Server) CreateSSARiskDisposals 

func (s *Server) CreateSSARiskDisposals(ctx context.Context, req *ypb.CreateSSARiskDisposalsRequest) (*ypb.CreateSSARiskDisposalsResponse, error)

func (*Server) CreateSnippet 

func (s *Server) CreateSnippet(ctx context.Context, req *ypb.SnippetsRequest) (*ypb.Empty, error)

func (*Server) CreateSyntaxFlowRule 

func (s *Server) CreateSyntaxFlowRule(ctx context.Context, req *ypb.CreateSyntaxFlowRuleRequest) (*ypb.DbOperateMessage, error)

func (*Server) CreateSyntaxFlowRuleEx 

func (s *Server) CreateSyntaxFlowRuleEx(ctx context.Context, req *ypb.CreateSyntaxFlowRuleRequest) (*ypb.CreateSyntaxFlowRuleResponse, error)

func (*Server) CreateSyntaxFlowRuleGroup 

func (s *Server) CreateSyntaxFlowRuleGroup(ctx context.Context, req *ypb.CreateSyntaxFlowGroupRequest) (*ypb.DbOperateMessage, error)

func (*Server) CreateVectorStoreEntry 

func (s *Server) CreateVectorStoreEntry(ctx context.Context, req *ypb.CreateVectorStoreEntryRequest) (*ypb.GeneralResponse, error)

CreateVectorStoreEntry 创建向量存储条目

func (*Server) CreateWebShell added in v1.3.0 

func (s *Server) CreateWebShell(ctx context.Context, req *ypb.WebShell) (*ypb.WebShell, error)

func (*Server) CreateWebsocketFuzzer 

func (s *Server) CreateWebsocketFuzzer(stream ypb.Yak_CreateWebsocketFuzzerServer) error

func (*Server) CreateYaklangShell 

func (s *Server) CreateYaklangShell(server ypb.Yak_CreateYaklangShellServer) error

func (*Server) DebugPlugin added in v1.2.2 

func (s *Server) DebugPlugin(req *ypb.DebugPluginRequest, stream ypb.Yak_DebugPluginServer) error

func (*Server) DelKey 

func (s *Server) DelKey(ctx context.Context, req *ypb.GetKeyRequest) (*ypb.Empty, error)

func (*Server) DeleteAIForge 

func (s *Server) DeleteAIForge(ctx context.Context, req *ypb.AIForgeFilter) (*ypb.DbOperateMessage, error)

func (*Server) DeleteAITask 

func (s *Server) DeleteAITask(ctx context.Context, req *ypb.AITaskDeleteRequest) (*ypb.DbOperateMessage, error)

func (*Server) DeleteAITool 

func (s *Server) DeleteAITool(ctx context.Context, req *ypb.DeleteAIToolRequest) (*ypb.DbOperateMessage, error)

func (*Server) DeleteAllLocalPlugins 

func (s *Server) DeleteAllLocalPlugins(ctx context.Context, req *ypb.Empty) (*ypb.Empty, error)

func (*Server) DeleteAllMenu 

func (s *Server) DeleteAllMenu(ctx context.Context, req *ypb.QueryAllMenuItemRequest) (*ypb.Empty, error)

func (*Server) DeleteAllMenuItem 

func (s *Server) DeleteAllMenuItem(ctx context.Context, req *ypb.Empty) (*ypb.Empty, error)

func (*Server) DeleteAllNavigation added in v1.2.3 

func (s *Server) DeleteAllNavigation(ctx context.Context, req *ypb.GetAllNavigationRequest) (*ypb.Empty, error)

func (*Server) DeleteChaosMakerRuleByID 

func (s *Server) DeleteChaosMakerRuleByID(ctx context.Context, req *ypb.DeleteChaosMakerRuleByIDRequest) (*ypb.Empty, error)

func (*Server) DeleteCodecFlow added in v1.3.3 

func (s *Server) DeleteCodecFlow(ctx context.Context, req *ypb.DeleteCodecFlowRequest) (*ypb.Empty, error)

func (*Server) DeleteDomains 

func (s *Server) DeleteDomains(ctx context.Context, req *ypb.DeleteDomainsRequest) (*ypb.Empty, error)

func (*Server) DeleteEntity 

func (s *Server) DeleteEntity(ctx context.Context, req *ypb.DeleteEntityRequest) (*ypb.DbOperateMessage, error)

func (*Server) DeleteFingerprint 

func (s *Server) DeleteFingerprint(ctx context.Context, req *ypb.DeleteFingerprintRequest) (*ypb.DbOperateMessage, error)

func (*Server) DeleteFingerprintGroup 

func (s *Server) DeleteFingerprintGroup(ctx context.Context, req *ypb.DeleteFingerprintGroupRequest) (*ypb.DbOperateMessage, error)

func (*Server) DeleteFuzzerConfig 

func (s *Server) DeleteFuzzerConfig(ctx context.Context, req *ypb.DeleteFuzzerConfigRequest) (*ypb.DbOperateMessage, error)

func (*Server) DeleteFuzzerLabel added in v1.2.3 

func (s *Server) DeleteFuzzerLabel(ctx context.Context, req *ypb.DeleteFuzzerLabelRequest) (*ypb.Empty, error)

func (*Server) DeleteHTTPFlows 

func (s *Server) DeleteHTTPFlows(ctx context.Context, r *ypb.DeleteHTTPFlowRequest) (*ypb.Empty, error)

func (*Server) DeleteHistoryHTTPFuzzerTask 

func (s *Server) DeleteHistoryHTTPFuzzerTask(ctx context.Context, d *ypb.DeleteHistoryHTTPFuzzerTaskRequest) (*ypb.Empty, error)

func (*Server) DeleteHosts 

func (s *Server) DeleteHosts(ctx context.Context, req *ypb.DeleteHostsRequest) (*ypb.Empty, error)

func (*Server) DeleteHotPatchTemplate 

func (s *Server) DeleteHotPatchTemplate(ctx context.Context, req *ypb.DeleteHotPatchTemplateRequest) (*ypb.DeleteHotPatchTemplateResponse, error)

func (*Server) DeleteHybridScanTask added in v1.2.9 

func (s *Server) DeleteHybridScanTask(ctx context.Context, request *ypb.DeleteHybridScanTaskRequest) (*ypb.Empty, error)

func (*Server) DeleteKnowledgeBase 

func (s *Server) DeleteKnowledgeBase(ctx context.Context, req *ypb.DeleteKnowledgeBaseRequest) (*ypb.GeneralResponse, error)

func (*Server) DeleteKnowledgeBaseEntry 

func (s *Server) DeleteKnowledgeBaseEntry(ctx context.Context, req *ypb.DeleteKnowledgeBaseEntryRequest) (*ypb.GeneralResponse, error)

func (*Server) DeleteLocalModel 

func (s *Server) DeleteLocalModel(ctx context.Context, req *ypb.DeleteLocalModelRequest) (*ypb.GeneralResponse, error)

func (*Server) DeleteLocalPluginsByWhere 

func (s *Server) DeleteLocalPluginsByWhere(ctx context.Context, req *ypb.DeleteLocalPluginsByWhereRequest) (*ypb.Empty, error)

func (*Server) DeleteMCPServer 

func (s *Server) DeleteMCPServer(ctx context.Context, req *ypb.DeleteMCPServerRequest) (*ypb.GeneralResponse, error)

DeleteMCPServer 删除MCP服务器

func (*Server) DeleteMarkdownDocument 

func (s *Server) DeleteMarkdownDocument(ctx context.Context, req *ypb.GetMarkdownDocumentRequest) (*ypb.Empty, error)

func (*Server) DeleteNote 

func (s *Server) DeleteNote(ctx context.Context, req *ypb.DeleteNoteRequest) (*ypb.DbOperateMessage, error)

func (*Server) DeletePayload 

func (s *Server) DeletePayload(ctx context.Context, req *ypb.DeletePayloadRequest) (*ypb.Empty, error)

func (*Server) DeletePayloadByFolder added in v1.2.9 

func (s *Server) DeletePayloadByFolder(ctx context.Context, req *ypb.NameRequest) (*ypb.Empty, error)

func (*Server) DeletePayloadByGroup 

func (s *Server) DeletePayloadByGroup(ctx context.Context, req *ypb.DeletePayloadByGroupRequest) (*ypb.Empty, error)

func (*Server) DeletePluginByUserID 

func (s *Server) DeletePluginByUserID(ctx context.Context, req *ypb.DeletePluginByUserIDRequest) (*ypb.Empty, error)

func (*Server) DeletePluginEnv 

func (s *Server) DeletePluginEnv(ctx context.Context, request *ypb.DeletePluginEnvRequest) (*ypb.Empty, error)

func (*Server) DeletePorts 

func (s *Server) DeletePorts(ctx context.Context, req *ypb.DeletePortsRequest) (*ypb.Empty, error)

func (*Server) DeleteProject 

func (s *Server) DeleteProject(ctx context.Context, req *ypb.DeleteProjectRequest) (*ypb.Empty, error)

func (*Server) DeleteRelationship 

func (s *Server) DeleteRelationship(ctx context.Context, req *ypb.DeleteRelationshipRequest) (*ypb.DbOperateMessage, error)

DeleteRelationship 删除关系

func (*Server) DeleteReport 

func (s *Server) DeleteReport(ctx context.Context, d *ypb.DeleteReportRequest) (*ypb.Empty, error)

func (*Server) DeleteRisk 

func (s *Server) DeleteRisk(ctx context.Context, req *ypb.DeleteRiskRequest) (*ypb.Empty, error)

func (*Server) DeleteSSAPrograms 

func (s *Server) DeleteSSAPrograms(ctx context.Context, req *ypb.DeleteSSAProgramRequest) (*ypb.DbOperateMessage, error)

func (*Server) DeleteSSAProject 

func (s *Server) DeleteSSAProject(ctx context.Context, req *ypb.DeleteSSAProjectRequest) (*ypb.DeleteSSAProjectResponse, error)

func (*Server) DeleteSSARiskDisposals 

func (s *Server) DeleteSSARiskDisposals(ctx context.Context, req *ypb.DeleteSSARiskDisposalsRequest) (*ypb.DeleteSSARiskDisposalsResponse, error)

func (*Server) DeleteSSARisks 

func (s *Server) DeleteSSARisks(ctx context.Context, req *ypb.DeleteSSARisksRequest) (*ypb.DbOperateMessage, error)

func (*Server) DeleteScreenRecorders added in v1.2.2 

func (s *Server) DeleteScreenRecorders(ctx context.Context, req *ypb.QueryScreenRecorderRequest) (*ypb.Empty, error)

func (*Server) DeleteSearchVectorDatabase 

func (s *Server) DeleteSearchVectorDatabase(ctx context.Context, req *ypb.DeleteSearchVectorDatabaseRequest) (*ypb.GeneralResponse, error)

func (*Server) DeleteSimpleDetectUnfinishedTask added in v1.3.3 

func (s *Server) DeleteSimpleDetectUnfinishedTask(ctx context.Context, req *ypb.DeleteUnfinishedTaskRequest) (*ypb.Empty, error)

func (*Server) DeleteSnippets 

func (s *Server) DeleteSnippets(ctx context.Context, req *ypb.QuerySnippetsRequest) (*ypb.Empty, error)

func (*Server) DeleteSyntaxFlowResult 

func (s *Server) DeleteSyntaxFlowResult(ctx context.Context, req *ypb.DeleteSyntaxFlowResultRequest) (*ypb.DeleteSyntaxFlowResultResponse, error)

func (*Server) DeleteSyntaxFlowRule 

func (s *Server) DeleteSyntaxFlowRule(ctx context.Context, req *ypb.DeleteSyntaxFlowRuleRequest) (*ypb.DbOperateMessage, error)

func (*Server) DeleteSyntaxFlowRuleGroup 

func (s *Server) DeleteSyntaxFlowRuleGroup(ctx context.Context, req *ypb.DeleteSyntaxFlowRuleGroupRequest) (*ypb.DbOperateMessage, error)

func (*Server) DeleteSyntaxFlowScanTask 

func (s *Server) DeleteSyntaxFlowScanTask(ctx context.Context, request *ypb.DeleteSyntaxFlowScanTaskRequest) (*ypb.DbOperateMessage, error)

func (*Server) DeleteWebShell added in v1.3.0 

func (s *Server) DeleteWebShell(ctx context.Context, req *ypb.DeleteWebShellRequest) (*ypb.Empty, error)

func (*Server) DeleteYakScript 

func (s *Server) DeleteYakScript(ctx context.Context, req *ypb.DeleteYakScriptRequest) (*ypb.Empty, error)

func (*Server) DeleteYakScriptExec 

func (s *Server) DeleteYakScriptExec(ctx context.Context, req *ypb.Empty) (*ypb.Empty, error)

func (*Server) DeleteYakScriptExecResult 

func (s *Server) DeleteYakScriptExecResult(ctx context.Context, req *ypb.DeleteYakScriptExecResultRequest) (*ypb.Empty, error)

func (*Server) DeleteYakScriptGroup added in v1.3.1 

func (s *Server) DeleteYakScriptGroup(ctx context.Context, req *ypb.DeleteYakScriptGroupRequest) (*ypb.Empty, error)

func (*Server) DiagnoseNetwork added in v1.2.4 

func (s *Server) DiagnoseNetwork(req *ypb.DiagnoseNetworkRequest, server ypb.Yak_DiagnoseNetworkServer) error

func (*Server) DiagnoseNetworkDNS added in v1.2.4 

func (s *Server) DiagnoseNetworkDNS(req *ypb.DiagnoseNetworkDNSRequest, server ypb.Yak_DiagnoseNetworkDNSServer) error

func (*Server) DisconnectVulinboxAgent added in v1.2.3 

func (s *Server) DisconnectVulinboxAgent(ctx context.Context, req *ypb.DisconnectVulinboxAgentRequest) (*ypb.Empty, error)

func (*Server) DoHTTPFlowsSync 

func (s *Server) DoHTTPFlowsSync(ctx context.Context, db *gorm.DB, toOnlineReq *ypb.HTTPFlowsToOnlineRequest) (success []string, failed []string, err error)

func (*Server) DownloadHotPatchTemplate 

func (s *Server) DownloadHotPatchTemplate(ctx context.Context, req *ypb.DownloadHotPatchTemplateRequest) (*ypb.Empty, error)

func (*Server) DownloadLocalModel 

func (s *Server) DownloadLocalModel(req *ypb.DownloadLocalModelRequest, stream ypb.Yak_DownloadLocalModelServer) error

DownloadLocalModel 下载本地模型

func (*Server) DownloadMITMCert 

func (s *Server) DownloadMITMCert(ctx context.Context, _ *ypb.Empty) (*ypb.MITMCert, error)

func (*Server) DownloadMITMGMCert 

func (s *Server) DownloadMITMGMCert(ctx context.Context, _ *ypb.Empty) (*ypb.MITMCert, error)

func (*Server) DownloadOnlinePluginAll 

func (s *Server) DownloadOnlinePluginAll(req *ypb.DownloadOnlinePluginByTokenRequest, stream ypb.Yak_DownloadOnlinePluginAllServer) error

func (*Server) DownloadOnlinePluginBatch added in v1.2.9 

func (s *Server) DownloadOnlinePluginBatch(ctx context.Context, req *ypb.DownloadOnlinePluginsRequest) (*ypb.Empty, error)

func (*Server) DownloadOnlinePluginById 

func (s *Server) DownloadOnlinePluginById(ctx context.Context, req *ypb.DownloadOnlinePluginByIdRequest) (*ypb.Empty, error)

func (*Server) DownloadOnlinePluginByIds 

func (s *Server) DownloadOnlinePluginByIds(ctx context.Context, req *ypb.DownloadOnlinePluginByIdsRequest) (*ypb.Empty, error)

func (*Server) DownloadOnlinePluginByPluginName added in v1.2.9 

func (s *Server) DownloadOnlinePluginByPluginName(ctx context.Context, req *ypb.DownloadOnlinePluginByScriptNamesRequest) (*ypb.DownloadOnlinePluginByScriptNamesResponse, error)

func (*Server) DownloadOnlinePluginByScriptNames 

func (s *Server) DownloadOnlinePluginByScriptNames(ctx context.Context, req *ypb.DownloadOnlinePluginByScriptNamesRequest) (*ypb.DownloadOnlinePluginByScriptNamesResponse, error)

func (*Server) DownloadOnlinePluginByUUID 

func (s *Server) DownloadOnlinePluginByUUID(ctx context.Context, req *ypb.DownloadOnlinePluginByUUIDRequest) (*ypb.YakScript, error)

func (*Server) DownloadOnlinePlugins added in v1.2.9 

func (s *Server) DownloadOnlinePlugins(req *ypb.DownloadOnlinePluginsRequest, stream ypb.Yak_DownloadOnlinePluginsServer) error

func (*Server) DownloadPayload 

func (s *Server) DownloadPayload(req *ypb.DownloadPayloadRequest, stream ypb.Yak_DownloadPayloadServer) error

func (*Server) DownloadReport 

func (s *Server) DownloadReport(ctx context.Context, req *ypb.DownloadReportRequest) (*ypb.Empty, error)

func (*Server) DownloadSyntaxFlowRule 

func (s *Server) DownloadSyntaxFlowRule(req *ypb.DownloadSyntaxFlowRuleRequest, stream ypb.Yak_DownloadSyntaxFlowRuleServer) error

DownloadSyntaxFlowRule 从在线服务下载规则到本地

下载规则时的处理逻辑： 

┌────────────┬──────────┬──────────┬─────────┬────────────────────────────┐
│ 本地规则   │ 本地版本  │ 在线版本  │ Dirty   │ 处理动作                   │
├────────────┼──────────┼──────────┼─────────┼────────────────────────────┤
│ 不存在     │ -        │ v2.0     │ -       │ 下载规则                   │
│ 存在       │ v1.0     │ v2.0     │ false   │ 更新规则（在线版本更新）   │
│ 存在       │ v3.0     │ v2.0     │ false   │ 跳过更新（本地版本更新）   │
│ 存在       │ v1.0/v2.0│ v2.0     │ true    │ 冲突-跳过（本地有修改）    │
│ 存在       │ v2.0     │ v2.0     │ false   │ 更新规则（强制同步）       │
└────────────┴──────────┴──────────┴─────────┴────────────────────────────┘

版本比较规则：

  • CheckNewerVersion(local, online) 返回 true 表示本地版本 > 在线版本
  • 使用字符串字典序比较（注意：v10.0 < v2.0）
  • 建议使用语义化版本号：1.0.0, 2.0.0 等

Dirty 标记说明：

  • true: 本地有修改，需要冲突处理，跳过更新
  • false: 本地未修改，可以安全覆盖

func (*Server) DownloadWithStream added in v1.2.3 

func (s *Server) DownloadWithStream(proxy string, fileGetter func() (urlStr string, name string, err error), stream DownloadStream) error

func (*Server) DuplexConnection added in v1.2.8 

func (s *Server) DuplexConnection(stream ypb.Yak_DuplexConnectionServer) error

func (*Server) Echo 

func (s *Server) Echo(ctx context.Context, req *ypb.EchoRequest) (*ypb.EchoResposne, error)

func (*Server) EvaluateExpression added in v1.3.3 

func (s *Server) EvaluateExpression(ctx context.Context, req *ypb.EvaluateExpressionRequest) (*ypb.EvaluateExpressionResponse, error)

func (*Server) EvaluateMultiExpression 

func (s *Server) EvaluateMultiExpression(ctx context.Context, req *ypb.EvaluateMultiExpressionRequest) (*ypb.EvaluateMultiExpressionResponse, error)

func (*Server) EvaluatePlugin added in v1.2.9 

func (s *Server) EvaluatePlugin(ctx context.Context, pluginCode, pluginType string, pluginTestingServer *PluginTestingEchoServer) (*ypb.SmokingEvaluatePluginResponse, error)

只在评分中使用

func (*Server) Exec 

func (s *Server) Exec(req *ypb.ExecRequest, stream ypb.Yak_ExecServer) error

func (*Server) ExecBatchYakScript 

func (s *Server) ExecBatchYakScript(req *ypb.ExecBatchYakScriptRequest, stream ypb.Yak_ExecBatchYakScriptServer) error

func (*Server) ExecPacketScan 

func (s *Server) ExecPacketScan(req *ypb.ExecPacketScanRequest, stream ypb.Yak_ExecPacketScanServer) error

func (*Server) ExecWithContext 

func (s *Server) ExecWithContext(ctx context.Context, req *ypb.ExecRequest, stream ypb.Yak_ExecServer) error

func (*Server) ExecYakScript 

func (s *Server) ExecYakScript(req *ypb.ExecRequest, stream ypb.Yak_ExecYakScriptServer) error

func (*Server) ExecYakitPluginsByYakScriptFilter 

func (s *Server) ExecYakitPluginsByYakScriptFilter(req *ypb.ExecYakitPluginsByYakScriptFilterRequest, stream ypb.Yak_ExecYakitPluginsByYakScriptFilterServer) error

func (*Server) ExecuteBatchPacketYakScript 

func (s *Server) ExecuteBatchPacketYakScript(req *ypb.ExecuteBatchPacketYakScriptParams, stream ypb.Yak_ExecuteBatchPacketYakScriptServer) error

func (*Server) ExecuteChaosMakerRule 

func (s *Server) ExecuteChaosMakerRule(req *ypb.ExecuteChaosMakerRuleRequest, stream ypb.Yak_ExecuteChaosMakerRuleServer) error

func (*Server) ExecutePacketYakScript 

func (s *Server) ExecutePacketYakScript(req *ypb.ExecutePacketYakScriptParams, stream ypb.Yak_ExecutePacketYakScriptServer) error

func (*Server) ExportAllPayload added in v1.3.0 

func (s *Server) ExportAllPayload(req *ypb.GetAllPayloadRequest, stream ypb.Yak_ExportAllPayloadServer) error

导出payload到文件

func (*Server) ExportAllPayloadFromFile added in v1.3.0 

func (s *Server) ExportAllPayloadFromFile(req *ypb.GetAllPayloadRequest, stream ypb.Yak_ExportAllPayloadFromFileServer) error

导出payload，从数据库中的文件导出到另外一个文件

func (*Server) ExportFingerprint 

func (s *Server) ExportFingerprint(req *ypb.ExportFingerprintRequest, stream ypb.Yak_ExportFingerprintServer) error

func (*Server) ExportHTTPFlowStream 

func (s *Server) ExportHTTPFlowStream(req *ypb.ExportHTTPFlowStreamRequest, stream ypb.Yak_ExportHTTPFlowStreamServer) error

func (*Server) ExportHTTPFlows added in v1.3.0 

func (s *Server) ExportHTTPFlows(ctx context.Context, req *ypb.ExportHTTPFlowsRequest) (*ypb.QueryHTTPFlowResponse, error)

func (*Server) ExportHTTPFuzzerTaskToYaml added in v1.2.7 

func (s *Server) ExportHTTPFuzzerTaskToYaml(ctx context.Context, req *ypb.ExportHTTPFuzzerTaskToYamlRequest) (*ypb.ExportHTTPFuzzerTaskToYamlResponse, error)

ExportHTTPFuzzerTaskToYaml fuzzerRequest -> yakTemplate -> yaml

func (*Server) ExportKnowledgeBase 

func (s *Server) ExportKnowledgeBase(req *ypb.ExportKnowledgeBaseRequest, stream ypb.Yak_ExportKnowledgeBaseServer) error

ExportKnowledgeBase 导出知识库到指定路径

func (*Server) ExportLocalYakScript added in v1.3.0 

func (s *Server) ExportLocalYakScript(ctx context.Context, req *ypb.ExportLocalYakScriptRequest) (*ypb.ExportLocalYakScriptResponse, error)

func (*Server) ExportLocalYakScriptStream added in v1.3.1 

func (s *Server) ExportLocalYakScriptStream(req *ypb.ExportLocalYakScriptRequest, stream ypb.Yak_ExportLocalYakScriptStreamServer) error

func (*Server) ExportMITMReplacerRules 

func (s *Server) ExportMITMReplacerRules(ctx context.Context, _ *ypb.Empty) (*ypb.ExportMITMReplacerRulesResponse, error)

func (*Server) ExportMITMRuleExtractedData 

func (s *Server) ExportMITMRuleExtractedData(req *ypb.ExportMITMRuleExtractedDataRequest, stream ypb.Yak_ExportMITMRuleExtractedDataServer) error

func (*Server) ExportMenuItem 

func (s *Server) ExportMenuItem(ctx context.Context, req *ypb.Empty) (*ypb.ExportMenuItemResult, error)

func (*Server) ExportNote 

func (s *Server) ExportNote(req *ypb.ExportNoteRequest, stream ypb.Yak_ExportNoteServer) error

func (*Server) ExportPayloadBatch 

func (s *Server) ExportPayloadBatch(req *ypb.ExportPayloadBatchRequest, stream ypb.Yak_ExportAllPayloadServer) error

func (*Server) ExportPayloadDBAndFile 

func (s *Server) ExportPayloadDBAndFile(req *ypb.ExportPayloadDBAndFileRequest, stream ypb.Yak_ExportPayloadDBAndFileServer) error

func (*Server) ExportProject 

func (s *Server) ExportProject(req *ypb.ExportProjectRequest, stream ypb.Yak_ExportProjectServer) error

func (*Server) ExportSSARisk 

func (s *Server) ExportSSARisk(req *ypb.ExportSSARiskRequest, stream ypb.Yak_ExportSSARiskServer) error

func (*Server) ExportSyntaxFlows 

func (s *Server) ExportSyntaxFlows(req *ypb.ExportSyntaxFlowsRequest, stream ypb.Yak_ExportSyntaxFlowsServer) error

func (*Server) ExportYakPluginBatch 

func (s *Server) ExportYakPluginBatch(script *schema.YakScript, dir, OutputPluginDir string) (string, error)

func (*Server) ExportYakScript 

func (s *Server) ExportYakScript(ctx context.Context, req *ypb.ExportYakScriptRequest) (*ypb.ExportYakScriptResponse, error)

func (*Server) ExportYakScriptStream 

func (s *Server) ExportYakScriptStream(
	req *ypb.ExportYakScriptStreamRequest,
	stream ypb.Yak_ExportYakScriptStreamServer,
) error

func (*Server) ExtractData 

func (s *Server) ExtractData(server ypb.Yak_ExtractDataServer) error

func (*Server) ExtractDataToFile 

func (s *Server) ExtractDataToFile(input ypb.Yak_ExtractDataToFileServer) error

func (*Server) ExtractHTTPResponse 

func (s *Server) ExtractHTTPResponse(ctx context.Context, req *ypb.ExtractHTTPResponseParams) (*ypb.ExtractHTTPResponseResult, error)

func (*Server) ExtractUrl 

func (s *Server) ExtractUrl(ctx context.Context, req *ypb.FuzzerRequest) (*ypb.ExtractedUrl, error)

func (*Server) FetchPortAssetFromSpaceEngine added in v1.2.9 

func (s *Server) FetchPortAssetFromSpaceEngine(req *ypb.FetchPortAssetFromSpaceEngineRequest, stream ypb.Yak_FetchPortAssetFromSpaceEngineServer) error

func (*Server) FixUploadPacket 

func (s *Server) FixUploadPacket(ctx context.Context, req *ypb.FixUploadPacketRequest) (*ypb.FixUploadPacketResponse, error)

func (*Server) ForceUpdateAvailableYakScriptTags 

func (s *Server) ForceUpdateAvailableYakScriptTags(ctx context.Context, req *ypb.Empty) (*ypb.Empty, error)

func (*Server) FuzzTagSuggestion 

func (s *Server) FuzzTagSuggestion(ctx context.Context, req *ypb.FuzzTagSuggestionRequest) (*ypb.YaklangLanguageSuggestionResponse, error)

func (*Server) GenQualityInspectionReport added in v1.2.4 

func (s *Server) GenQualityInspectionReport(req *ypb.GenQualityInspectionReportRequest, stream ypb.Yak_GenQualityInspectionReportServer) error

func (*Server) GenerateCSRFPocByPacket 

func (s *Server) GenerateCSRFPocByPacket(ctx context.Context, req *ypb.GenerateCSRFPocByPacketRequest) (*ypb.GenerateCSRFPocByPacketResponse, error)

func (*Server) GenerateERMDot 

func (s *Server) GenerateERMDot(ctx context.Context, req *ypb.GenerateERMDotRequest) (*ypb.GenerateERMDotResponse, error)

GenerateERMDot 生成 ER 图 DOT 格式

func (*Server) GenerateExtractRule 

func (s *Server) GenerateExtractRule(
	ctx context.Context,
	req *ypb.GenerateExtractRuleRequest,
) (*ypb.GenerateExtractRuleResponse, error)

func (*Server) GenerateFuzztag 

func (s *Server) GenerateFuzztag(ctx context.Context, req *ypb.GenerateFuzztagRequest) (*ypb.GenerateFuzztagResponse, error)

func (*Server) GenerateReverseShellCommand 

func (s *Server) GenerateReverseShellCommand(ctx context.Context, req *ypb.GenerateReverseShellCommandRequest) (*ypb.GenerateReverseShellCommandResponse, error)

func (*Server) GenerateSSAReport 

func (s *Server) GenerateSSAReport(ctx context.Context, req *ypb.GenerateSSAReportRequest) (*ypb.GenerateSSAReportResponse, error)

GenerateSSAReport 生成SSA扫描报告 支持两种生成方式： 1. 基于TaskID：生成整个扫描任务的完整报告 2. 基于Filter：使用SSARisksFilter过滤器生成报告

func (*Server) GenerateURL added in v1.2.9 

func (s *Server) GenerateURL(ctx context.Context, req *ypb.GenerateURLRequest) (*ypb.GenerateURLResponse, error)

func (*Server) GenerateWebShell added in v1.3.3 

func (s *Server) GenerateWebShell(context.Context, *ypb.ShellGenerate) (*ypb.WebShellResponse, error)

func (*Server) GenerateWebsiteTree 

func (s *Server) GenerateWebsiteTree(ctx context.Context, req *ypb.GenerateWebsiteTreeRequest) (
	*ypb.GenerateWebsiteTreeResponse, error,
)

func (*Server) GenerateYakCodeByPacket 

func (s *Server) GenerateYakCodeByPacket(ctx context.Context, req *ypb.GenerateYakCodeByPacketRequest) (*ypb.GenerateYakCodeByPacketResponse, error)

func (*Server) GenerateYsoBytes 

func (s *Server) GenerateYsoBytes(ctx context.Context, req *ypb.YsoOptionsRequerstWithVerbose) (*ypb.YsoBytesResponse, error)

func (*Server) GenerateYsoCode 

func (s *Server) GenerateYsoCode(ctx context.Context, req *ypb.YsoOptionsRequerstWithVerbose) (*ypb.YsoCodeResponse, error)

func (*Server) GetAIForge 

func (s *Server) GetAIForge(ctx context.Context, req *ypb.GetAIForgeRequest) (*ypb.AIForge, error)

func (*Server) GetAIToolList 

func (s *Server) GetAIToolList(ctx context.Context, req *ypb.GetAIToolListRequest) (*ypb.GetAIToolListResponse, error)

func (*Server) GetAllCodecFlow added in v1.3.3 

func (s *Server) GetAllCodecFlow(ctx context.Context, req *ypb.Empty) (*ypb.GetCodecFlowResponse, error)

func (*Server) GetAllCodecMethods added in v1.3.1 

func (s *Server) GetAllCodecMethods(ctx context.Context, in *ypb.Empty) (*ypb.CodecMethods, error)

func (*Server) GetAllFingerprintGroup 

func (s *Server) GetAllFingerprintGroup(ctx context.Context, req *ypb.Empty) (*ypb.FingerprintGroups, error)

func (*Server) GetAllFuzztagInfo 

func (s *Server) GetAllFuzztagInfo(ctx context.Context, req *ypb.GetAllFuzztagInfoRequest) (*ypb.GetAllFuzztagInfoResponse, error)

func (*Server) GetAllMCPServers 

func (s *Server) GetAllMCPServers(ctx context.Context, req *ypb.GetAllMCPServersRequest) (*ypb.GetAllMCPServersResponse, error)

GetAllMCPServers 获取所有MCP服务器（支持分页和搜索）

func (*Server) GetAllMenuItem 

func (s *Server) GetAllMenuItem(ctx context.Context, req *ypb.Empty) (*ypb.MenuByGroup, error)

func (*Server) GetAllNavigationItem added in v1.2.3 

func (s *Server) GetAllNavigationItem(ctx context.Context, req *ypb.GetAllNavigationRequest) (*ypb.GetAllNavigationItemResponse, error)

func (*Server) GetAllPayload 

func (s *Server) GetAllPayload(ctx context.Context, req *ypb.GetAllPayloadRequest) (*ypb.GetAllPayloadResponse, error)

! 已弃用 导出payload到文件

func (*Server) GetAllPayloadGroup 

func (s *Server) GetAllPayloadGroup(ctx context.Context, _ *ypb.Empty) (*ypb.GetAllPayloadGroupResponse, error)

func (*Server) GetAllPluginEnv 

func (s *Server) GetAllPluginEnv(ctx context.Context, empty *ypb.Empty) (*ypb.PluginEnvData, error)

func (*Server) GetAllProcessEnvKey 

func (s *Server) GetAllProcessEnvKey(ctx context.Context, req *ypb.Empty) (*ypb.GetProcessEnvKeyResult, error)

func (*Server) GetAllStartedLocalModels 

func (s *Server) GetAllStartedLocalModels(ctx context.Context, req *ypb.Empty) (*ypb.GetAllStartedLocalModelsResponse, error)

func (*Server) GetAllVectorStoreCollections 

func (s *Server) GetAllVectorStoreCollections(ctx context.Context, req *ypb.Empty) (*ypb.GetAllVectorStoreCollectionsResponse, error)

func (*Server) GetAllVectorStoreCollectionsWithFilter 

func (s *Server) GetAllVectorStoreCollectionsWithFilter(ctx context.Context, req *ypb.GetAllVectorStoreCollectionsWithFilterRequest) (*ypb.GetAllVectorStoreCollectionsWithFilterResponse, error)

GetAllVectorStoreCollectionsWithFilter 获取所有向量存储集合（带过滤和分页）

func (*Server) GetAllYsoClassGeneraterOptions 

func (s *Server) GetAllYsoClassGeneraterOptions(ctx context.Context, req *ypb.YsoOptionsRequerstWithVerbose) (*ypb.YsoClassOptionsResponseWithVerbose, error)

func (*Server) GetAllYsoClassOptions 

func (s *Server) GetAllYsoClassOptions(ctx context.Context, req *ypb.YsoOptionsRequerstWithVerbose) (*ypb.YsoOptionsWithVerbose, error)

func (*Server) GetAllYsoGadgetOptions 

func (s *Server) GetAllYsoGadgetOptions(ctx context.Context, _ *ypb.Empty) (*ypb.YsoOptionsWithVerbose, error)

func (*Server) GetAvailableBruteTypes 

func (s *Server) GetAvailableBruteTypes(ctx context.Context, req *ypb.Empty) (*ypb.GetAvailableBruteTypesResponse, error)

func (*Server) GetAvailableYakScriptTags 

func (s *Server) GetAvailableYakScriptTags(ctx context.Context, req *ypb.Empty) (*ypb.Fields, error)

func (*Server) GetBasicInfo added in v1.3.0 

func (s *Server) GetBasicInfo(ctx context.Context, req *ypb.WebShellRequest) (*ypb.WebShellResponse, error)

func (*Server) GetCVE 

func (s *Server) GetCVE(ctx context.Context, req *ypb.GetCVERequest) (*ypb.CVEDetailEx, error)

func (*Server) GetCurrentProject 

func (s *Server) GetCurrentProject(ctx context.Context, _ *ypb.Empty) (*ypb.ProjectDescription, error)

func (*Server) GetCurrentProjectEx 

func (s *Server) GetCurrentProjectEx(ctx context.Context, req *ypb.GetCurrentProjectExRequest) (*ypb.ProjectDescription, error)

func (*Server) GetCurrentRules 

func (s *Server) GetCurrentRules(c context.Context, req *ypb.Empty) (*ypb.MITMContentReplacers, error)

func (*Server) GetCurrentYakBridgeLogServer 

func (s *Server) GetCurrentYakBridgeLogServer(ctx context.Context, l *ypb.Empty) (*ypb.YakDNSLogBridgeAddr, error)

func (*Server) GetDefaultProject 

func (s *Server) GetDefaultProject(ctx context.Context, req *ypb.Empty) (*ypb.ProjectDescription, error)

func (*Server) GetDefaultProjectEx 

func (s *Server) GetDefaultProjectEx(ctx context.Context, req *ypb.GetDefaultProjectExRequest) (*ypb.ProjectDescription, error)

func (*Server) GetDocumentByVectorStoreEntryID 

func (s *Server) GetDocumentByVectorStoreEntryID(ctx context.Context, req *ypb.GetDocumentByVectorStoreEntryIDRequest) (*ypb.GetDocumentByVectorStoreEntryIDResponse, error)

GetDocumentByVectorStoreEntryID 根据向量存储条目ID获取对应的知识库文档

func (*Server) GetEngineDefaultProxy 

func (s *Server) GetEngineDefaultProxy(ctx context.Context, e *ypb.Empty) (*ypb.DefaultProxyResult, error)

func (*Server) GetExecBatchYakScriptUnfinishedTask 

func (s *Server) GetExecBatchYakScriptUnfinishedTask(ctx context.Context, req *ypb.Empty) (*ypb.GetExecBatchYakScriptUnfinishedTaskResponse, error)

func (*Server) GetExecBatchYakScriptUnfinishedTaskByUid 

func (s *Server) GetExecBatchYakScriptUnfinishedTaskByUid(ctx context.Context, req *ypb.GetExecBatchYakScriptUnfinishedTaskByUidRequest) (*ypb.ExecBatchYakScriptRequest, error)

func (*Server) GetFingerprintGroupSetByFilter 

func (s *Server) GetFingerprintGroupSetByFilter(ctx context.Context, req *ypb.GetFingerprintGroupSetRequest) (*ypb.FingerprintGroups, error)

func (*Server) GetGlobalNetworkConfig added in v1.2.4 

func (s *Server) GetGlobalNetworkConfig(ctx context.Context, req *ypb.GetGlobalNetworkConfigRequest) (*ypb.GlobalNetworkConfig, error)

func (*Server) GetGlobalReverseServer 

func (s *Server) GetGlobalReverseServer(ctx context.Context, req *ypb.Empty) (*ypb.GetGlobalReverseServerResponse, error)

func (*Server) GetHTTPFlowBare added in v1.2.6 

func (s *Server) GetHTTPFlowBare(ctx context.Context, req *ypb.HTTPFlowBareRequest) (*ypb.HTTPFlowBareResponse, error)

func (*Server) GetHTTPFlowBodyById 

func (s *Server) GetHTTPFlowBodyById(r *ypb.GetHTTPFlowBodyByIdRequest, stream ypb.Yak_GetHTTPFlowBodyByIdServer) error

func (*Server) GetHTTPFlowByHash 

func (s *Server) GetHTTPFlowByHash(_ context.Context, r *ypb.GetHTTPFlowByHashRequest) (*ypb.HTTPFlow, error)

func (*Server) GetHTTPFlowById 

func (s *Server) GetHTTPFlowById(_ context.Context, r *ypb.GetHTTPFlowByIdRequest) (*ypb.HTTPFlow, error)

func (*Server) GetHTTPFlowByIds added in v1.2.5 

func (s *Server) GetHTTPFlowByIds(_ context.Context, r *ypb.GetHTTPFlowByIdsRequest) (*ypb.HTTPFlows, error)

func (*Server) GetHTTPPacketBody 

func (s *Server) GetHTTPPacketBody(ctx context.Context, req *ypb.GetHTTPPacketBodyRequest) (*ypb.Bytes, error)

func (*Server) GetHistoryHTTPFuzzerTask 

func (s *Server) GetHistoryHTTPFuzzerTask(ctx context.Context, req *ypb.GetHistoryHTTPFuzzerTaskRequest) (*ypb.HistoryHTTPFuzzerTaskDetail, error)

func (*Server) GetKey 

func (s *Server) GetKey(ctx context.Context, req *ypb.GetKeyRequest) (*ypb.GetKeyResult, error)

func (*Server) GetKnowledgeBase 

func (s *Server) GetKnowledgeBase(ctx context.Context, req *ypb.GetKnowledgeBaseRequest) (*ypb.GetKnowledgeBaseResponse, error)

GetKnowledgeBase 获取知识库信息和条目列表

func (*Server) GetKnowledgeBaseNameList 

func (s *Server) GetKnowledgeBaseNameList(ctx context.Context, req *ypb.Empty) (*ypb.GetKnowledgeBaseNameListResponse, error)

func (*Server) GetKnowledgeBaseTypeList 

func (s *Server) GetKnowledgeBaseTypeList(ctx context.Context, req *ypb.Empty) (*ypb.GetKnowledgeBaseTypeListResponse, error)

func (*Server) GetLicense 

func (s *Server) GetLicense(ctx context.Context, _ *ypb.Empty) (_ *ypb.GetLicenseResponse, unexpectedError error)

func (*Server) GetMITMFilter 

func (s *Server) GetMITMFilter(ctx context.Context, req *ypb.Empty) (*ypb.SetMITMFilterRequest, error)

func (*Server) GetMITMHijackFilter 

func (s *Server) GetMITMHijackFilter(ctx context.Context, req *ypb.Empty) (*ypb.SetMITMFilterRequest, error)

func (*Server) GetMachineID 

func (s *Server) GetMachineID(ctx context.Context, _ *ypb.Empty) (*ypb.GetMachineIDResponse, error)

func (*Server) GetMarkdownDocument 

func (s *Server) GetMarkdownDocument(ctx context.Context, req *ypb.GetMarkdownDocumentRequest) (*ypb.GetMarkdownDocumentResponse, error)

func (*Server) GetMenuItemById 

func (s *Server) GetMenuItemById(ctx context.Context, req *ypb.GetMenuItemByIdRequest) (*ypb.MenuItem, error)

func (*Server) GetOneScreenRecorders added in v1.2.2 

func (s *Server) GetOneScreenRecorders(ctx context.Context, req *ypb.GetOneScreenRecorderRequest) (*ypb.ScreenRecorder, error)

func (*Server) GetOnlineProfile 

func (s *Server) GetOnlineProfile(ctx context.Context, req *ypb.Empty) (*ypb.OnlineProfile, error)

func (*Server) GetPcapMetadata added in v1.2.8 

func (s *Server) GetPcapMetadata(ctx context.Context, req *ypb.PcapMetadataRequest) (*ypb.PcapMetadata, error)

func (*Server) GetProfileDatabase 

func (s *Server) GetProfileDatabase() *gorm.DB

func (*Server) GetProjectDBWithType 

func (s *Server) GetProjectDBWithType(typ string) *gorm.DB

func (*Server) GetProjectDatabase 

func (s *Server) GetProjectDatabase() *gorm.DB

func (*Server) GetProjectKey added in v1.2.2 

func (s *Server) GetProjectKey(ctx context.Context, req *ypb.GetKeyRequest) (*ypb.GetKeyResult, error)

func (*Server) GetProjects 

func (s *Server) GetProjects(ctx context.Context, req *ypb.GetProjectsRequest) (*ypb.GetProjectsResponse, error)

func (*Server) GetRandomAIMaterials 

func (s *Server) GetRandomAIMaterials(ctx context.Context, req *ypb.GetRandomAIMaterialsRequest) (*ypb.GetRandomAIMaterialsResponse, error)

func (*Server) GetRegisteredVulinboxAgent added in v1.2.3 

func (s *Server) GetRegisteredVulinboxAgent(ctx context.Context, req *ypb.GetRegisteredAgentRequest) (*ypb.GetRegisteredAgentResponse, error)

func (*Server) GetRequestBodyByHTTPFlowID 

func (s *Server) GetRequestBodyByHTTPFlowID(ctx context.Context, req *ypb.DownloadBodyByHTTPFlowIDRequest) (*ypb.Bytes, error)

func (*Server) GetResponseBodyByHTTPFlowID 

func (s *Server) GetResponseBodyByHTTPFlowID(ctx context.Context, req *ypb.DownloadBodyByHTTPFlowIDRequest) (*ypb.Bytes, error)

func (*Server) GetReverseShellProgramList 

func (s *Server) GetReverseShellProgramList(ctx context.Context, req *ypb.GetReverseShellProgramListRequest) (*ypb.GetReverseShellProgramListResponse, error)

func (*Server) GetSSADatabase 

func (s *Server) GetSSADatabase() *gorm.DB

func (*Server) GetSSARiskDisposal 

func (s *Server) GetSSARiskDisposal(ctx context.Context, req *ypb.GetSSARiskDisposalRequest) (*ypb.GetSSARiskDisposalResponse, error)

func (*Server) GetSSARiskFieldGroup 

func (s *Server) GetSSARiskFieldGroup(ctx context.Context, req *ypb.Empty) (*ypb.SSARiskFieldGroupResponse, error)

func (*Server) GetSSARiskFieldGroupEx 

func (s *Server) GetSSARiskFieldGroupEx(ctx context.Context, req *ypb.GetSSARiskFieldGroupRequest) (*ypb.SSARiskFieldGroupResponse, error)

func (*Server) GetSimpleDetectRecordRequestById added in v1.3.3 

func (s *Server) GetSimpleDetectRecordRequestById(ctx context.Context, req *ypb.GetUnfinishedTaskDetailByIdRequest) (*ypb.RecordPortScanRequest, error)

func (*Server) GetSimpleDetectUnfinishedTask 

func (s *Server) GetSimpleDetectUnfinishedTask(ctx context.Context, req *ypb.Empty) (*ypb.GetSimpleDetectUnfinishedTaskResponse, error)

func (*Server) GetSimpleDetectUnfinishedTaskByUid 

func (s *Server) GetSimpleDetectUnfinishedTaskByUid(ctx context.Context, req *ypb.GetExecBatchYakScriptUnfinishedTaskByUidRequest) (*ypb.RecordPortScanRequest, error)

func (*Server) GetSpaceEngineAccountStatus added in v1.3.1 

func (s *Server) GetSpaceEngineAccountStatus(ctx context.Context, req *ypb.GetSpaceEngineAccountStatusRequest) (result *ypb.SpaceEngineStatus, err error)

func (*Server) GetSpaceEngineAccountStatusV2 

func (s *Server) GetSpaceEngineAccountStatusV2(ctx context.Context, req *ypb.ThirdPartyApplicationConfig) (result *ypb.SpaceEngineStatus, err error)

func (*Server) GetSpaceEngineStatus added in v1.2.9 

func (s *Server) GetSpaceEngineStatus(ctx context.Context, req *ypb.GetSpaceEngineStatusRequest) (*ypb.SpaceEngineStatus, error)

func (*Server) GetSupportedLocalModels 

func (s *Server) GetSupportedLocalModels(ctx context.Context, req *ypb.Empty) (*ypb.GetSupportedLocalModelsResponse, error)

GetSupportedLocalModels 获取支持的本地模型列表

func (*Server) GetSystemDefaultDnsServers added in v1.2.3 

func (s *Server) GetSystemDefaultDnsServers(ctx context.Context, req *ypb.Empty) (*ypb.DefaultDnsServerResponse, error)

func (*Server) GetSystemProxy 

func (s *Server) GetSystemProxy(ctx context.Context, req *ypb.Empty) (*ypb.GetSystemProxyResult, error)

func (*Server) GetTemporaryProject added in v1.3.0 

func (s *Server) GetTemporaryProject(ctx context.Context, req *ypb.Empty) (*ypb.ProjectDescription, error)

func (*Server) GetTemporaryProjectEx 

func (s *Server) GetTemporaryProjectEx(ctx context.Context, req *ypb.GetTemporaryProjectExRequest) (*ypb.ProjectDescription, error)

func (*Server) GetThirdPartyAppConfigTemplate 

func (s *Server) GetThirdPartyAppConfigTemplate(ctx context.Context, _ *ypb.Empty) (*ypb.GetThirdPartyAppConfigTemplateResponse, error)

func (*Server) GetToolSetList 

func (s *Server) GetToolSetList(ctx context.Context, req *ypb.Empty) (*ypb.GetToolSetListResponse, error)

func (*Server) GetTunnelServerExternalIP 

func (s *Server) GetTunnelServerExternalIP(ctx context.Context, p *ypb.GetTunnelServerExternalIPParams) (*ypb.GetTunnelServerExternalIPResponse, error)

func (*Server) GetYakScriptById 

func (s *Server) GetYakScriptById(ctx context.Context, req *ypb.GetYakScriptByIdRequest) (*ypb.YakScript, error)

func (*Server) GetYakScriptByName 

func (s *Server) GetYakScriptByName(ctx context.Context, req *ypb.GetYakScriptByNameRequest) (*ypb.YakScript, error)

func (*Server) GetYakScriptByOnlineID 

func (s *Server) GetYakScriptByOnlineID(ctx context.Context, req *ypb.GetYakScriptByOnlineIDRequest) (*ypb.YakScript, error)

func (*Server) GetYakScriptGroup added in v1.3.1 

func (s *Server) GetYakScriptGroup(ctx context.Context, req *ypb.QueryYakScriptRequest) (*ypb.GetYakScriptGroupResponse, error)

func (*Server) GetYakScriptTags 

func (s *Server) GetYakScriptTags(c context.Context, req *ypb.Empty) (*ypb.GetYakScriptTagsResponse, error)

func (*Server) GetYakScriptTagsAndType 

func (s *Server) GetYakScriptTagsAndType(ctx context.Context, req *ypb.Empty) (*ypb.GetYakScriptTagsAndTypeResponse, error)

func (*Server) GetYakVMBuildInMethodCompletion 

func (s *Server) GetYakVMBuildInMethodCompletion(
	ctx context.Context,
	req *ypb.GetYakVMBuildInMethodCompletionRequest,
) (*ypb.GetYakVMBuildInMethodCompletionResponse, error)

func (*Server) GetYakitCompletionRaw 

func (s *Server) GetYakitCompletionRaw(ctx context.Context, _ *ypb.Empty) (*ypb.YakitCompletionRawResponse, error)

func (*Server) GroupTableColumn 

func (s *Server) GroupTableColumn(ctx context.Context, req *ypb.GroupTableColumnRequest) (*ypb.GroupTableColumnResponse, error)

func (*Server) HTTPFlowsData added in v1.3.3 

func (s *Server) HTTPFlowsData(ctx context.Context, httpFlow *schema.HTTPFlow) (*schema.HTTPFlow, []*schema.ExtractedData, []*schema.WebsocketFlow, []*schema.ProjectGeneralStorage)

func (*Server) HTTPFlowsExtract added in v1.2.2 

func (s *Server) HTTPFlowsExtract(ctx context.Context, req *ypb.HTTPFlowsExtractRequest) (*ypb.Empty, error)

func (*Server) HTTPFlowsFieldGroup 

func (s *Server) HTTPFlowsFieldGroup(ctx context.Context, req *ypb.HTTPFlowsFieldGroupRequest) (*ypb.HTTPFlowsFieldGroupResponse, error)

func (*Server) HTTPFlowsShare added in v1.2.2 

func (s *Server) HTTPFlowsShare(ctx context.Context, req *ypb.HTTPFlowsShareRequest) (*ypb.HTTPFlowsShareResponse, error)

func (*Server) HTTPFlowsToOnline added in v1.3.3 

func (s *Server) HTTPFlowsToOnline(ctx context.Context, req *ypb.HTTPFlowsToOnlineRequest) (*ypb.Empty, error)

func (*Server) HTTPFlowsToOnlineBatch 

func (s *Server) HTTPFlowsToOnlineBatch(ctx context.Context, req *ypb.HTTPFlowsToOnlineBatchRequest) (*ypb.HTTPFlowsToOnlineBatchResponse, error)

func (*Server) HTTPFuzzer 

func (s *Server) HTTPFuzzer(req *ypb.FuzzerRequest, stream ypb.Yak_HTTPFuzzerServer) (finalError error)

func (*Server) HTTPFuzzerGroup 

func (s *Server) HTTPFuzzerGroup(req *ypb.GroupHTTPFuzzerRequest, stream ypb.Yak_HTTPFuzzerGroupServer) error

func (*Server) HTTPFuzzerSequence added in v1.2.4 

func (s *Server) HTTPFuzzerSequence(seqreq *ypb.FuzzerRequests, stream ypb.Yak_HTTPFuzzerSequenceServer) error

func (*Server) HTTPRequestAnalyzer 

func (s *Server) HTTPRequestAnalyzer(ctx context.Context, req *ypb.HTTPRequestAnalysisMaterial) (*ypb.HTTPRequestAnalysis, error)

func (*Server) HTTPRequestBuilder added in v1.2.2 

func (s *Server) HTTPRequestBuilder(ctx context.Context, req *ypb.HTTPRequestBuilderParams) (*ypb.HTTPRequestBuilderResponse, error)

func (*Server) HTTPRequestMutate 

func (s *Server) HTTPRequestMutate(ctx context.Context, req *ypb.HTTPRequestMutateParams) (*ypb.MutateResult, error)

已弃用，使用 common\yak\yaklib\codec\codegrpc\codec_grpc_methods.go:HTTPRequestMutate

func (*Server) HTTPResponseMutate 

func (s *Server) HTTPResponseMutate(ctx context.Context, req *ypb.HTTPResponseMutateParams) (*ypb.MutateResult, error)

func (*Server) Handshake 

func (s *Server) Handshake(ctx context.Context, req *ypb.HandshakeRequest) (*ypb.HandshakeResponse, error)

func (*Server) HybridScan added in v1.2.9 

func (s *Server) HybridScan(stream ypb.Yak_HybridScanServer) error

func (*Server) IgnoreYakScript 

func (s *Server) IgnoreYakScript(ctx context.Context, req *ypb.DeleteYakScriptRequest) (*ypb.Empty, error)

func (*Server) ImportChaosMakerRules 

func (s *Server) ImportChaosMakerRules(ctx context.Context, req *ypb.ImportChaosMakerRulesRequest) (*ypb.Empty, error)

func (*Server) ImportFingerprint 

func (s *Server) ImportFingerprint(req *ypb.ImportFingerprintRequest, stream ypb.Yak_ImportFingerprintServer) error

func (*Server) ImportHTTPFlowStream 

func (s *Server) ImportHTTPFlowStream(req *ypb.ImportHTTPFlowStreamRequest, stream ypb.Yak_ImportHTTPFlowStreamServer) error

func (*Server) ImportHTTPFuzzerTaskFromYaml added in v1.2.7 

func (s *Server) ImportHTTPFuzzerTaskFromYaml(ctx context.Context, req *ypb.ImportHTTPFuzzerTaskFromYamlRequest) (*ypb.ImportHTTPFuzzerTaskFromYamlResponse, error)

ImportHTTPFuzzerTaskFromYaml yaml -> yakTemplate -> fuzzerRequest

func (*Server) ImportKnowledgeBase 

func (s *Server) ImportKnowledgeBase(req *ypb.ImportKnowledgeBaseRequest, stream ypb.Yak_ImportKnowledgeBaseServer) error

ImportKnowledgeBase 从指定路径导入知识库

func (*Server) ImportMITMReplacerRules 

func (s *Server) ImportMITMReplacerRules(ctx context.Context, req *ypb.ImportMITMReplacerRulesRequest) (*ypb.Empty, error)

func (*Server) ImportMenuItem 

func (s *Server) ImportMenuItem(ctx context.Context, req *ypb.ImportMenuItemRequest) (*ypb.Empty, error)

func (*Server) ImportNote 

func (s *Server) ImportNote(req *ypb.ImportNoteRequest, stream ypb.Yak_ImportNoteServer) error

func (*Server) ImportProject 

func (s *Server) ImportProject(req *ypb.ImportProjectRequest, stream ypb.Yak_ImportProjectServer) error

func (*Server) ImportSSARisk 

func (s *Server) ImportSSARisk(req *ypb.ImportSSARiskRequest, stream ypb.Yak_ImportSSARiskServer) error

func (*Server) ImportSyntaxFlows 

func (s *Server) ImportSyntaxFlows(req *ypb.ImportSyntaxFlowsRequest, stream ypb.Yak_ImportSyntaxFlowsServer) error

func (*Server) ImportYakScript added in v1.3.0 

func (s *Server) ImportYakScript(req *ypb.ImportYakScriptRequest, stream ypb.Yak_ImportYakScriptServer) error

func (*Server) ImportYakScriptStream 

func (s *Server) ImportYakScriptStream(
	req *ypb.ImportYakScriptStreamRequest,
	stream ypb.Yak_ImportYakScriptStreamServer,
) error

func (*Server) InitSearchVectorDatabase 

func (s *Server) InitSearchVectorDatabase(req *ypb.InitSearchVectorDatabaseRequest, stream ypb.Yak_InitSearchVectorDatabaseServer) error

func (*Server) InstallLlamaServer 

func (s *Server) InstallLlamaServer(req *ypb.InstallLlamaServerRequest, stream ypb.Yak_InstallLlamaServerServer) error

InstallLocalModel 安装本地模型（主要是下载llama-server）

func (*Server) InstallMITMCertificate 

func (s *Server) InstallMITMCertificate(ctx context.Context, _ *ypb.Empty) (*ypb.GeneralResponse, error)

func (*Server) InstallScrecorder 

func (s *Server) InstallScrecorder(req *ypb.InstallScrecorderRequest, stream ypb.Yak_InstallScrecorderServer) error

func (*Server) InstallThirdPartyBinary 

func (s *Server) InstallThirdPartyBinary(req *ypb.InstallThirdPartyBinaryRequest, stream ypb.Yak_InstallThirdPartyBinaryServer) error

func (*Server) InstallVulinbox added in v1.2.3 

func (s *Server) InstallVulinbox(req *ypb.InstallVulinboxRequest, stream ypb.Yak_InstallVulinboxServer) error

func (*Server) IsCVEDatabaseReady 

func (s *Server) IsCVEDatabaseReady(ctx context.Context, req *ypb.IsCVEDatabaseReadyRequest) (*ypb.IsCVEDatabaseReadyResponse, error)

func (*Server) IsLlamaServerReady 

func (s *Server) IsLlamaServerReady(ctx context.Context, req *ypb.Empty) (*ypb.IsLlamaServerReadyResponse, error)

IsLlamaServerReady 检查llama-server是否已安装并可用

func (*Server) IsLocalModelReady 

func (s *Server) IsLocalModelReady(ctx context.Context, req *ypb.IsLocalModelReadyRequest) (*ypb.IsLocalModelReadyResponse, error)

IsLocalModelReady 检查本地模型是否就绪

func (*Server) IsMultipartFormDataRequest 

func (s *Server) IsMultipartFormDataRequest(ctx context.Context, req *ypb.FixUploadPacketRequest) (*ypb.IsMultipartFormDataRequestResult, error)

func (*Server) IsPrivilegedForNetRaw 

func (s *Server) IsPrivilegedForNetRaw(ctx context.Context, req *ypb.Empty) (*ypb.IsPrivilegedForNetRawResponse, error)

func (*Server) IsProjectNameValid 

func (s *Server) IsProjectNameValid(ctx context.Context, req *ypb.IsProjectNameValidRequest) (*ypb.Empty, error)

func (*Server) IsRemoteAddrAvailable 

func (s *Server) IsRemoteAddrAvailable(ctx context.Context, req *ypb.IsRemoteAddrAvailableRequest) (*ypb.IsRemoteAddrAvailableResponse, error)

func (*Server) IsScrecorderReady 

func (s *Server) IsScrecorderReady(ctx context.Context, req *ypb.IsScrecorderReadyRequest) (*ypb.IsScrecorderReadyResponse, error)

func (*Server) IsSearchVectorDatabaseReady 

func (s *Server) IsSearchVectorDatabaseReady(ctx context.Context, req *ypb.IsSearchVectorDatabaseReadyRequest) (*ypb.IsSearchVectorDatabaseReadyResponse, error)

func (*Server) IsThirdPartyBinaryReady 

func (s *Server) IsThirdPartyBinaryReady(ctx context.Context, req *ypb.IsThirdPartyBinaryReadyRequest) (*ypb.IsThirdPartyBinaryReadyResponse, error)

func (*Server) IsVulinboxReady added in v1.2.3 

func (s *Server) IsVulinboxReady(ctx context.Context, req *ypb.IsVulinboxReadyRequest) (*ypb.IsVulinboxReadyResponse, error)

func (*Server) ListAiModel 

func (s *Server) ListAiModel(ctx context.Context, req *ypb.ListAiModelRequest) (*ypb.ListAiModelResponse, error)

func (*Server) ListEntityRepository 

func (s *Server) ListEntityRepository(ctx context.Context, req *ypb.Empty) (*ypb.ListEntityRepositoryResponse, error)

ListEntityRepository 列出所有实体仓库

func (*Server) ListThirdPartyBinary 

func (s *Server) ListThirdPartyBinary(ctx context.Context, req *ypb.Empty) (*ypb.ListThirdPartyBinaryResponse, error)

func (*Server) ListVectorStoreEntries 

func (s *Server) ListVectorStoreEntries(ctx context.Context, req *ypb.ListVectorStoreEntriesRequest) (*ypb.ListVectorStoreEntriesResponse, error)

ListVectorStoreEntries 列出向量存储条目

func (*Server) LoadNucleiTemplates 

func (s *Server) LoadNucleiTemplates(ctx context.Context, req *ypb.Empty) (*ypb.Empty, error)

func (*Server) MITM 

func (s *Server) MITM(stream ypb.Yak_MITMServer) error

func (*Server) MITMV2 

func (s *Server) MITMV2(stream ypb.Yak_MITMV2Server) error

func (*Server) MatchHTTPResponse 

func (s *Server) MatchHTTPResponse(ctx context.Context, req *ypb.MatchHTTPResponseParams) (*ypb.MatchHTTPResponseResult, error)

func (*Server) MigrateLegacyDatabase 

func (s *Server) MigrateLegacyDatabase(ctx context.Context, req *ypb.Empty) (*ypb.Empty, error)

func (*Server) MigratePayloads added in v1.3.0 

func (s *Server) MigratePayloads(req *ypb.Empty, stream ypb.Yak_MigratePayloadsServer) error

func (*Server) MigrateSSAProject 

func (s *Server) MigrateSSAProject(req *ypb.MigrateSSAProjectRequest, stream ypb.Yak_MigrateSSAProjectServer) error

func (*Server) NewCodec added in v1.2.6 

func (s *Server) NewCodec(ctx context.Context, req *ypb.CodecRequestFlow) (resp *ypb.CodecResponse, err error)

func (*Server) NewProject 

func (s *Server) NewProject(ctx context.Context, req *ypb.NewProjectRequest) (*ypb.NewProjectResponse, error)

func (*Server) NewRiskRead 

func (s *Server) NewRiskRead(ctx context.Context, req *ypb.NewRiskReadRequest) (*ypb.Empty, error)

func (*Server) NewSSARiskRead 

func (s *Server) NewSSARiskRead(ctx context.Context, req *ypb.NewSSARiskReadRequest) (*ypb.NewSSARiskReadResponse, error)

func (*Server) OpenPort 

func (s *Server) OpenPort(inputStream ypb.Yak_OpenPortServer) error

func (*Server) PacketPrettifyHelper added in v1.2.5 

func (s *Server) PacketPrettifyHelper(ctx context.Context, req *ypb.PacketPrettifyHelperRequest) (*ypb.PacketPrettifyHelperResponse, error)

func (*Server) ParseTraffic added in v1.3.0 

func (s *Server) ParseTraffic(ctx context.Context, req *ypb.ParseTrafficRequest) (*ypb.ParseTrafficResponse, error)

func (*Server) PcapX added in v1.2.8 

func (s *Server) PcapX(stream ypb.Yak_PcapXServer) error

func (*Server) Ping added in v1.3.0 

func (s *Server) Ping(ctx context.Context, req *ypb.WebShellRequest) (*ypb.WebShellResponse, error)

func (*Server) PluginGenerator added in v1.2.9 

func (s *Server) PluginGenerator(l *list.List, ctx context.Context, plugin *ypb.HybridScanPluginConfig) (chan *schema.YakScript, error)

func (*Server) PluginListGenerator added in v1.3.2 

func (s *Server) PluginListGenerator(plugin *ypb.HybridScanPluginConfig, ctx context.Context) (res []string)

func (*Server) PluginTrace 

func (s *Server) PluginTrace(stream ypb.Yak_PluginTraceServer) error

PluginTrace 实现插件执行跟踪的双向流服务

func (*Server) PopExecBatchYakScriptUnfinishedTaskByUid 

func (s *Server) PopExecBatchYakScriptUnfinishedTaskByUid(ctx context.Context, req *ypb.GetExecBatchYakScriptUnfinishedTaskByUidRequest) (*ypb.ExecBatchYakScriptRequest, error)

func (*Server) PopSimpleDetectUnfinishedTaskByUid 

func (s *Server) PopSimpleDetectUnfinishedTaskByUid(ctx context.Context, req *ypb.GetExecBatchYakScriptUnfinishedTaskByUidRequest) (*ypb.RecordPortScanRequest, error)

func (*Server) PortScan 

func (s *Server) PortScan(req *ypb.PortScanRequest, stream ypb.Yak_PortScanServer) error

func (*Server) PreRenderVariables added in v1.2.7 

func (s *Server) PreRenderVariables(ctx context.Context, params []*ypb.FuzzerParamItem, https, gmtls, syncTagIndex bool) chan map[string]any

func (*Server) PreloadHTTPFuzzerParams 

func (s *Server) PreloadHTTPFuzzerParams(ctx context.Context, req *ypb.PreloadHTTPFuzzerParamsRequest) (*ypb.PreloadHTTPFuzzerParamsResponse, error)

func (*Server) PromotePermissionForUserPcap 

func (s *Server) PromotePermissionForUserPcap(ctx context.Context, req *ypb.Empty) (*ypb.Empty, error)

func (*Server) QueryAIEvent 

func (s *Server) QueryAIEvent(ctx context.Context, req *ypb.AIEventQueryRequest) (*ypb.AIEventQueryResponse, error)

func (*Server) QueryAIForge 

func (s *Server) QueryAIForge(ctx context.Context, req *ypb.QueryAIForgeRequest) (*ypb.QueryAIForgeResponse, error)

func (*Server) QueryAITask 

func (s *Server) QueryAITask(ctx context.Context, req *ypb.AITaskQueryRequest) (*ypb.AITaskQueryResponse, error)

func (*Server) QueryAllMenuItem 

func (s *Server) QueryAllMenuItem(ctx context.Context, req *ypb.QueryAllMenuItemRequest) (*ypb.MenuByGroup, error)

func (*Server) QueryAvailableReportFrom 

func (s *Server) QueryAvailableReportFrom(ctx context.Context, _ *ypb.Empty) (*ypb.Fields, error)

func (*Server) QueryAvailableRiskLevel 

func (s *Server) QueryAvailableRiskLevel(ctx context.Context, _ *ypb.Empty) (*ypb.Fields, error)

func (*Server) QueryAvailableRiskType 

func (s *Server) QueryAvailableRiskType(ctx context.Context, req *ypb.Empty) (*ypb.Fields, error)

func (*Server) QueryCVE 

func (s *Server) QueryCVE(ctx context.Context, req *ypb.QueryCVERequest) (*ypb.QueryCVEResponse, error)

func (*Server) QueryChaosMakerRule 

func (s *Server) QueryChaosMakerRule(ctx context.Context, req *ypb.QueryChaosMakerRuleRequest) (*ypb.QueryChaosMakerRuleResponse, error)

func (*Server) QueryDNSLogByToken 

func (s *Server) QueryDNSLogByToken(ctx context.Context, req *ypb.QueryDNSLogByTokenRequest) (*ypb.QueryDNSLogByTokenResponse, error)

func (*Server) QueryDNSLogTokenByScript added in v1.2.6 

func (s *Server) QueryDNSLogTokenByScript(ctx context.Context, req *ypb.RequireDNSLogDomainByScriptRequest) (*ypb.QueryDNSLogByTokenResponse, error)

func (*Server) QueryDomains 

func (s *Server) QueryDomains(ctx context.Context, req *ypb.QueryDomainsRequest) (*ypb.QueryDomainsResponse, error)

func (*Server) QueryEntity 

func (s *Server) QueryEntity(ctx context.Context, req *ypb.QueryEntityRequest) (*ypb.QueryEntityResponse, error)

QueryEntity 查询实体

func (*Server) QueryExecHistory 

func (s *Server) QueryExecHistory(ctx context.Context, req *ypb.ExecHistoryRequest) (*ypb.ExecHistoryRecordResponse, error)

func (*Server) QueryFingerprint 

func (s *Server) QueryFingerprint(ctx context.Context, req *ypb.QueryFingerprintRequest) (*ypb.QueryFingerprintResponse, error)

func (*Server) QueryFuzzerConfig 

func (s *Server) QueryFuzzerConfig(ctx context.Context, params *ypb.QueryFuzzerConfigRequest) (*ypb.QueryFuzzerConfigResponse, error)

func (*Server) QueryFuzzerLabel added in v1.2.3 

func (s *Server) QueryFuzzerLabel(ctx context.Context, req *ypb.Empty) (*ypb.QueryFuzzerLabelResponse, error)

func (*Server) QueryGroupsByYakScriptId 

func (s *Server) QueryGroupsByYakScriptId(ctx context.Context, req *ypb.QueryGroupsByYakScriptIdRequest) (*ypb.GroupNames, error)

func (*Server) QueryHTTPFlows 

func (s *Server) QueryHTTPFlows(ctx context.Context, req *ypb.QueryHTTPFlowRequest) (*ypb.QueryHTTPFlowResponse, error)

func (*Server) QueryHTTPFlowsIds 

func (s *Server) QueryHTTPFlowsIds(ctx context.Context, req *ypb.QueryHTTPFlowsIdsRequest) (*ypb.QueryHTTPFlowsIdsResponse, error)

似乎已弃用？没有调用

func (*Server) QueryHTTPFlowsProcessNames 

func (s *Server) QueryHTTPFlowsProcessNames(ctx context.Context, req *ypb.QueryHTTPFlowRequest) (*ypb.QueryHTTPFlowsProcessNamesResponse, error)

func (*Server) QueryHTTPFuzzerResponseByTaskId added in v1.3.3 

func (s *Server) QueryHTTPFuzzerResponseByTaskId(ctx context.Context, req *ypb.QueryHTTPFuzzerResponseByTaskIdRequest) (*ypb.QueryHTTPFuzzerResponseByTaskIdResponse, error)

func (*Server) QueryHistoryHTTPFuzzerTask 

func (s *Server) QueryHistoryHTTPFuzzerTask(ctx context.Context, req *ypb.Empty) (*ypb.HistoryHTTPFuzzerTasks, error)

Deprecated

func (*Server) QueryHistoryHTTPFuzzerTaskEx 

func (s *Server) QueryHistoryHTTPFuzzerTaskEx(ctx context.Context, req *ypb.QueryHistoryHTTPFuzzerTaskExParams) (*ypb.HistoryHTTPFuzzerTasksResponse, error)

func (*Server) QueryHosts 

func (s *Server) QueryHosts(ctx context.Context, req *ypb.QueryHostsRequest) (*ypb.QueryHostsResponse, error)

func (*Server) QueryHotPatchTemplate 

func (s *Server) QueryHotPatchTemplate(ctx context.Context, req *ypb.HotPatchTemplateRequest) (*ypb.QueryHotPatchTemplateResponse, error)

func (*Server) QueryHotPatchTemplateList 

func (s *Server) QueryHotPatchTemplateList(ctx context.Context, req *ypb.QueryHotPatchTemplateListRequest) (*ypb.QueryHotPatchTemplateListResponse, error)

func (*Server) QueryHybridScanTask added in v1.2.9 

func (s *Server) QueryHybridScanTask(ctx context.Context, request *ypb.QueryHybridScanTaskRequest) (*ypb.QueryHybridScanTaskResponse, error)

func (*Server) QueryICMPTrigger 

func (s *Server) QueryICMPTrigger(ctx context.Context, req *ypb.QueryICMPTriggerRequest) (*ypb.QueryICMPTriggerResponse, error)

func (*Server) QueryKnowledgeBaseByAI 

func (s *Server) QueryKnowledgeBaseByAI(req *ypb.QueryKnowledgeBaseByAIRequest, stream ypb.Yak_QueryKnowledgeBaseByAIServer) error

rpc QueryKnowledgeBaseByAI(QueryKnowledgeBaseByAIRequest) returns(stream QueryKnowledgeBaseByAIResponse);

func (*Server) QueryMITMReplacerRules 

func (s *Server) QueryMITMReplacerRules(ctx context.Context, req *ypb.QueryMITMReplacerRulesRequest) (*ypb.QueryMITMReplacerRulesResponse, error)

func (*Server) QueryMITMRuleExtractedData 

func (s *Server) QueryMITMRuleExtractedData(ctx context.Context, req *ypb.QueryMITMRuleExtractedDataRequest) (*ypb.QueryMITMRuleExtractedDataResponse, error)

func (*Server) QueryNavigationGroups added in v1.2.3 

func (s *Server) QueryNavigationGroups(ctx context.Context, req *ypb.QueryNavigationGroupsRequest) (*ypb.GroupNames, error)

func (*Server) QueryNewRisk 

func (s *Server) QueryNewRisk(ctx context.Context, req *ypb.QueryNewRiskRequest) (*ypb.QueryNewRiskResponse, error)

func (*Server) QueryNewSSARisks 

func (s *Server) QueryNewSSARisks(ctx context.Context, req *ypb.QueryNewSSARisksRequest) (*ypb.QueryNewSSARisksResponse, error)

func (*Server) QueryNote 

func (s *Server) QueryNote(ctx context.Context, req *ypb.QueryNoteRequest) (*ypb.QueryNoteResponse, error)

func (*Server) QueryOnlinePlugins 

func (s *Server) QueryOnlinePlugins(ctx context.Context, req *ypb.QueryOnlinePluginsRequest) (*ypb.QueryOnlinePluginsResponse, error)

func (*Server) QueryPayload 

func (s *Server) QueryPayload(ctx context.Context, req *ypb.QueryPayloadRequest) (*ypb.QueryPayloadResponse, error)

func (*Server) QueryPayloadFromFile added in v1.2.9 

func (s *Server) QueryPayloadFromFile(ctx context.Context, req *ypb.QueryPayloadFromFileRequest) (*ypb.QueryPayloadFromFileResponse, error)

func (*Server) QueryPluginEnv 

func (s *Server) QueryPluginEnv(ctx context.Context, request *ypb.QueryPluginEnvRequest) (*ypb.PluginEnvData, error)

func (*Server) QueryPorts 

func (s *Server) QueryPorts(ctx context.Context, req *ypb.QueryPortsRequest) (*ypb.QueryPortsResponse, error)

func (*Server) QueryPortsGroup added in v1.2.2 

func (s *Server) QueryPortsGroup(ctx context.Context, req *ypb.Empty) (*ypb.QueryPortsGroupResponse, error)

func (*Server) QueryProjectDetail 

func (s *Server) QueryProjectDetail(ctx context.Context, req *ypb.QueryProjectDetailRequest) (*ypb.ProjectDescription, error)

func (*Server) QueryRandomPortTrigger 

func (s *Server) QueryRandomPortTrigger(ctx context.Context, r *ypb.QueryRandomPortTriggerRequest) (*ypb.RandomPortTriggerNotification, error)

func (*Server) QueryRelationship 

func (s *Server) QueryRelationship(ctx context.Context, req *ypb.QueryRelationshipRequest) (*ypb.QueryRelationshipResponse, error)

QueryRelationship 查询关系

func (*Server) QueryReport 

func (s *Server) QueryReport(ctx context.Context, d *ypb.QueryReportRequest) (*ypb.Report, error)

func (*Server) QueryReports 

func (s *Server) QueryReports(ctx context.Context, d *ypb.QueryReportsRequest) (*ypb.QueryReportsResponse, error)

func (*Server) QueryRisk 

func (s *Server) QueryRisk(ctx context.Context, req *ypb.QueryRiskRequest) (*ypb.Risk, error)

func (*Server) QueryRiskTableStats 

func (s *Server) QueryRiskTableStats(ctx context.Context, e *ypb.Empty) (*ypb.RiskTableStats, error)

func (*Server) QueryRiskTags 

func (s *Server) QueryRiskTags(ctx context.Context, req *ypb.Empty) (*ypb.QueryRiskTagsResponse, error)

func (*Server) QueryRisks 

func (s *Server) QueryRisks(ctx context.Context, req *ypb.QueryRisksRequest) (*ypb.QueryRisksResponse, error)

func (*Server) QuerySSAPrograms 

func (s *Server) QuerySSAPrograms(ctx context.Context, req *ypb.QuerySSAProgramRequest) (*ypb.QuerySSAProgramResponse, error)

func (*Server) QuerySSAProject 

func (s *Server) QuerySSAProject(ctx context.Context, req *ypb.QuerySSAProjectRequest) (*ypb.QuerySSAProjectResponse, error)

func (*Server) QuerySSARiskDisposals 

func (s *Server) QuerySSARiskDisposals(ctx context.Context, req *ypb.QuerySSARiskDisposalsRequest) (*ypb.QuerySSARiskDisposalsResponse, error)

func (*Server) QuerySSARisks 

func (s *Server) QuerySSARisks(ctx context.Context, req *ypb.QuerySSARisksRequest) (*ypb.QuerySSARisksResponse, error)

func (*Server) QueryScreenRecorders 

func (s *Server) QueryScreenRecorders(ctx context.Context, req *ypb.QueryScreenRecorderRequest) (*ypb.QueryScreenRecorderResponse, error)

func (*Server) QuerySimpleDetectUnfinishedTask added in v1.3.3 

func (s *Server) QuerySimpleDetectUnfinishedTask(ctx context.Context, req *ypb.QueryUnfinishedTaskRequest) (*ypb.QueryUnfinishedTaskResponse, error)

func (*Server) QuerySnippets 

func (s *Server) QuerySnippets(ctx context.Context, req *ypb.QuerySnippetsRequest) (*ypb.SnippetsResponse, error)

func (*Server) QuerySubERM 

func (s *Server) QuerySubERM(ctx context.Context, req *ypb.QuerySubERMRequest) (*ypb.QuerySubERMResponse, error)

func (*Server) QuerySupportedDnsLogPlatforms added in v1.2.6 

func (s *Server) QuerySupportedDnsLogPlatforms(ctx context.Context, req *ypb.Empty) (*ypb.QuerySupportedDnsLogPlatformsResponse, error)

func (*Server) QuerySyntaxFlowResult 

func (s *Server) QuerySyntaxFlowResult(ctx context.Context, req *ypb.QuerySyntaxFlowResultRequest) (*ypb.QuerySyntaxFlowResultResponse, error)

func (*Server) QuerySyntaxFlowRule 

func (s *Server) QuerySyntaxFlowRule(ctx context.Context, req *ypb.QuerySyntaxFlowRuleRequest) (*ypb.QuerySyntaxFlowRuleResponse, error)

func (*Server) QuerySyntaxFlowRuleGroup 

func (s *Server) QuerySyntaxFlowRuleGroup(ctx context.Context, req *ypb.QuerySyntaxFlowRuleGroupRequest) (*ypb.QuerySyntaxFlowRuleGroupResponse, error)

func (*Server) QuerySyntaxFlowSameGroup 

func (s *Server) QuerySyntaxFlowSameGroup(ctx context.Context, req *ypb.QuerySyntaxFlowSameGroupRequest) (*ypb.QuerySyntaxFlowSameGroupResponse, error)

func (*Server) QuerySyntaxFlowScanTask 

func (s *Server) QuerySyntaxFlowScanTask(ctx context.Context, request *ypb.QuerySyntaxFlowScanTaskRequest) (*ypb.QuerySyntaxFlowScanTaskResponse, error)

func (*Server) QueryTrafficPacket added in v1.2.8 

func (s *Server) QueryTrafficPacket(ctx context.Context, req *ypb.QueryTrafficPacketRequest) (*ypb.QueryTrafficPacketResponse, error)

func (*Server) QueryTrafficSession added in v1.2.8 

func (s *Server) QueryTrafficSession(ctx context.Context, req *ypb.QueryTrafficSessionRequest) (*ypb.QueryTrafficSessionResponse, error)

func (*Server) QueryTrafficTCPReassembled added in v1.2.8 

func (s *Server) QueryTrafficTCPReassembled(ctx context.Context, req *ypb.QueryTrafficTCPReassembledRequest) (*ypb.QueryTrafficTCPReassembledResponse, error)

func (*Server) QueryWebShells added in v1.3.0 

func (s *Server) QueryWebShells(ctx context.Context, req *ypb.QueryWebShellsRequest) (*ypb.QueryWebShellsResponse, error)

func (*Server) QueryWebsocketFlowByHTTPFlowWebsocketHash 

func (s *Server) QueryWebsocketFlowByHTTPFlowWebsocketHash(ctx context.Context, req *ypb.QueryWebsocketFlowByHTTPFlowWebsocketHashRequest) (*ypb.WebsocketFlows, error)

func (*Server) QueryYakScript 

func (s *Server) QueryYakScript(ctx context.Context, req *ypb.QueryYakScriptRequest) (*ypb.QueryYakScriptResponse, error)

func (*Server) QueryYakScriptByIsCore added in v1.2.4 

func (s *Server) QueryYakScriptByIsCore(ctx context.Context, req *ypb.QueryYakScriptByIsCoreRequest) (*ypb.QueryYakScriptByIsCoreResponse, error)

func (*Server) QueryYakScriptByNames added in v1.2.3 

func (s *Server) QueryYakScriptByNames(ctx context.Context, req *ypb.QueryYakScriptByNamesRequest) (*ypb.QueryYakScriptByNamesResponse, error)

func (*Server) QueryYakScriptByOnlineGroup 

func (s *Server) QueryYakScriptByOnlineGroup(c context.Context, req *ypb.QueryYakScriptByOnlineGroupRequest) (*ypb.QueryYakScriptLocalAndUserResponse, error)

func (*Server) QueryYakScriptByYakScriptName 

func (s *Server) QueryYakScriptByYakScriptName(req *ypb.QueryYakScriptRequest, stream ypb.Yak_QueryYakScriptByYakScriptNameServer) error

func (*Server) QueryYakScriptExecResult 

func (s *Server) QueryYakScriptExecResult(ctx context.Context, req *ypb.QueryYakScriptExecResultRequest) (*ypb.QueryYakScriptExecResultResponse, error)

func (*Server) QueryYakScriptGroup added in v1.3.1 

func (s *Server) QueryYakScriptGroup(ctx context.Context, req *ypb.QueryYakScriptGroupRequest) (*ypb.QueryYakScriptGroupResponse, error)

func (*Server) QueryYakScriptLocalAll 

func (s *Server) QueryYakScriptLocalAll(c context.Context, req *ypb.Empty) (*ypb.QueryYakScriptLocalAndUserResponse, error)

func (*Server) QueryYakScriptLocalAndUser 

func (s *Server) QueryYakScriptLocalAndUser(c context.Context, req *ypb.QueryYakScriptLocalAndUserRequest) (*ypb.QueryYakScriptLocalAndUserResponse, error)

func (*Server) QueryYakScriptNameInExecResult 

func (s *Server) QueryYakScriptNameInExecResult(ctx context.Context, req *ypb.Empty) (*ypb.YakScriptNames, error)

func (*Server) QueryYakScriptRiskDetailByCWE added in v1.2.9 

func (s *Server) QueryYakScriptRiskDetailByCWE(ctx context.Context, req *ypb.QueryYakScriptRiskDetailByCWERequest) (*ypb.QueryYakScriptRiskDetailByCWEResponse, error)

func (*Server) QueryYakScriptSkipUpdate 

func (s *Server) QueryYakScriptSkipUpdate(ctx context.Context, req *ypb.QueryYakScriptRequest) (*ypb.QueryYakScriptSkipUpdateResponse, error)

func (*Server) QueryYakScriptTagsGroup added in v1.2.3 

func (s *Server) QueryYakScriptTagsGroup(db *gorm.DB) []*ypb.Tags

func (*Server) RAGCollectionSearch 

func (s *Server) RAGCollectionSearch(req *ypb.RAGCollectionSearchRequest, stream ypb.Yak_RAGCollectionSearchServer) (err error)

func (*Server) ReadFile 

func (s *Server) ReadFile(req *ypb.ReadFileRequest, stream ypb.Yak_ReadFileServer) error

func (*Server) RecoverBuiltinFingerprint 

func (s *Server) RecoverBuiltinFingerprint(ctx context.Context, _ *ypb.Empty) (*ypb.DbOperateMessage, error)

func (*Server) RecoverExecBatchYakScriptUnfinishedTask 

func (s *Server) RecoverExecBatchYakScriptUnfinishedTask(req *ypb.RecoverExecBatchYakScriptUnfinishedTaskRequest, stream ypb.Yak_RecoverExecBatchYakScriptUnfinishedTaskServer) error

func (*Server) RecoverSimpleDetectTask added in v1.3.3 

func (s *Server) RecoverSimpleDetectTask(req *ypb.RecoverUnfinishedTaskRequest, stream ypb.Yak_RecoverSimpleDetectTaskServer) error

func (*Server) RecoverSimpleDetectUnfinishedTask 

func (s *Server) RecoverSimpleDetectUnfinishedTask(req *ypb.RecoverExecBatchYakScriptUnfinishedTaskRequest, stream ypb.Yak_RecoverSimpleDetectUnfinishedTaskServer) error

func (*Server) RedirectRequest 

func (s *Server) RedirectRequest(ctx context.Context, req *ypb.RedirectRequestParams) (*ypb.FuzzerResponse, error)

func (*Server) RegisterFacadesHTTP 

func (s *Server) RegisterFacadesHTTP(ctx context.Context, req *ypb.RegisterFacadesHTTPRequest) (*ypb.RegisterFacadesHTTPResponse, error)

func (*Server) RemoveDuplicatePayloads added in v1.2.9 

func (s *Server) RemoveDuplicatePayloads(req *ypb.NameRequest, stream ypb.Yak_RemoveDuplicatePayloadsServer) error

func (*Server) RemoveFromMenu 

func (s *Server) RemoveFromMenu(ctx context.Context, req *ypb.RemoveFromMenuRequest) (*ypb.Empty, error)

func (*Server) RenameFingerprintGroup 

func (s *Server) RenameFingerprintGroup(ctx context.Context, req *ypb.RenameFingerprintGroupRequest) (*ypb.DbOperateMessage, error)

func (*Server) RenamePayloadFolder added in v1.2.9 

func (s *Server) RenamePayloadFolder(ctx context.Context, req *ypb.RenameRequest) (*ypb.Empty, error)

func (*Server) RenamePayloadGroup added in v1.2.9 

func (s *Server) RenamePayloadGroup(ctx context.Context, req *ypb.RenameRequest) (*ypb.Empty, error)

func (*Server) RenameYakScriptGroup added in v1.3.1 

func (s *Server) RenameYakScriptGroup(ctx context.Context, req *ypb.RenameYakScriptGroupRequest) (*ypb.Empty, error)

func (*Server) RenderHTTPFuzzerPacket added in v1.3.1 

func (s *Server) RenderHTTPFuzzerPacket(ctx context.Context, req *ypb.RenderHTTPFuzzerPacketRequest) (*ypb.RenderHTTPFuzzerPacketResponse, error)

! 已弃用

func (*Server) RenderVariables 

func (s *Server) RenderVariables(ctx context.Context, req *ypb.RenderVariablesRequest) (*ypb.RenderVariablesResponse, error)

func (*Server) RenderVariablesWithTypedKV added in v1.2.7 

func (s *Server) RenderVariablesWithTypedKV(ctx context.Context, kvs []*ypb.FuzzerParamItem) map[string]any

func (*Server) RequestYakURL added in v1.2.6 

func (s *Server) RequestYakURL(ctx context.Context, req *ypb.RequestYakURLParams) (*ypb.RequestYakURLResponse, error)

func (*Server) RequireDNSLogDomain 

func (s *Server) RequireDNSLogDomain(ctx context.Context, params *ypb.YakDNSLogBridgeAddr) (*ypb.DNSLogRootDomain, error)

func (*Server) RequireDNSLogDomainByScript added in v1.2.6 

func (s *Server) RequireDNSLogDomainByScript(ctx context.Context, req *ypb.RequireDNSLogDomainByScriptRequest) (*ypb.DNSLogRootDomain, error)

func (*Server) RequireICMPRandomLength 

func (s *Server) RequireICMPRandomLength(ctx context.Context, req *ypb.Empty) (*ypb.RequireICMPRandomLengthResponse, error)

func (*Server) RequireRandomPortToken 

func (s *Server) RequireRandomPortToken(ctx context.Context, req *ypb.Empty) (*ypb.RandomPortInfo, error)

func (*Server) ResetAndInvalidUserData 

func (s *Server) ResetAndInvalidUserData(ctx context.Context, req *ypb.ResetAndInvalidUserDataRequest) (*ypb.Empty, error)

func (*Server) ResetGlobalNetworkConfig added in v1.2.4 

func (s *Server) ResetGlobalNetworkConfig(ctx context.Context, req *ypb.ResetGlobalNetworkConfigRequest) (*ypb.Empty, error)

func (*Server) ResetMITMFilter 

func (s *Server) ResetMITMFilter(ctx context.Context, req *ypb.Empty) (*ypb.SetMITMFilterRequest, error)

func (*Server) ResetMITMHijackFilter 

func (s *Server) ResetMITMHijackFilter(ctx context.Context, req *ypb.Empty) (*ypb.SetMITMFilterRequest, error)

func (*Server) ResetRiskTableStats 

func (s *Server) ResetRiskTableStats(ctx context.Context, e *ypb.Empty) (*ypb.Empty, error)

func (*Server) ResetYakScriptGroup added in v1.3.1 

func (s *Server) ResetYakScriptGroup(ctx context.Context, req *ypb.ResetYakScriptGroupRequest) (*ypb.Empty, error)

func (*Server) RiskFeedbackToOnline 

func (s *Server) RiskFeedbackToOnline(ctx context.Context, req *ypb.UploadRiskToOnlineRequest) (*ypb.Empty, error)

func (*Server) RiskFieldGroup 

func (s *Server) RiskFieldGroup(ctx context.Context, req *ypb.Empty) (*ypb.RiskFieldGroupResponse, error)

func (*Server) SSARiskDiff 

func (s *Server) SSARiskDiff(req *ypb.SSARiskDiffRequest, server ypb.Yak_SSARiskDiffServer) error

func (*Server) SSARiskFeedbackToOnline 

func (s *Server) SSARiskFeedbackToOnline(ctx context.Context, req *ypb.SSARiskFeedbackToOnlineRequest) (*ypb.Empty, error)

func (*Server) SaveAITool 

func (s *Server) SaveAITool(ctx context.Context, req *ypb.SaveAIToolRequest) (*ypb.DbOperateMessage, error)

func (*Server) SaveAIToolV2 

func (s *Server) SaveAIToolV2(ctx context.Context, req *ypb.SaveAIToolRequest) (*ypb.SaveAIToolV2Response, error)

func (*Server) SaveCancelSimpleDetect 

func (s *Server) SaveCancelSimpleDetect(ctx context.Context, req *ypb.RecordPortScanRequest) (*ypb.Empty, error)

func (*Server) SaveCodecFlow added in v1.3.3 

func (s *Server) SaveCodecFlow(ctx context.Context, req *ypb.CustomizeCodecFlow) (*ypb.Empty, error)

func (*Server) SaveFuzzerConfig 

func (s *Server) SaveFuzzerConfig(ctx context.Context, req *ypb.SaveFuzzerConfigRequest) (*ypb.DbOperateMessage, error)

func (*Server) SaveFuzzerLabel added in v1.2.3 

func (s *Server) SaveFuzzerLabel(ctx context.Context, req *ypb.SaveFuzzerLabelRequest) (*ypb.Empty, error)

func (Server) SaveLargePayloadToFileStream 

func (s Server) SaveLargePayloadToFileStream(req *ypb.SavePayloadRequest, stream ypb.Yak_SaveLargePayloadToFileStreamServer) error

func (*Server) SaveMarkdownDocument 

func (s *Server) SaveMarkdownDocument(ctx context.Context, req *ypb.SaveMarkdownDocumentRequest) (*ypb.Empty, error)

func (*Server) SaveNewYakScript added in v1.2.9 

func (s *Server) SaveNewYakScript(ctx context.Context, request *ypb.SaveNewYakScriptRequest) (*ypb.YakScript, error)

func (*Server) SavePayloadStream 

func (s *Server) SavePayloadStream(req *ypb.SavePayloadRequest, stream ypb.Yak_SavePayloadStreamServer) (ret error)

func (*Server) SavePayloadToFileStream added in v1.2.9 

func (s *Server) SavePayloadToFileStream(req *ypb.SavePayloadRequest, stream ypb.Yak_SavePayloadToFileStreamServer) error

func (*Server) SaveSetTagForHTTPFlow 

func (s *Server) SaveSetTagForHTTPFlow(id int64, hash string, tags []string) error

func (*Server) SaveTextToTemporalFile 

func (s *Server) SaveTextToTemporalFile(ctx context.Context, req *ypb.SaveTextToTemporalFileRequest) (*ypb.SaveTextToTemporalFileResponse, error)

func (*Server) SaveYakScript 

func (s *Server) SaveYakScript(ctx context.Context, script *ypb.YakScript) (*ypb.YakScript, error)

func (*Server) SaveYakScriptGroup added in v1.3.1 

func (s *Server) SaveYakScriptGroup(ctx context.Context, req *ypb.SaveYakScriptGroupRequest) (*ypb.Empty, error)

func (*Server) SaveYakScriptToOnline added in v1.2.9 

func (s *Server) SaveYakScriptToOnline(req *ypb.SaveYakScriptToOnlineRequest, stream ypb.Yak_SaveYakScriptToOnlineServer) error

func (*Server) SearchKnowledgeBaseEntry 

func (s *Server) SearchKnowledgeBaseEntry(ctx context.Context, req *ypb.SearchKnowledgeBaseEntryRequest) (*ypb.SearchKnowledgeBaseEntryResponse, error)

func (*Server) SearchNoteContent 

func (s *Server) SearchNoteContent(ctx context.Context, req *ypb.SearchNoteContentRequest) (*ypb.SearchNoteContentResponse, error)

func (*Server) SetCurrentProject 

func (s *Server) SetCurrentProject(ctx context.Context, req *ypb.SetCurrentProjectRequest) (*ypb.Empty, error)

func (*Server) SetCurrentRules 

func (s *Server) SetCurrentRules(c context.Context, req *ypb.MITMContentReplacers) (*ypb.Empty, error)

func (*Server) SetEngineDefaultProxy 

func (s *Server) SetEngineDefaultProxy(ctx context.Context, d *ypb.DefaultProxyResult) (*ypb.Empty, error)

func (*Server) SetGlobalNetworkConfig added in v1.2.4 

func (s *Server) SetGlobalNetworkConfig(ctx context.Context, req *ypb.GlobalNetworkConfig) (*ypb.Empty, error)

func (*Server) SetGroup 

func (s *Server) SetGroup(ctx context.Context, req *ypb.SetGroupRequest) (*ypb.Empty, error)

func (*Server) SetKey 

func (s *Server) SetKey(ctx context.Context, req *ypb.SetKeyRequest) (*ypb.Empty, error)

func (*Server) SetMITMFilter 

func (s *Server) SetMITMFilter(ctx context.Context, req *ypb.SetMITMFilterRequest) (*ypb.SetMITMFilterResponse, error)

func (*Server) SetMITMHijackFilter 

func (s *Server) SetMITMHijackFilter(ctx context.Context, req *ypb.SetMITMFilterRequest) (*ypb.SetMITMFilterResponse, error)

func (*Server) SetOnlineProfile 

func (s *Server) SetOnlineProfile(ctx context.Context, req *ypb.OnlineProfile) (*ypb.Empty, error)

func (*Server) SetPluginEnv 

func (s *Server) SetPluginEnv(ctx context.Context, request *ypb.PluginEnvData) (*ypb.Empty, error)

func (*Server) SetProcessEnvKey 

func (s *Server) SetProcessEnvKey(ctx context.Context, req *ypb.SetKeyRequest) (*ypb.Empty, error)

func (*Server) SetProjectKey added in v1.2.2 

func (s *Server) SetProjectKey(ctx context.Context, req *ypb.SetKeyRequest) (*ypb.Empty, error)

func (*Server) SetSystemProxy 

func (s *Server) SetSystemProxy(ctx context.Context, req *ypb.SetSystemProxyRequest) (*ypb.Empty, error)

func (*Server) SetTagForHTTPFlow 

func (s *Server) SetTagForHTTPFlow(ctx context.Context, req *ypb.SetTagForHTTPFlowRequest) (*ypb.Empty, error)

func (*Server) SetTagForRisk 

func (s *Server) SetTagForRisk(ctx context.Context, req *ypb.SetTagForRiskRequest) (*ypb.Empty, error)

func (*Server) SetYakBridgeLogServer 

func (s *Server) SetYakBridgeLogServer(ctx context.Context, l *ypb.YakDNSLogBridgeAddr) (*ypb.Empty, error)

func (*Server) SetYakScriptSkipUpdate 

func (s *Server) SetYakScriptSkipUpdate(ctx context.Context, req *ypb.SetYakScriptSkipUpdateRequest) (*ypb.Empty, error)

func (*Server) SimpleDetect 

func (s *Server) SimpleDetect(req *ypb.RecordPortScanRequest, stream ypb.Yak_SimpleDetectServer) error

func (*Server) SimpleDetectCreatReport added in v1.3.3 

func (s *Server) SimpleDetectCreatReport(req *ypb.CreatReportRequest, stream ypb.Yak_SimpleDetectCreatReportServer) error

func (*Server) SmokingEvaluatePlugin added in v1.2.3 

func (s *Server) SmokingEvaluatePlugin(ctx context.Context, req *ypb.SmokingEvaluatePluginRequest) (*ypb.SmokingEvaluatePluginResponse, error)

func (*Server) SmokingEvaluatePluginBatch added in v1.2.9 

func (s *Server) SmokingEvaluatePluginBatch(req *ypb.SmokingEvaluatePluginBatchRequest, stream ypb.Yak_SmokingEvaluatePluginBatchServer) error

SmokingEvaluatePluginBatch(*SmokingEvaluatePluginBatchRequest, Yak_SmokingEvaluatePluginBatchServer) error SmokingEvaluatePluginBatch

func (*Server) StartAIReAct 

func (s *Server) StartAIReAct(stream ypb.Yak_StartAIReActServer) error

func (*Server) StartAITask 

func (s *Server) StartAITask(stream ypb.Yak_StartAITaskServer) error

func (*Server) StartAITriage 

func (s *Server) StartAITriage(stream ypb.Yak_StartAITriageServer) error

func (*Server) StartBrute 

func (s *Server) StartBrute(params *ypb.StartBruteParams, stream ypb.Yak_StartBruteServer) error

func (*Server) StartFacades 

func (s *Server) StartFacades(req *ypb.StartFacadesParams, stream ypb.Yak_StartFacadesServer) error

func (*Server) StartFacadesWithYsoObject 

func (s *Server) StartFacadesWithYsoObject(req *ypb.StartFacadesWithYsoParams, stream ypb.Yak_StartFacadesWithYsoObjectServer) error

func (*Server) StartLocalModel 

func (s *Server) StartLocalModel(req *ypb.StartLocalModelRequest, stream ypb.Yak_StartLocalModelServer) error

StartLocalModel 启动本地模型

func (*Server) StartMcpServer 

func (s *Server) StartMcpServer(req *ypb.StartMcpServerRequest, stream ypb.Yak_StartMcpServerServer) error

func (*Server) StartScrecorder 

func (s *Server) StartScrecorder(req *ypb.StartScrecorderRequest, stream ypb.Yak_StartScrecorderServer) error

func (*Server) StartThirdPartyBinary 

func (s *Server) StartThirdPartyBinary(req *ypb.StartThirdPartyBinaryRequest, stream ypb.Yak_StartThirdPartyBinaryServer) error

func (*Server) StartVulinbox added in v1.2.3 

func (s *Server) StartVulinbox(req *ypb.StartVulinboxRequest, stream ypb.Yak_StartVulinboxServer) error

func (*Server) StaticAnalyzeError 

func (s *Server) StaticAnalyzeError(ctx context.Context, r *ypb.StaticAnalyzeErrorRequest) (*ypb.StaticAnalyzeErrorResponse, error)

func (*Server) StopLocalModel 

func (s *Server) StopLocalModel(ctx context.Context, req *ypb.StopLocalModelRequest) (*ypb.GeneralResponse, error)

func (*Server) StringFuzzer 

func (s *Server) StringFuzzer(rootCtx context.Context, req *ypb.StringFuzzerRequest) (*ypb.StringFuzzerResponse, error)

func (*Server) SyntaxFlowRuleToOnline 

func (s *Server) SyntaxFlowRuleToOnline(req *ypb.SyntaxFlowRuleToOnlineRequest, stream ypb.Yak_SyntaxFlowRuleToOnlineServer) error

func (*Server) SyntaxFlowScan 

func (s *Server) SyntaxFlowScan(stream ypb.Yak_SyntaxFlowScanServer) error

func (*Server) ToGRPCNavigation added in v1.2.3 

func (s *Server) ToGRPCNavigation(i *schema.NavigationBar) (*ypb.NavigationItem, error)

func (*Server) ToggleAIToolFavorite 

func (s *Server) ToggleAIToolFavorite(ctx context.Context, req *ypb.ToggleAIToolFavoriteRequest) (*ypb.ToggleAIToolFavoriteResponse, error)

func (*Server) TraceRoute added in v1.3.1 

func (s *Server) TraceRoute(req *ypb.TraceRouteRequest, server ypb.Yak_TraceRouteServer) error

func (*Server) UnIgnoreYakScript 

func (s *Server) UnIgnoreYakScript(ctx context.Context, req *ypb.DeleteYakScriptRequest) (*ypb.Empty, error)

func (*Server) UninstallThirdPartyBinary 

func (s *Server) UninstallThirdPartyBinary(ctx context.Context, req *ypb.UninstallThirdPartyBinaryRequest) (*ypb.GeneralResponse, error)

func (*Server) UpdateAIForge 

func (s *Server) UpdateAIForge(ctx context.Context, req *ypb.AIForge) (*ypb.DbOperateMessage, error)

func (*Server) UpdateAITool 

func (s *Server) UpdateAITool(ctx context.Context, req *ypb.UpdateAIToolRequest) (*ypb.DbOperateMessage, error)

func (*Server) UpdateAllPayloadGroup added in v1.2.9 

func (s *Server) UpdateAllPayloadGroup(ctx context.Context, req *ypb.UpdateAllPayloadGroupRequest) (*ypb.Empty, error)

func (*Server) UpdateCVEDatabase 

func (s *Server) UpdateCVEDatabase(req *ypb.UpdateCVEDatabaseRequest, stream ypb.Yak_UpdateCVEDatabaseServer) error

func (*Server) UpdateCodecFlow 

func (s *Server) UpdateCodecFlow(ctx context.Context, req *ypb.UpdateCodecFlowRequest) (*ypb.Empty, error)

func (*Server) UpdateEntity 

func (s *Server) UpdateEntity(ctx context.Context, req *ypb.Entity) (*ypb.DbOperateMessage, error)

UpdateEntity 更新或创建实体（根据 yakit 实现）

func (*Server) UpdateFingerprint 

func (s *Server) UpdateFingerprint(ctx context.Context, req *ypb.UpdateFingerprintRequest) (*ypb.DbOperateMessage, error)

func (*Server) UpdateFromGithub 

func (s *Server) UpdateFromGithub(ctx context.Context, req *ypb.UpdateFromGithubRequest) (*ypb.Empty, error)

func (*Server) UpdateFromYakitResource 

func (s *Server) UpdateFromYakitResource(ctx context.Context, req *ypb.UpdateFromYakitResourceRequest) (*ypb.Empty, error)

func (*Server) UpdateHotPatchTemplate 

func (s *Server) UpdateHotPatchTemplate(ctx context.Context, req *ypb.UpdateHotPatchTemplateRequest) (*ypb.UpdateHotPatchTemplateResponse, error)

func (*Server) UpdateKnowledgeBase 

func (s *Server) UpdateKnowledgeBase(ctx context.Context, req *ypb.UpdateKnowledgeBaseRequest) (*ypb.GeneralResponse, error)

func (*Server) UpdateKnowledgeBaseEntry 

func (s *Server) UpdateKnowledgeBaseEntry(ctx context.Context, req *ypb.UpdateKnowledgeBaseEntryRequest) (*ypb.GeneralResponse, error)

func (*Server) UpdateLocalModel 

func (s *Server) UpdateLocalModel(ctx context.Context, req *ypb.UpdateLocalModelRequest) (*ypb.GeneralResponse, error)

func (*Server) UpdateMCPServer 

func (s *Server) UpdateMCPServer(ctx context.Context, req *ypb.UpdateMCPServerRequest) (*ypb.GeneralResponse, error)

UpdateMCPServer 更新MCP服务器

func (*Server) UpdateNote 

func (s *Server) UpdateNote(ctx context.Context, req *ypb.UpdateNoteRequest) (*ypb.DbOperateMessage, error)

func (*Server) UpdatePayload 

func (s *Server) UpdatePayload(ctx context.Context, req *ypb.UpdatePayloadRequest) (*ypb.Empty, error)

func (*Server) UpdatePayloadToFile added in v1.2.9 

func (s *Server) UpdatePayloadToFile(ctx context.Context, req *ypb.UpdatePayloadToFileRequest) (*ypb.Empty, error)

func (*Server) UpdateProject 

func (s *Server) UpdateProject(ctx context.Context, req *ypb.NewProjectRequest) (*ypb.NewProjectResponse, error)

func (*Server) UpdateRelationship 

func (s *Server) UpdateRelationship(ctx context.Context, req *ypb.Relationship) (*ypb.DbOperateMessage, error)

UpdateRelationship 更新或创建关系（根据 yakit 实现） 使用 profile 数据库，调用 yakit.UpdateRelationshipByUUID 来执行具体的 DB 操作

func (*Server) UpdateSSAProgram 

func (s *Server) UpdateSSAProgram(ctx context.Context, req *ypb.UpdateSSAProgramRequest) (*ypb.DbOperateMessage, error)

func (*Server) UpdateSSAProject 

func (s *Server) UpdateSSAProject(ctx context.Context, req *ypb.UpdateSSAProjectRequest) (*ypb.UpdateSSAProjectResponse, error)

func (*Server) UpdateSSARiskDisposals 

func (s *Server) UpdateSSARiskDisposals(ctx context.Context, req *ypb.UpdateSSARiskDisposalsRequest) (*ypb.UpdateSSARiskDisposalsResponse, error)

func (*Server) UpdateSSARiskTags 

func (s *Server) UpdateSSARiskTags(ctx context.Context, req *ypb.UpdateSSARiskTagsRequest) (*ypb.DbOperateMessage, error)

func (*Server) UpdateScreenRecorders added in v1.2.2 

func (s *Server) UpdateScreenRecorders(ctx context.Context, req *ypb.UpdateScreenRecorderRequest) (*ypb.Empty, error)

func (*Server) UpdateSnippet 

func (s *Server) UpdateSnippet(ctx context.Context, req *ypb.EditSnippetsRequest) (*ypb.Empty, error)

func (*Server) UpdateSyntaxFlowRule 

func (s *Server) UpdateSyntaxFlowRule(ctx context.Context, req *ypb.UpdateSyntaxFlowRuleRequest) (*ypb.DbOperateMessage, error)

func (*Server) UpdateSyntaxFlowRuleAndGroup 

func (s *Server) UpdateSyntaxFlowRuleAndGroup(ctx context.Context, req *ypb.UpdateSyntaxFlowRuleAndGroupRequest) (*ypb.DbOperateMessage, error)

func (*Server) UpdateSyntaxFlowRuleEx 

func (s *Server) UpdateSyntaxFlowRuleEx(ctx context.Context, req *ypb.UpdateSyntaxFlowRuleRequest) (*ypb.UpdateSyntaxFlowRuleResponse, error)

func (*Server) UpdateSyntaxFlowRuleGroup 

func (s *Server) UpdateSyntaxFlowRuleGroup(ctx context.Context, req *ypb.UpdateSyntaxFlowRuleGroupRequest) (*ypb.DbOperateMessage, error)

func (*Server) UpdateVectorStoreCollection 

func (s *Server) UpdateVectorStoreCollection(ctx context.Context, req *ypb.UpdateVectorStoreCollectionRequest) (*ypb.GeneralResponse, error)

UpdateVectorStoreCollection 更新向量存储集合信息

func (*Server) UpdateWebShell added in v1.3.0 

func (s *Server) UpdateWebShell(ctx context.Context, req *ypb.WebShell) (*ypb.WebShell, error)

func (*Server) UploadHotPatchTemplateToOnline 

func (s *Server) UploadHotPatchTemplateToOnline(ctx context.Context, req *ypb.UploadHotPatchTemplateToOnlineRequest) (*ypb.Empty, error)

func (*Server) UploadPayloadToOnline 

func (s *Server) UploadPayloadToOnline(req *ypb.UploadPayloadToOnlineRequest, stream ypb.Yak_UploadPayloadToOnlineServer) error

func (*Server) UploadRiskToOnline 

func (s *Server) UploadRiskToOnline(ctx context.Context, req *ypb.UploadRiskToOnlineRequest) (*ypb.Empty, error)

func (*Server) UploadScreenRecorders added in v1.2.2 

func (s *Server) UploadScreenRecorders(ctx context.Context, req *ypb.UploadScreenRecorderRequest) (*ypb.Empty, error)

func (*Server) ValidP12PassWord added in v1.2.8 

func (s *Server) ValidP12PassWord(ctx context.Context, req *ypb.ValidP12PassWordRequest) (*ypb.ValidP12PassWordResponse, error)

func (*Server) VerifySystemCertificate added in v1.3.3 

func (s *Server) VerifySystemCertificate(ctx context.Context, _ *ypb.Empty) (*ypb.VerifySystemCertificateResponse, error)

func (*Server) VerifyTunnelServerDomain 

func (s *Server) VerifyTunnelServerDomain(ctx context.Context, p *ypb.VerifyTunnelServerDomainParams) (*ypb.VerifyTunnelServerDomainResponse, error)

func (*Server) Version 

func (s *Server) Version(ctx context.Context, _ *ypb.Empty) (*ypb.VersionResponse, error)

func (*Server) ViewPortScanCode 

func (s *Server) ViewPortScanCode(ctx context.Context, req *ypb.Empty) (*ypb.SimpleScript, error)

func (*Server) YakScriptIsInMenu 

func (s *Server) YakScriptIsInMenu(ctx context.Context, req *ypb.YakScriptIsInMenuRequest) (*ypb.Empty, error)

func (*Server) YakScriptRiskTypeList added in v1.2.9 

func (s *Server) YakScriptRiskTypeList(context.Context, *ypb.Empty) (*ypb.YakScriptRiskTypeListResponse, error)

func (*Server) YakVersionAtLeast added in v1.3.0 

func (s *Server) YakVersionAtLeast(ctx context.Context, req *ypb.YakVersionAtLeastRequest) (*ypb.GeneralResponse, error)

func (*Server) YaklangCompileAndFormat 

func (s *Server) YaklangCompileAndFormat(cx context.Context, req *ypb.YaklangCompileAndFormatRequest) (*ypb.YaklangCompileAndFormatResponse, error)

func (*Server) YaklangGetCliCodeFromDatabase added in v1.3.0 

func (s *Server) YaklangGetCliCodeFromDatabase(ctx context.Context, req *ypb.YaklangGetCliCodeFromDatabaseRequest) (*ypb.YaklangGetCliCodeFromDatabaseResponse, error)

func (*Server) YaklangInspectInformation added in v1.2.9 

func (s *Server) YaklangInspectInformation(ctx context.Context, req *ypb.YaklangInspectInformationRequest) (*ypb.YaklangInspectInformationResponse, error)

func (*Server) YaklangLanguageFind added in v1.3.3 

func (s *Server) YaklangLanguageFind(ctx context.Context, req *ypb.YaklangLanguageSuggestionRequest) (*ypb.YaklangLanguageFindResponse, error)

func (*Server) YaklangLanguageSuggestion added in v1.2.9 

func (s *Server) YaklangLanguageSuggestion(ctx context.Context, req *ypb.YaklangLanguageSuggestionRequest) (*ypb.YaklangLanguageSuggestionResponse, error)

func (*Server) YaklangTerminal 

func (s *Server) YaklangTerminal(inputStream ypb.Yak_YaklangTerminalServer) error

func (*Server) YsoDump 

func (s *Server) YsoDump(ctx context.Context, req *ypb.YsoBytesObject) (*ypb.YsoDumpResponse, error)

type ServerConfig added in v1.3.3 

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

type ServerOpts added in v1.3.3 

type ServerOpts func(config *ServerConfig)

func WithInitFacadeServer added in v1.3.3 

func WithInitFacadeServer(init bool) ServerOpts

func WithProfileDatabasePath 

func WithProfileDatabasePath(p string) ServerOpts

func WithProjectDatabasePath 

func WithProjectDatabasePath(p string) ServerOpts

func WithReverseServerPort added in v1.3.3 

func WithReverseServerPort(port int) ServerOpts

func WithStartCacheLog added in v1.3.3 

func WithStartCacheLog() ServerOpts

type TerminalWrapper 

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

func (*TerminalWrapper) Write 

func (t *TerminalWrapper) Write(p []byte) (n int, err error)

type VAttachCombinedOutputServer 

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

func NewVAttachCombinedOutputServer 

func NewVAttachCombinedOutputServer(send func(msg *ypb.ExecResult) error) *VAttachCombinedOutputServer

func (*VAttachCombinedOutputServer) Cancel 

func (v *VAttachCombinedOutputServer) Cancel()

func (*VAttachCombinedOutputServer) Context 

func (v *VAttachCombinedOutputServer) Context() context.Context

func (*VAttachCombinedOutputServer) IsValid 

func (v *VAttachCombinedOutputServer) IsValid() bool

func (*VAttachCombinedOutputServer) RecvMsg 

func (v *VAttachCombinedOutputServer) RecvMsg(m interface{}) error

func (*VAttachCombinedOutputServer) Send 

func (v *VAttachCombinedOutputServer) Send(result *ypb.ExecResult) error

func (*VAttachCombinedOutputServer) SendHeader 

func (v *VAttachCombinedOutputServer) SendHeader(md grpcMetadata.MD) error

func (*VAttachCombinedOutputServer) SendMsg 

func (v *VAttachCombinedOutputServer) SendMsg(m interface{}) error

func (*VAttachCombinedOutputServer) SetHeader 

func (v *VAttachCombinedOutputServer) SetHeader(md grpcMetadata.MD) error

func (*VAttachCombinedOutputServer) SetTrailer 

func (v *VAttachCombinedOutputServer) SetTrailer(md grpcMetadata.MD)

type VulinboxAgentFacade added in v1.2.3 

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

func GetVulinboxAgent added in v1.2.3 

func GetVulinboxAgent(addr string) (*VulinboxAgentFacade, bool)

func (*VulinboxAgentFacade) AddPing added in v1.2.3 

func (v *VulinboxAgentFacade) AddPing()

func (*VulinboxAgentFacade) AddRequestCount added in v1.2.3 

func (v *VulinboxAgentFacade) AddRequestCount()

func (*VulinboxAgentFacade) Close added in v1.2.3 

func (v *VulinboxAgentFacade) Close()

func (*VulinboxAgentFacade) IsClosed added in v1.2.3 

func (v *VulinboxAgentFacade) IsClosed() bool

func (*VulinboxAgentFacade) Status added in v1.2.3 

func (v *VulinboxAgentFacade) Status() *ypb.IsRemoteAddrAvailableResponse

type WrapperHTTPFuzzerGroupStream 

type WrapperHTTPFuzzerGroupStream struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

WrapperHTTPFuzzerGroupStream adapts HTTPFuzzer responses to the group stream.

func NewHTTPFuzzerGroupWrapper 

func NewHTTPFuzzerGroupWrapper(fallback *httpFuzzerGroupFallback) *WrapperHTTPFuzzerGroupStream

func (*WrapperHTTPFuzzerGroupStream) Send 

func (w *WrapperHTTPFuzzerGroupStream) Send(r *ypb.FuzzerResponse) error

type WrapperHTTPFuzzerStream 

type WrapperHTTPFuzzerStream struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func NewHTTPFuzzerFallbackWrapper 

func NewHTTPFuzzerFallbackWrapper(fallback *httpFuzzerFallback) *WrapperHTTPFuzzerStream

func (*WrapperHTTPFuzzerStream) Send 

func (w *WrapperHTTPFuzzerStream) Send(r *ypb.FuzzerResponse) error

type YakExecServerWrapper 

type YakExecServerWrapper struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func NewYakExecServerWrapper 

func NewYakExecServerWrapper(stream grpc.ServerStream, handle func(result *ypb.ExecResult) error) *YakExecServerWrapper

func (*YakExecServerWrapper) Send 

func (y *YakExecServerWrapper) Send(result *ypb.ExecResult) error

type YakFuzzerMatcher 

type YakFuzzerMatcher struct {
	Matcher *httptpl.YakMatcher
	Color   string
	Action  string
}

func NewHttpFlowMatcherFromGRPCModel 

func NewHttpFlowMatcherFromGRPCModel(m *ypb.HTTPResponseMatcher) *YakFuzzerMatcher

type YakOutputStreamerHelperWC 

type YakOutputStreamerHelperWC struct {
	io.WriteCloser
	// contains filtered or unexported fields
}

OpenPortServerStreamerHelperRWC

func (*YakOutputStreamerHelperWC) Close 

func (s *YakOutputStreamerHelperWC) Close() (err error)

func (*YakOutputStreamerHelperWC) Write 

func (s *YakOutputStreamerHelperWC) Write(b []byte) (int, error)

type YamlArrayBuilder added in v1.2.7 

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

func (*YamlArrayBuilder) Add added in v1.2.7 

func (a *YamlArrayBuilder) Add(slice *YamlMapBuilder)

type YamlMapBuilder added in v1.2.7 

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

func NewYamlMapBuilder added in v1.2.7 

func NewYamlMapBuilder() *YamlMapBuilder

func (*YamlMapBuilder) AddComment added in v1.2.7 

func (m *YamlMapBuilder) AddComment(comment string)

func (*YamlMapBuilder) AddEmptyLine added in v1.2.7 

func (m *YamlMapBuilder) AddEmptyLine()

func (*YamlMapBuilder) FilterEmptyField added in v1.2.7 

func (m *YamlMapBuilder) FilterEmptyField() *yaml.MapSlice

func (*YamlMapBuilder) ForceSet added in v1.2.7 

func (m *YamlMapBuilder) ForceSet(k string, v any)

func (*YamlMapBuilder) MarshalToString added in v1.2.7 

func (m *YamlMapBuilder) MarshalToString() (string, error)

func (*YamlMapBuilder) NewSubArrayBuilder added in v1.2.7 

func (m *YamlMapBuilder) NewSubArrayBuilder(k string) *YamlArrayBuilder

func (*YamlMapBuilder) NewSubMapBuilder added in v1.2.7 

func (m *YamlMapBuilder) NewSubMapBuilder(k string) *YamlMapBuilder

func (*YamlMapBuilder) Set added in v1.2.7 

func (m *YamlMapBuilder) Set(k string, v any)

func (*YamlMapBuilder) SetDefaultField added in v1.2.7 

func (a *YamlMapBuilder) SetDefaultField(fieldMap map[string]any)

Source Files

View all Source files

Directories

Path Synopsis

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.