yakgrpc

package
v0.0.0-...-9a26220 Latest Latest
Warning

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

 Go to latest Published: Apr 6, 2025 License: AGPL-3.0 Imports: 152 Imported by: 0

Documentation

Index

Constants

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 (
	MITMReplacerKeyRecords     = "R1oHf8xca6CobwVg2_MITMReplacerKeyRecords"
	MITMFilterKeyRecords       = "uWokegBnCQdnxezJtMVo_MITMFilterKeyRecords"
	MITMHijackFilterKeyRecords = "XcCPLRElWMVjnCNT_MITMHijackFilterKeyRecords"
)
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 (
	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 (
	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 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 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 VerifySystemCertificateCD = utils.NewCoolDown(10 * time.Second)
View Source 
var YakitAllTables = schema.ProjectTables
View Source 
var YakitProfileTables = schema.ProfileTables

Functions

func AddExecBatchTask 

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

func AddSimpleDetectTask 

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

func AfterAndBeforeIsExit 

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 

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) error

func CheckShouldDiscard 

func CheckShouldDiscard(action string, matchRes bool) bool

func CompareParameter 

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

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

func ConvertLowhttpResponseToFuzzerResponseBase 

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

func ConvertYakScriptToExecRequest 

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

func DeleteBatchYakScriptRequestByRuntimeId 

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

func DeleteSimpleDetectUnfinishedTaskByUid 

func DeleteSimpleDetectUnfinishedTaskByUid(db *gorm.DB, runtimeId string) (*ypb.RecordPortScanRequest, 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 FixPacket 

func FixPacket(packet []byte, isReq bool) (fixed []byte, use bool)

func FuzztagServer 

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

func GRPCYakScriptToYakitScript 

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

func GenerateParameterFromProgram 

func GenerateParameterFromProgram(prog *ssaapi.Program) (string, string, error)

func GenerateYsoPayload 

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 

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

func GetBuildinAvailableBruteTypeTree 

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

func GetSimpleDetectUnfinishedTaskByUid 

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

func GrpcRangeToSSARange 

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

func IsContain 

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

func IsContainNavigation 

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

func IsExtOption 

func IsExtOption(key string) bool

func IsValueInSortedSlice 

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

func KVPairToParamItem 

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

func LegacyFilter2FilterMatcherData 

func LegacyFilter2FilterMatcherData(m *MITMFilterManager) *ypb.MITMFilterData

func LegacyGRPCSaveNewYakScriptRequestGetYakScript 

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

func MarshalYakTemplateToYaml 

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 

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

func NewFuzzerSequenceFlow 

func NewFuzzerSequenceFlow(request *ypb.FuzzerRequest) *fuzzerSequenceFlow

func NewLocalClient 

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

func NewLocalClientWithTempDatabase 

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

func NewMITMReplacer 

func NewMITMReplacer(initFunc ...func() []*ypb.MITMContentReplacer) *mitmReplacer

func NewPagingFromGRPCModel 

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

func NewRiskGRPCModel 

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

func OnCompletion 

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

func OnFindDefinition 

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

func OnFindReferences 

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

func OnHover 

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

func OnSignature 

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

func ParamItemToKVPair 

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

func ParseReassembledTraffic 

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

func ParseTraffic 

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

func PortsServiceTypeGroup 

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

func QueryYakScriptByNames 

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

func RangeIfToGrpcRange 

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

func RegisterVulinboxAgent 

func RegisterVulinboxAgent(addr string, agent *VulinboxAgentFacade)

func RemoveHybridTask 

func RemoveHybridTask(id string)

func RemoveSyntaxFlowTaskByID 

func RemoveSyntaxFlowTaskByID(id string)

func ReplaceString 

func ReplaceString(s string) string

func SaveFromYakitLog 

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

func ScanHybridTargetWithPlugin 

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

func SyntaxFlowServer 

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

func TargetGenerator 

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 

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

Types

type ColorFlow 

type ColorFlow interface {
	Red()
	Green()
	Blue()
	Yellow()
	Orange()
	Purple()
	Cyan()
	Grey()
}

type DownloadStream 

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 HTTPFlowShare 

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

type HTTPRequestBuilderRes 

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

type HybridScanRequestStream 

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

type HybridScanStatusManager 

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 

func (h *HybridScanStatusManager) DoActiveTarget() int64

func (*HybridScanStatusManager) DoActiveTask 

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

DoActiveTask returns index of task

func (*HybridScanStatusManager) DoneFailureTarget 

func (h *HybridScanStatusManager) DoneFailureTarget()

func (*HybridScanStatusManager) DoneTarget 

func (h *HybridScanStatusManager) DoneTarget()

func (*HybridScanStatusManager) DoneTask 

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

func (*HybridScanStatusManager) Feedback 

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

func (*HybridScanStatusManager) GetCurrentActiveTaskIndexes 

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

func (*HybridScanStatusManager) GetStatus 

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

func (*HybridScanStatusManager) PushActiveTask 

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

func (*HybridScanStatusManager) RemoveActiveTask 

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

func (*HybridScanStatusManager) SetCurrentTaskIndex 

func (h *HybridScanStatusManager) SetCurrentTaskIndex(i int64)

type HybridScanTarget 

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

type HybridScanTaskManager 

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

func CreateHybridTask 

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

func GetHybridTask 

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

func (*HybridScanTaskManager) Checkpoint 

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

func (*HybridScanTaskManager) Context 

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

func (*HybridScanTaskManager) IsPaused 

func (h *HybridScanTaskManager) IsPaused() bool

func (*HybridScanTaskManager) IsStop 

func (h *HybridScanTaskManager) IsStop() bool

func (*HybridScanTaskManager) Pause 

func (h *HybridScanTaskManager) Pause()

func (*HybridScanTaskManager) PauseEffect 

func (h *HybridScanTaskManager) PauseEffect()

func (*HybridScanTaskManager) Resume 

func (h *HybridScanTaskManager) Resume()

func (*HybridScanTaskManager) Stop 

func (h *HybridScanTaskManager) Stop()

func (*HybridScanTaskManager) TaskId 

func (h *HybridScanTaskManager) TaskId() string

func (*HybridScanTaskManager) WaitCount 

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 

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

func LanguageServerAnalyzeProgram 

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 MITMReplaceRule 

type MITMReplaceRule struct {
	*ypb.MITMContentReplacer
	// contains filtered or unexported fields
}

func (*MITMReplaceRule) MatchAndReplacePacket 

func (m *MITMReplaceRule) MatchAndReplacePacket(packet []byte, isReq bool) ([]*yakit.MatchResult, []byte, error)

MatchAndReplacePacket match and replace package, return matched result and replaced package

func (*MITMReplaceRule) MatchPacket 

func (m *MITMReplaceRule) MatchPacket(packet []byte, isReq bool) (*yakit.PacketInfo, []*yakit.MatchResult, error)

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 PluginParamSelect 

type PluginParamSelect struct {
	Double bool                    `json:"double"`
	Data   []PluginParamSelectData `json:"data"`
}

type PluginParamSelectData 

type PluginParamSelectData struct {
	Key   string `json:"key"`
	Label string `json:"label"`
	Value string `json:"value"`
}

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 Rules 

type Rules []*MITMReplaceRule

func NewRuleGroup 

func NewRuleGroup(r ...*ypb.MITMContentReplacer) Rules

func (Rules) Len 

func (a Rules) Len() int

func (Rules) Less 

func (a Rules) Less(i, j int) bool

func (Rules) MITMContentReplacers 

func (a Rules) MITMContentReplacers() []*ypb.MITMContentReplacer

func (Rules) Swap 

func (a Rules) Swap(i, j int)

type Server 

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

func NewServer 

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

func NewServerWithLogCache 

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

func NewTestServer 

func NewTestServer() (*Server, error)

func (*Server) AddMenus 

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

func (*Server) AddOneNavigation 

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 

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

func (*Server) ApplyClassToFacades 

func (s *Server) ApplyClassToFacades(ctx context.Context, req *ypb.ApplyClassToFacadesParamsWithVerbose) (*ypb.Empty, 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 

func (s *Server) BackUpOrCopyPayloads(ctx context.Context, req *ypb.BackUpOrCopyPayloadsRequest) (*ypb.Empty, 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) 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 

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 

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

func (*Server) CreateFingerprint 

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

func (*Server) CreateHotPatchTemplate 

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

func (*Server) CreatePayloadFolder 

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) 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) CreateWebShell 

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 

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) 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 

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 

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) DeleteFingerprint 

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

func (*Server) DeleteFuzzerConfig 

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

func (*Server) DeleteFuzzerLabel 

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 

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

func (*Server) DeleteLocalPluginsByWhere 

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

func (*Server) DeleteMarkdownDocument 

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

func (*Server) DeletePayload 

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

func (*Server) DeletePayloadByFolder 

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) 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) DeleteSSARisks 

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

func (*Server) DeleteScreenRecorders 

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

func (*Server) DeleteSimpleDetectUnfinishedTask 

func (s *Server) DeleteSimpleDetectUnfinishedTask(ctx context.Context, req *ypb.DeleteUnfinishedTaskRequest) (*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 

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 

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

func (*Server) DiagnoseNetwork 

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

func (*Server) DiagnoseNetworkDNS 

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

func (*Server) DisconnectVulinboxAgent 

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

func (*Server) DownloadHotPatchTemplate 

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

func (*Server) DownloadMITMCert 

func (s *Server) DownloadMITMCert(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 

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 

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 

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

func (*Server) DownloadReport 

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

func (*Server) DownloadWithStream 

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

func (*Server) DuplexConnection 

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 

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 

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 

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

导出payload到文件

func (*Server) ExportAllPayloadFromFile 

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

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

func (*Server) ExportHTTPFlows 

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

func (*Server) ExportHTTPFuzzerTaskToYaml 

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

ExportHTTPFuzzerTaskToYaml fuzzerRequest -> yakTemplate -> yaml

func (*Server) ExportLocalYakScript 

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

func (*Server) ExportLocalYakScriptStream 

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) ExportProject 

func (s *Server) ExportProject(req *ypb.ExportProjectRequest, stream ypb.Yak_ExportProjectServer) 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 

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 

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) 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) GenerateURL 

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

func (*Server) GenerateWebShell 

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) GetAllCodecFlow 

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

func (*Server) GetAllCodecMethods 

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

func (*Server) GetAllFuzztagInfo 

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

func (*Server) GetAllMenuItem 

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

func (*Server) GetAllNavigationItem 

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) 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 

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) 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) 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) GetGlobalNetworkConfig 

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 

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 

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) 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 

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 

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

func (*Server) GetProfileDatabase 

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

func (*Server) GetProjectDatabase 

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

func (*Server) GetProjectKey 

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) GetRegisteredVulinboxAgent 

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) GetSSARiskFieldGroup 

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

func (*Server) GetSimpleDetectRecordRequestById 

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 

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 

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

func (*Server) GetSystemDefaultDnsServers 

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 

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

func (*Server) GetThirdPartyAppConfigTemplate 

func (s *Server) GetThirdPartyAppConfigTemplate(ctx context.Context, _ *ypb.Empty) (*ypb.GetThirdPartyAppConfigTemplateResponse, 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 

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 

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

func (*Server) HTTPFlowsExtract 

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 

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

func (*Server) HTTPFlowsToOnline 

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

func (*Server) HTTPFuzzer 

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

func (*Server) HTTPFuzzerSequence 

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 

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) HybridScan 

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) ImportHTTPFuzzerTaskFromYaml 

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

ImportHTTPFuzzerTaskFromYaml yaml -> yakTemplate -> fuzzerRequest

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) ImportProject 

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

func (*Server) ImportSyntaxFlows 

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

func (*Server) ImportYakScript 

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) InstallScrecorder 

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

func (*Server) InstallVulinbox 

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) 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) IsVulinboxReady 

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

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) 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 

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

func (*Server) NewCodec 

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 

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

func (*Server) ParseTraffic 

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

func (*Server) PcapX 

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

func (*Server) Ping 

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

func (*Server) PluginGenerator 

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

func (*Server) PluginListGenerator 

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

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 

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) 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 

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) 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 

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 

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 

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) QueryMITMRuleExtractedData 

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

func (*Server) QueryNavigationGroups 

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) QueryPayload 

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

func (*Server) QueryPayloadFromFile 

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 

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) 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) 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 

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

func (*Server) QuerySupportedDnsLogPlatforms 

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 

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

func (*Server) QueryTrafficSession 

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

func (*Server) QueryTrafficTCPReassembled 

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

func (*Server) QueryWebShells 

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 

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

func (*Server) QueryYakScriptByNames 

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 

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 

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

func (*Server) QueryYakScriptTagsGroup 

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

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 

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 

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) RenamePayloadFolder 

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

func (*Server) RenamePayloadGroup 

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

func (*Server) RenameYakScriptGroup 

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

func (*Server) RenderHTTPFuzzerPacket 

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 

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

func (*Server) RequestYakURL 

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 

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 

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 

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

func (*Server) RiskFieldGroup 

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

func (*Server) SaveCancelSimpleDetect 

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

func (*Server) SaveCodecFlow 

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 

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 

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 

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 

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

func (*Server) SaveYakScriptToOnline 

func (s *Server) SaveYakScriptToOnline(req *ypb.SaveYakScriptToOnlineRequest, stream ypb.Yak_SaveYakScriptToOnlineServer) 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 

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 

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) SimpleDetect 

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

func (*Server) SimpleDetectCreatReport 

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

func (*Server) SmokingEvaluatePlugin 

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

func (*Server) SmokingEvaluatePluginBatch 

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

SmokingEvaluatePluginBatch(*SmokingEvaluatePluginBatchRequest, Yak_SmokingEvaluatePluginBatchServer) error SmokingEvaluatePluginBatch

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) StartScrecorder 

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

func (*Server) StartVulinbox 

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) StringFuzzer 

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

func (*Server) SyntaxFlowScan 

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

func (*Server) ToGRPCNavigation 

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

func (*Server) TraceRoute 

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) UpdateAllPayloadGroup 

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) 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) UpdatePayload 

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

func (*Server) UpdatePayloadToFile 

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) UpdateSSAProgram 

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

func (*Server) UpdateSSARiskTags 

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

func (*Server) UpdateScreenRecorders 

func (s *Server) UpdateScreenRecorders(ctx context.Context, req *ypb.UpdateScreenRecorderRequest) (*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) UpdateWebShell 

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) UploadRiskToOnline 

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

func (*Server) UploadScreenRecorders 

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

func (*Server) ValidP12PassWord 

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

func (*Server) VerifySystemCertificate 

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 

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

func (*Server) YakVersionAtLeast 

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 

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

func (*Server) YaklangInspectInformation 

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

func (*Server) YaklangLanguageFind 

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

func (*Server) YaklangLanguageSuggestion 

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 

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

type ServerOpts 

type ServerOpts func(config *ServerConfig)

func WithInitFacadeServer 

func WithInitFacadeServer(init bool) ServerOpts

func WithProfileDatabasePath 

func WithProfileDatabasePath(p string) ServerOpts

func WithProjectDatabasePath 

func WithProjectDatabasePath(p string) ServerOpts

func WithReverseServerPort 

func WithReverseServerPort(port int) ServerOpts

func WithStartCacheLog 

func WithStartCacheLog() ServerOpts

type SyntaxFlowScanManager 

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

func CreateSyntaxflowTaskById 

func CreateSyntaxflowTaskById(
	taskId string, ctx context.Context,
	req *ypb.SyntaxFlowScanRequest,
	stream ypb.Yak_SyntaxFlowScanServer,
) (*SyntaxFlowScanManager, error)

func LoadSyntaxflowTaskFromDB 

func LoadSyntaxflowTaskFromDB(taskId string, ctx context.Context, stream ypb.Yak_SyntaxFlowScanServer) (*SyntaxFlowScanManager, error)

func (*SyntaxFlowScanManager) CurrentTaskIndex 

func (m *SyntaxFlowScanManager) CurrentTaskIndex() int64

func (*SyntaxFlowScanManager) IsPause 

func (m *SyntaxFlowScanManager) IsPause() bool

func (*SyntaxFlowScanManager) IsStop 

func (m *SyntaxFlowScanManager) IsStop() bool

func (*SyntaxFlowScanManager) Pause 

func (m *SyntaxFlowScanManager) Pause()

func (*SyntaxFlowScanManager) Query 

func (m *SyntaxFlowScanManager) Query(rule *schema.SyntaxFlowRule, prog *ssaapi.Program)

func (*SyntaxFlowScanManager) RestoreTask 

func (m *SyntaxFlowScanManager) RestoreTask(stream ypb.Yak_SyntaxFlowScanServer) error

func (*SyntaxFlowScanManager) Resume 

func (m *SyntaxFlowScanManager) Resume()

func (*SyntaxFlowScanManager) ResumeTask 

func (m *SyntaxFlowScanManager) ResumeTask() error

func (*SyntaxFlowScanManager) SaveTask 

func (m *SyntaxFlowScanManager) SaveTask() error

SaveTask save task info which is from manager to database

func (*SyntaxFlowScanManager) ScanNewTask 

func (m *SyntaxFlowScanManager) ScanNewTask() error

func (*SyntaxFlowScanManager) StartQuerySF 

func (m *SyntaxFlowScanManager) StartQuerySF(startIndex ...int64) error

func (*SyntaxFlowScanManager) StatusTask 

func (m *SyntaxFlowScanManager) StatusTask() error

func (*SyntaxFlowScanManager) Stop 

func (m *SyntaxFlowScanManager) Stop()

func (*SyntaxFlowScanManager) TaskId 

func (m *SyntaxFlowScanManager) TaskId() string

type SyntaxFlowScanTaskConfig 

type SyntaxFlowScanTaskConfig struct {
	*ypb.SyntaxFlowScanRequest
	RuleNames []string `json:"rule_names"`
}

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 

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

func GetVulinboxAgent 

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

func (*VulinboxAgentFacade) AddPing 

func (v *VulinboxAgentFacade) AddPing()

func (*VulinboxAgentFacade) AddRequestCount 

func (v *VulinboxAgentFacade) AddRequestCount()

func (*VulinboxAgentFacade) Close 

func (v *VulinboxAgentFacade) Close()

func (*VulinboxAgentFacade) IsClosed 

func (v *VulinboxAgentFacade) IsClosed() bool

func (*VulinboxAgentFacade) Status 

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

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 

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

func (*YamlArrayBuilder) Add 

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

type YamlMapBuilder 

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

func NewYamlMapBuilder 

func NewYamlMapBuilder() *YamlMapBuilder

func (*YamlMapBuilder) AddComment 

func (m *YamlMapBuilder) AddComment(comment string)

func (*YamlMapBuilder) AddEmptyLine 

func (m *YamlMapBuilder) AddEmptyLine()

func (*YamlMapBuilder) FilterEmptyField 

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

func (*YamlMapBuilder) ForceSet 

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

func (*YamlMapBuilder) MarshalToString 

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

func (*YamlMapBuilder) NewSubArrayBuilder 

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

func (*YamlMapBuilder) NewSubMapBuilder 

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

func (*YamlMapBuilder) Set 

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

func (*YamlMapBuilder) SetDefaultField 

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.