Documentation
¶
Index ¶
- Constants
- Variables
- func BuildTlsConfig(crt, key interface{}, cas ...interface{}) *tls.Config
- func CreateYakLogger(yakFile string) *yakLogger
- func CsrfOptWithHTTPS(b bool) csrfConfig
- func CsrfOptWithMultipartDefaultValue(b bool) csrfConfig
- func DebugMockUDP(rsp []byte) (string, int)
- func DebugMockUDPFromScan(du time.Duration, responses map[string][][]byte) (string, int)
- func DebugMockUDPProtocol(name string) (string, int)
- func DebugMockUDPWithTimeout(du time.Duration, rsp []byte) (string, int)
- func DownloadMMDB() error
- func DownloadOnlineAuthProxy(baseUrl string) error
- func Escape(s []byte) string
- func GenerateCSRFPoc(raw interface{}, opts ...csrfConfig) (string, error)
- func GetExtYakitLibByClient(client *YakitClient) map[string]interface{}
- func InitYakit(y *YakitClient)
- func JsonRawByteToMap(jbyte json.RawMessage) (map[string]interface{}, error)
- func JsonStrToVarList(jstr string) ([]interface{}, error)
- func JsonStreamToMapList(reader io.Reader) []map[string]interface{}
- func JsonStreamToMapListWithDepth(reader io.Reader, i int) []map[string]interface{}
- func JsonToMap(line string) map[string]string
- func JsonToMapList(line string) []map[string]string
- func JsonbToMap(jb postgres.Jsonb) (map[string]interface{}, error)
- func JsonbToString(jb postgres.Jsonb) (string, error)
- func JsonbToVarList(jb postgres.Jsonb) ([]interface{}, error)
- func MarshalYakitOutput(t interface{}) (string, string)
- func NewDefaultPoCConfig() *_pocConfig
- func NewPortFromMatchResult(f *fp.MatchResult) *yakit.Port
- func NewPortFromSpaceEngineResult(f *spacengine.NetSpaceEngineResult) *yakit.Port
- func NewPortFromSynScanResult(f *synscan.SynScanResult) *yakit.Port
- func NewSizedWaitGroup(size int) *utils.SizedWaitGroup
- func NewYakitLogExecResult(level string, data string, items ...interface{}) *ypb.ExecResult
- func NewYakitProgressExecResult(id string, progress float64) *ypb.ExecResult
- func NewYakitStatusCardExecResult(status, data string, items ...string) *ypb.ExecResult
- func ParamsGetOr(i map[string]string, keyValue, defaultValue string) string
- func QueryIP(ip string) (*geo.City, error)
- func QueryIPForISP(ip string) (*geo.ISP, error)
- func RawHandlerToExecOutput(h func(any) error) func(result *ypb.ExecResult) error
- func RegexpMatchEmail(i interface{}) []string
- func RegexpMatchHostPort(i interface{}) []string
- func RegexpMatchIP(i interface{}) []string
- func RegexpMatchIPv4(i interface{}) []string
- func RegexpMatchIPv6(i interface{}) []string
- func RegexpMatchMac(i interface{}) []string
- func RegexpMatchPathParam(i interface{}) []string
- func RegexpMatchTTY(i interface{}) []string
- func RegexpMatchURL(i interface{}) []string
- func SetEngineClient(e *antlr4yak.Engine, client *YakitClient)
- func SetYakitServer_LogHandler(h func(level string, info string)) func(s *YakitServer)
- func SetYakitServer_ProgressHandler(h func(id string, progress float64)) func(s *YakitServer)
- func YakitInfo(c *YakitClient) func(tmp string, items ...interface{})
- func YakitMessageGenerator(i interface{}) ([]byte, error)
- type GrokResult
- type HttpFlowShare
- type HttpFlowShareRequest
- type OnlineClient
- func (s *OnlineClient) DownloadYakitPluginAll(ctx context.Context) *OnlineDownloadStream
- func (s *OnlineClient) DownloadYakitPluginAllWithToken(ctx context.Context, token string, keywords string, pluginType string, ...) *OnlineDownloadStream
- func (s *OnlineClient) DownloadYakitPluginById(id string, token string) (*OnlinePlugin, error)
- func (s *OnlineClient) DownloadYakitPluginByIdWithToken(id string, token string) (*OnlinePlugin, error)
- func (s *OnlineClient) DownloadYakitPluginIDWithToken(ctx context.Context, token string, ids ...string) *OnlineDownloadStream
- func (s *OnlineClient) DownloadYakitPluginWithTokenBindMe(ctx context.Context, token string, keywords string, pluginType string, ...) *OnlineDownloadStream
- func (s *OnlineClient) DownloadYakitPluginsEx(ctx context.Context, all bool, ids []string, userToken string, bindMe bool, ...) *OnlineDownloadStream
- func (s *OnlineClient) DownloadYakitScriptName(ctx context.Context, token string, scriptName ...string) *OnlineDownloadStream
- func (s *OnlineClient) HttpFlowShare(ctx context.Context, token string, expiredTime int64, module string, ...) (*HttpFlowShare, error)
- func (s *OnlineClient) HttpFlowShareWithToken(ctx context.Context, token string, expiredTime int64, module string, ...) (*HttpFlowShare, error)
- func (s *OnlineClient) Save(db *gorm.DB, plugins ...*OnlinePlugin) error
- func (s *OnlineClient) UploadRiskToOnline(ctx context.Context, token string, hash string, ip string, ipInteger int64, ...) error
- func (s *OnlineClient) UploadRiskToOnlineWithToken(ctx context.Context, token string, risk *yakit.Risk) error
- func (s *OnlineClient) UploadScreenRecordersToOnline(ctx context.Context, token string, file os.File, noteInfo string, ...) error
- func (s *OnlineClient) UploadScreenRecordersWithToken(ctx context.Context, token string, file os.File, ...) error
- type OnlineDownloadStream
- type OnlinePaging
- type OnlinePlugin
- type OnlinePluginItem
- type OnlinePluginParam
- type PocConfig
- type ProtobufRecord
- type ProtobufRecords
- func (r *ProtobufRecords) Error() error
- func (r *ProtobufRecords) Find(index int) []*ProtobufRecord
- func (r *ProtobufRecords) FuzzEveryIndex(callback func(index int, typ string, data interface{}) interface{}) ([][]byte, error)
- func (r *ProtobufRecords) FuzzIndex(index int, callback func(index int, typ string, data interface{}) interface{}) ([][]byte, error)
- func (r *ProtobufRecords) MarshalJSON() ([]byte, error)
- func (r *ProtobufRecords) MarshalYAML() (interface{}, error)
- func (r *ProtobufRecords) String() string
- func (r *ProtobufRecords) ToBytes() []byte
- func (r *ProtobufRecords) ToHex() string
- func (r *ProtobufRecords) ToJSON() string
- func (r *ProtobufRecords) ToYAML() string
- func (r *ProtobufRecords) UnmarshalJSON(data []byte) error
- func (r *ProtobufRecords) UnmarshalYAML(node *yaml.Node) error
- type QueryOnlinePluginRequest
- type QueryUploadRiskOnlineRequest
- type RegisterOutputFuncType
- type ScreenRecordersUploadToOnlineRequest
- type StringMap
- type TagAndTypeValue
- type TagStat
- type TagValue
- type UnregisterOutputFuncType
- type WaitGroupProxy
- type YakitClient
- func (c *YakitClient) Error(tmp string, items ...interface{}) error
- func (c *YakitClient) Info(info string, items ...interface{}) error
- func (c *YakitClient) Output(t interface{}) error
- func (c *YakitClient) OutputLog(level string, info string, items ...interface{}) error
- func (c *YakitClient) Save(t interface{}) error
- func (c *YakitClient) SendRaw(y *YakitLog) error
- func (c *YakitClient) SetProgress(id string, progress float64) error
- func (c *YakitClient) Warn(info string, items ...interface{}) error
- type YakitFeature
- type YakitFixedTableData
- type YakitGraph
- type YakitHTTPFlowRisk
- type YakitLog
- type YakitMessage
- type YakitMessageHandleFunc
- type YakitProgress
- type YakitServer
- type YakitStatusCard
- type YakitTable
Constants ¶
View Source
const ( YAKIT_PLUGIN_TYPE_YAK = "yak" YAKIT_PLUGIN_TYPE_NUCLEI = "nuclei" YAKIT_PLUGIN_TYPE_MITM = "mitm" YAKIT_PLUGIN_TYPE_PORTSCAN = "port-scan" YAKIT_PLUGIN_TYPE_CODEC = "codec" YAKIT_PLUGIN_TYPE_PACKET_HACK = "packet-hack" )
View Source
const YAKIT_TAG_STATS = "YAKIT_TAG_STATS"
Variables ¶
View Source
var ( RegisterLogHook = createRegisterOutputFunc(logHooks) UnregisterLogHook = createUnregisterOutputFunc(logHooks) RegisterLogConsoleHook = createRegisterOutputFunc(logConsoleHooks) UnregisterLogConsoleHook = createUnregisterOutputFunc(logConsoleHooks) RegisterFailedHooks = createRegisterOutputFunc(failedHooks) UnregisterFailedHooks = createUnregisterOutputFunc(failedHooks) RegisterOutputHooks = createRegisterOutputFunc(outputHooks) UnregisterOutputHooks = createUnregisterOutputFunc(outputHooks) RegisterFinishHooks = createRegisterOutputFunc(finishHooks) UnregisterFinishHooks = createUnregisterOutputFunc(finishHooks) RegisterAlertHooks = createRegisterOutputFunc(alertHooks) UnregisterAlertHooks = createUnregisterOutputFunc(alertHooks) )
View Source
var ( //RE_HOSTNAME = regexp.MustCompile(`\b(?:[0-9A-Za-z][0-9A-Za-z-]{0,62})(?:\.(?:[0-9A-Za-z][0-9A-Za-z-]{0,62}))*(\.?|\b)`) RE_IPV4 = regexp.MustCompile(`(?:(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.){3}(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)`) RE_IPV6 = regexp.MustCompile(`((([0-9A-Fa-f]{1,4}:){7}([0-9A-Fa-f]{1,4}|:))|(([0-9A-Fa-f]{1,4}:){6}(:[0-9A-Fa-f]{1,4}|((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3})|:))|(([0-9A-Fa-f]{1,4}:){5}(((:[0-9A-Fa-f]{1,4}){1,2})|:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3})|:))|(([0-9A-Fa-f]{1,4}:){4}(((:[0-9A-Fa-f]{1,4}){1,3})|((:[0-9A-Fa-f]{1,4})?:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(([0-9A-Fa-f]{1,4}:){3}(((:[0-9A-Fa-f]{1,4}){1,4})|((:[0-9A-Fa-f]{1,4}){0,2}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(([0-9A-Fa-f]{1,4}:){2}(((:[0-9A-Fa-f]{1,4}){1,5})|((:[0-9A-Fa-f]{1,4}){0,3}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(([0-9A-Fa-f]{1,4}:){1}(((:[0-9A-Fa-f]{1,4}){1,6})|((:[0-9A-Fa-f]{1,4}){0,4}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(:(((:[0-9A-Fa-f]{1,4}){1,7})|((:[0-9A-Fa-f]{1,4}){0,5}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:)))(%.+)?`) RE_MAC = regexp.MustCompile(`((?:(?:[A-Fa-f0-9]{4}\.){2}[A-Fa-f0-9]{4})|(?:(?:[A-Fa-f0-9]{2}-){5}[A-Fa-f0-9]{2})|(?:(?:[A-Fa-f0-9]{2}:){5}[A-Fa-f0-9]{2}))`) RE_HOSTPORT = regexp.MustCompile(`(((?:(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.){3}(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?))|(((([0-9A-Fa-f]{1,4}:){7}([0-9A-Fa-f]{1,4}|:))|(([0-9A-Fa-f]{1,4}:){6}(:[0-9A-Fa-f]{1,4}|((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3})|:))|(([0-9A-Fa-f]{1,4}:){5}(((:[0-9A-Fa-f]{1,4}){1,2})|:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3})|:))|(([0-9A-Fa-f]{1,4}:){4}(((:[0-9A-Fa-f]{1,4}){1,3})|((:[0-9A-Fa-f]{1,4})?:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(([0-9A-Fa-f]{1,4}:){3}(((:[0-9A-Fa-f]{1,4}){1,4})|((:[0-9A-Fa-f]{1,4}){0,2}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(([0-9A-Fa-f]{1,4}:){2}(((:[0-9A-Fa-f]{1,4}){1,5})|((:[0-9A-Fa-f]{1,4}){0,3}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(([0-9A-Fa-f]{1,4}:){1}(((:[0-9A-Fa-f]{1,4}){1,6})|((:[0-9A-Fa-f]{1,4}){0,4}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(:(((:[0-9A-Fa-f]{1,4}){1,7})|((:[0-9A-Fa-f]{1,4}){0,5}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:)))(%.+)?)):(\b(?:[1-9][0-9]*)\b)`) RE_URL = regexp.MustCompile(`[A-Za-z]+(\+[A-Za-z+]+)?://\S+`) RE_PATH = regexp.MustCompile(`(?:/[A-Za-z0-9$.+!*'(){},~:;=@#%_\-]*)+`) RE_PATHPARAM = regexp.MustCompile(`(?:/[A-Za-z0-9$.+!*'(){},~:;=@#%_\-]*)+(?:\?[A-Za-z0-9$.+!*'|(){},~@#%&/=:;_?\-\[\]<>]*)?`) RE_EMAIL = regexp.MustCompile(`[a-zA-Z][a-zA-Z0-9_.+-=:]+@\b(?:[0-9A-Za-z][0-9A-Za-z-]{0,62})(?:\.(?:[0-9A-Za-z][0-9A-Za-z-]{0,62}))*(\.?|\b)`) RE_TTY = regexp.MustCompile(`(?:/dev/(pts|tty([pq])?)(\w+)?/?(?:[0-9]+))`) )
View Source
var (
Args []string
)
View Source
var BotExports = map[string]interface{}{ "New": bot.New, "FromEnv": bot.FromEnv, "webhook": bot.WithWebhook, "webhookWithSecret": bot.WithWebhookWithSecret, "workwx": bot.WithWebhook, "ding": bot.WithWebhookWithSecret, }
View Source
var BufioExport = map[string]interface{}{
"NewReader": _newReader,
"NewReaderSize": _newReaderSize,
"NewWriter": _newWriter,
"NewWriterSize": _newWriterSize,
"NewReadWriter": _newReadWriter,
"NewScanner": _newScanner,
}
View Source
var CNCountry = struct { GeoNameID uint `maxminddb:"geoname_id"` IsInEuropeanUnion bool `maxminddb:"is_in_european_union"` IsoCode string `maxminddb:"iso_code"` Names map[string]string `maxminddb:"names"` }(struct { GeoNameID uint IsInEuropeanUnion bool IsoCode string Names map[string]string }{GeoNameID: 1814991, IsInEuropeanUnion: false, IsoCode: "CN", Names: map[string]string{ "ru": "Китай", "zh-CN": "中国", "pt-BR": "China", "en": "China", "es": "China", "de": "China", "fr": "China", "ja": "中国", }})
(map[string]interface {}) (len=4) { (string) (len=9) "GeoNameID": (float64) 1.814991e+06, (string) (len=17) "IsInEuropeanUnion": (bool) false, (string) (len=7) "IsoCode": (string) (len=2) "CN", (string) (len=5) "Names": (map[string]interface {}) (len=8) { (string) (len=5) "pt-BR": (string) (len=5) "China", (string) (len=2) "ru": (string) (len=10) "Китай", (string) (len=5) "zh-CN": (string) (len=6) "中国", (string) (len=2) "de": (string) (len=5) "China", (string) (len=2) "en": (string) (len=5) "China", (string) (len=2) "es": (string) (len=5) "China", (string) (len=2) "fr": (string) (len=5) "Chine", (string) (len=2) "ja": (string) (len=6) "中国" } }
var CNCountry =
View Source
var CSRFExports = map[string]interface{}{ "Generate": GenerateCSRFPoc, "multipartDefaultValue": CsrfOptWithMultipartDefaultValue, "https": CsrfOptWithHTTPS, }
View Source
var CliExports = map[string]interface{}{ "Args": _getArgs, "Bool": _cliBool, "Have": _cliBool, "String": _cliString, "Int": _cliInt, "Integer": _cliInt, "Float": _cliFloat, "Double": _cliFloat, "YakitPlugin": _cliYakitPluginFiles, "StringSlice": _cliStringSlice, "Urls": _cliUrls, "Url": _cliUrls, "Ports": _cliPort, "Port": _cliPort, "Hosts": _cliHosts, "Host": _cliHosts, "Network": _cliHosts, "Net": _cliHosts, "File": _cliFile, "FileOrContent": _cliFileOrContent, "LineDict": _cliLineDict, "setHelp": _cliSetHelpInfo, "setDefault": _cliSetDefaultValue, "setRequired": _cliSetRequired, "SetCliName": _cliSetName, "SetDoc": _cliSetDocument, "help": _help, "check": func() { if helpParam.foundArgsIndex() != -1 { _help() os.Exit(1) } else if cliParamInvalid.IsSet() { errorMsg = strings.TrimSpace(errorMsg) if len(errorMsg) > 0 { fmt.Printf("Error:\n %s\n\n", errorMsg) } _help() } }, }
View Source
var CodecExports = map[string]interface{}{}/* 122 elements not displayed */
View Source
var ContextExports = map[string]interface{}{ "Seconds": utils.TimeoutContextSeconds, "New": context.Background, "Background": context.Background, "WithCancel": context.WithCancel, "WithTimeout": context.WithTimeout, "WithDeadline": context.WithDeadline, "WithValue": context.WithValue, }
View Source
var CrawlerExports = map[string]interface{}{}
View Source
var DatabaseExports = map[string]interface{}{ "DownloadGeoIP": DownloadMMDB, "QueryIPCity": QueryIP, "QueryIPForIPS": QueryIPForISP, "SaveHTTPFlowFromNative": saveCrawler, "SaveHTTPFlowFromNativeWithType": saveHTTPFlowWithType, "SavePortFromResult": savePortFromObj, "SaveDomain": saveDomain, "SavePayload": savePayloads, "SavePayloadByFile": savePayloadByFile, "YAKIT_PLUGIN_TYPE_NUCLEI": YAKIT_PLUGIN_TYPE_NUCLEI, "YAKIT_PLUGIN_TYPE_YAK": YAKIT_PLUGIN_TYPE_YAK, "YAKIT_PLUGIN_TYPE_MITM": YAKIT_PLUGIN_TYPE_MITM, "YAKIT_PLUGIN_TYPE_PORTSCAN": YAKIT_PLUGIN_TYPE_PORTSCAN, "YAKIT_PLUGIN_TYPE_CODEC": YAKIT_PLUGIN_TYPE_CODEC, "YAKIT_PLUGIN_TYPE_PACKET_HACK": YAKIT_PLUGIN_TYPE_PACKET_HACK, "SaveYakitPlugin": saveYakitPlugin, "QueryUrlsByKeyword": queryUrlsByKeyword, "QueryUrlsAll": queryAllUrls, "QueryHTTPFlowsByKeyword": queryHTTPFlowByKeyword, "QueryHTTPFlowsAll": func() chan *yakit.HTTPFlow { return queryHTTPFlowByKeyword("") }, "QueryPortsByUpdatedAt": queryPortsByUpdatedAt, "QueryPortsByTaskName": queryPortsByTaskName, "QueryHTTPFlowsByID": queryHTTPFlowByID, "QueryHostPortByNetwork": queryHostPortByNetwork, "QueryHostPortByKeyword": queryHostAssetByNetwork, "QueryHostsByDomain": queryHostAssetByDomainKeyword, "QueryDomainsByNetwork": queryDomainAssetByNetwork, "QueryDomainsByDomainKeyword": queryDomainAssetByDomainKeyword, "QueryDomainsByTitle": queryDomainAssetByHTMLTitle, "QueryPayloadGroups": getPayloadGroups, "DeletePayloadByGroup": deletePayload, "SetKey": func(k, v interface{}) error { return yakit.SetKey(consts.GetGormProfileDatabase(), k, v) }, "GetKey": func(k interface{}) string { return yakit.GetKey(consts.GetGormProfileDatabase(), k) }, "DelKey": func(k interface{}) { yakit.DelKey(consts.GetGormProfileDatabase(), k) }, "GetYakitPluginByName": queryYakitPluginByName, "SaveYakitMenuItemByBatchExecuteConfig": saveYakitMenuItemByBatchExecuteConfig, "DeleteYakitMenuItemAll": deleteYakitMenuItemAll, "YieldYakScriptAll": _yieldYakScript, "DeleteYakScriptByName": _deleteYakScriptByName, "CreateTemporaryYakScript": yakit.CreateTemporaryYakScript, }
View Source
var DictUtilExports = map[string]interface{}{
"Mix": _dictMix,
}
View Source
var DnsExports = map[string]interface{}{
"QueryIP": _dnsQueryIP,
"QueryIPAll": _dnsQueryIPAll,
"QueryNS": _dnsQueryNS,
"QueryTXT": _dnsQueryTxt,
"QuertAxfr": _dnsQueryAxfr,
"timeout": _dnsConfigOpt_WithTimeout,
"dnsServers": _dnsConfigOpt_WithDNSServers,
}
View Source
var EmptyBytesSlice = make([][]byte, 0)
View Source
var EnvExports = map[string]interface{}{ "Get": func(key string) string { return os.Getenv(key) }, "Set": func(key string, value string) { _ = os.Setenv(key, value) }, }
View Source
var ExecExports = map[string]interface{}{ "CommandContext": _execStringToCommand, "Command": func(i string) (*exec.Cmd, error) { return _execStringToCommand(context.Background(), i) }, "CheckCrash": _checkExecCrash, "SystemBatch": _execSystemBatch, "SystemContext": _execSystem, "System": func(i string) ([]byte, error) { return _execSystem(context.Background(), i) }, "WatchStdout": _execWatchStdout, "WatchOutput": _execWatchStdout, "WatchStderr": _execWatchStderr, "timeout": _execTimeout, "callback": _execSetCallback, "concurrent": _execConcurrent, }
系统命令执行导出接口
View Source
var FileExport = map[string]interface{}{ "ReadLines": readLines, "GetDirPath": filepath.Dir, "Split": filepath.Split, "IsExisted": func(name string) bool { ret, _ := utils.PathExists(name) return ret }, "IsFile": func(file string) bool { if info, err := os.Stat(file); err != nil { return false } else { if info.IsDir() { return false } return true } }, "IsAbs": filepath.IsAbs, "IsLink": _fileIsLink, "IsDir": _fileIsDir, "Join": filepath.Join, "O_RDWR": os.O_RDWR, "O_CREATE": os.O_CREATE, "O_APPEND": os.O_APPEND, "O_EXCL": os.O_EXCL, "O_RDONLY": os.O_RDONLY, "O_SYNC": os.O_SYNC, "O_TRUNC": os.O_TRUNC, "O_WRONLY": os.O_WRONLY, "ReadAll": ioutil.ReadAll, "ReadFile": ioutil.ReadFile, "TempFile": _tempFile, "TempFileName": func() (string, error) { f, err := _tempFile() if err != nil { return "", err } f.Close() return f.Name(), nil }, "Mkdir": func(name string) error { return os.Mkdir(name, os.ModePerm) }, "MkdirAll": func(name string) error { return os.MkdirAll(name, os.ModePerm) }, "Rename": os.Rename, "Remove": os.RemoveAll, "Create": func(name string) (*_yakFile, error) { f, err := os.Create(name) if err != nil { return nil, err } return &_yakFile{file: f}, nil }, "Open": func(name string) (*_yakFile, error) { file, err := os.OpenFile(name, os.O_CREATE|os.O_RDWR, os.ModePerm) if err != nil { return nil, err } return &_yakFile{file: file}, nil }, "OpenFile": func(name string, flag int, perm os.FileMode) (*_yakFile, error) { f, err := os.OpenFile(name, flag, perm) if err != nil { return nil, err } return &_yakFile{file: f}, nil }, "Stat": os.Stat, "Lstat": os.Lstat, "Save": _saveFile, "SaveJson": func(name string, i interface{}) error { switch ret := i.(type) { case []byte: return _saveFile(name, ret) case string: return _saveFile(name, ret) case []string: return _saveFile(name, ret) default: raw, err := json.Marshal(i) if err != nil { return utils.Errorf("marshal %v failed: %s", spew.Sdump(i), err) } return _saveFile(name, raw) } }, "Cat": func(i string) { raw, err := ioutil.ReadFile(i) _diewith(err) fmt.Print(string(raw)) }, "TailF": func(i string, line func(i string)) { t, err := tail.TailFile(i, tail.Config{ MustExist: false, Follow: true, Logger: tail.DiscardingLogger, }) if err != nil { log.Errorf("tail failed: %s", err) return } for { select { case l, ok := <-t.Lines: if !ok { return } if line != nil { line(l.Text) } } } }, "Mv": os.Rename, "Rm": os.RemoveAll, "Cp": _fileCopy, "Dir": _lsDir, "Ls": _lsDir, "Abs": func(i string) string { raw, err := filepath.Abs(i) if err != nil { log.Errorf("fetch abs path failed for[%v]: %s", i, raw) return i } return raw }, "ReadFileInfoInDirectory": utils.ReadFilesRecursively, "ReadDirInfoInDirectory": utils.ReadDirsRecursively, "NewMultiFileLineReader": mfreader.NewMultiFileLineReader, }
View Source
var FunkExports = map[string]interface{}{ "WaitConnect": WaitConnect, "Map": func(i interface{}, fc funkGeneralFuncType) interface{} { return funk.Map(i, func(i interface{}) interface{} { return fc(i) }) }, "ToMap": funk.ToMap, "Reduce": func(i interface{}, fc funkGeneralReduceFuncType, acc interface{}) interface{} { return funk.Reduce(i, func(pre interface{}, after interface{}) interface{} { return fc(pre, after) }, acc) }, "Filter": func(i interface{}, fc func(interface{}) bool) interface{} { return funk.Filter(i, func(pre interface{}) bool { return fc(pre) }) }, "Find": func(i interface{}, fc func(interface{}) bool) interface{} { return funk.Find(i, func(pre interface{}) bool { return fc(pre) }) }, "Foreach": func(i interface{}, fc func(interface{})) { funk.ForEach(i, func(pre interface{}) { fc(pre) }) }, "ForeachRight": func(i interface{}, fc func(interface{})) { funk.ForEachRight(i, func(pre interface{}) { fc(pre) }) }, "Contains": funk.Contains, "IndexOf": funk.IndexOf, "Difference": funk.Difference, "Subtract": funk.Subtract, "Intersect": intersect, "IsSubset": funk.Subset, "Equal": funk.IsEqual, "Chunk": funk.Chunk, "RemoveRepeat": funk.Uniq, "Tail": funk.Tail, "Head": funk.Head, "Drop": funk.Drop, "Shift": func(i interface{}) interface{} { return funk.Drop(i, 1) }, "Values": funk.Values, "Keys": funk.Keys, "Zip": funk.Zip, "ToFloat64": funk.ToFloat64, "Shuffle": funk.Shuffle, "Reverse": funk.Reverse, "Sum": funk.Sum, "All": funk.All, "Max": max, "Min": min, "Some": funk.Some, "Every": funk.Every, "Any": funk.Any, "Sort": sort.SliceStable, "Range": func(i int) []interface{} { return make([]interface{}, i) }, "If": func(i bool, a, b interface{}) interface{} { if i { return a } else { return b } }, "ConvertToMap": func(i interface{}) map[string][]string { return utils.InterfaceToMap(i) }, }
View Source
var FuzzExports = map[string]interface{}{ "Strings": _fuzz, "StringsWithParam": _fuzzFuncEx, "StringsFunc": _fuzzFunc, "HTTPRequest": mutate.NewFuzzHTTPRequest, "MustHTTPRequest": mutate.NewMustFuzzHTTPRequest, "https": mutate.OptHTTPS, "UrlsToHTTPRequests": mutate.UrlsToHTTPRequests, "UrlToHTTPRequest": _urlToFuzzRequest, "ProtobufHex": _protobufRecordsFromHex, "ProtobufBytes": _protobufRecordsFromBytes, "ProtobufJSON": _protobufRecordsFromJSON, "ProtobufYAML": _protobufRecordsFromYAML, "WithDelay": mutate.WithPoolOPt_DelaySeconds, "WithNamingContext": mutate.WithPoolOpt_NamingContext, "WithConcurrentLimit": mutate.WithPoolOpt_Concurrent, "WithTimeOut": mutate.WithPoolOpt_Timeout, }
View Source
var GeoJsonExports = map[string]interface{}{ "NewFeatureCollection": geojson.NewFeatureCollection, "FeaturesToCollection": func(fs ...*geojson.Feature) *geojson.FeatureCollection { col := geojson.NewFeatureCollection() for _, i := range fs { col.AddFeature(i) } return col }, "WithValue": func(f *geojson.Feature, value float64) *geojson.Feature { f.SetProperty("value", value) return f }, "WithName": func(f *geojson.Feature, value string) *geojson.Feature { f.SetProperty("name", value) return f }, "WithNameValue": func(f *geojson.Feature, name string, value float64) *geojson.Feature { f.SetProperty("name", name) f.SetProperty("value", value) return f }, "WithProperty": func(f *geojson.Feature, key string, value float64) *geojson.Feature { f.SetProperty(key, value) return f }, }
View Source
var GlobalExport = map[string]interface{}{ "_createOnLogger": createLogger, "_createOnLoggerConsole": createConsoleLogger, "_createOnFailed": createFailed, "_createOnOutput": createOnOutput, "_createOnFinished": createOnFinished, "_createOnAlert": createOnAlert, "loglevel": setLogLevel, "logquiet": _logDiscard, "logdiscard": _logDiscard, "logrecover": _logRecover, "yakit_output": dummyN, "yakit_save": dummyN, "yakit_status": dummyN, "fail": _failed, "die": _diewith, "uuid": func() string { return uuid.New().String() }, "timestamp": func() int64 { return time.Now().Unix() }, "nanotimestamp": func() int64 { return time.Now().UnixNano() }, "datetime": func() string { return time.Now().Format("2006-01-02 15:04:05") }, "date": func() string { return time.Now().Format("2006-01-02") }, "now": time.Now, "timestampToDatetime": func(tValue int64) string { tm := time.Unix(tValue, 0) return tm.Format("2006-01-02 15:04:05") }, "datetimeToTimestamp": func(str string) (int64, error) { t, err := time.Parse("2006-01-02 15:04:05", str) if err != nil { return 0, err } return t.Unix(), nil }, "timestampToTime": func(i int64) time.Time { return time.Unix(i, 0) }, "dump": func(i ...interface{}) { spew.Dump(i...) }, "sdump": func(i ...interface{}) string { return spew.Sdump(i...) }, "randn": func(min, max int) int { if min > max { panic(_sfmt("randn failed; min: %v max: %v", min, max)) } return min + rand.Intn(max-min) }, "randstr": func(length int) string { return utils.RandStringBytes(length) }, "sleep": sleep, "wait": func(i interface{}) { switch ret := i.(type) { case context.Context: select { case <-ret.Done(): } case string: sleep(parseFloat(ret)) case float64: sleep(ret) case float32: sleep(float64(ret)) case int: sleep(float64(ret)) default: panic(fmt.Sprintf("cannot wait %v", spew.Sdump(ret))) } }, "assert": _assert, "assertTrue": _assert, "isEmpty": func(i interface{}) bool { if i == nil || i == spec.Undefined { return true } return false }, "assertEmpty": func(i interface{}) { if i == nil || i == spec.Undefined { return } panic(_sfmt("expect nil but got %v", spew.Sdump(i))) }, "assertf": func(b bool, f string, items ...interface{}) { if !b { panic(_sfmt(f, items)) } }, "parseInt": parseInt, "parseStr": parseString, "parseString": parseString, "parseBool": parseBool, "parseBoolean": parseBool, "parseFloat": parseFloat, "atoi": strconv.Atoi, "parseTime": time.Parse, "tick1s": tick1s, "desc": _desc, "descStr": _descToString, "chr": func(i interface{}) string { return string([]byte{byte(parseInt(utils.InterfaceToString(i)))}) }, "ord": func(i interface{}) int { switch ret := i.(type) { case byte: return int(ret) default: strRaw := utils.InterfaceToString(i) if strRaw == "" { return -1 } if r := []rune(strRaw); r != nil { return int(r[0]) } return int(strRaw[0]) } }, "typeof": func(i interface{}) reflect.Type { return reflect.TypeOf(i) }, }
View Source
var GrokExports = map[string]interface{}{ "ExtractIPv4": RegexpMatchIPv4, "ExtractIPv6": RegexpMatchIPv6, "ExtractIP": RegexpMatchIP, "ExtractEmail": RegexpMatchEmail, "ExtractPath": RegexpMatchPathParam, "ExtractTTY": RegexpMatchTTY, "ExtractURL": RegexpMatchURL, "ExtractHostPort": RegexpMatchHostPort, "ExtractMac": RegexpMatchMac, }
View Source
var GzipExports = map[string]interface{}{ "Compress": utils.GzipCompress, "Decompress": utils.GzipDeCompress, "IsGzip": utils.IsGzip, }
View Source
var HTTPServer_Serve = _httpServe
View Source
var HTTPServer_ServeOpt_Callback = _httpServerOptCallback
View Source
var HTTPServer_ServeOpt_Context = _httpServerOptContext
View Source
var HttpExports = yakhttp.HttpExports
View Source
var HttpPoolExports = mutate.HttpPoolExports
View Source
var HttpServeExports = map[string]interface{}{
"Serve": _httpServe,
"tlsCertAndKey": _httpServerOptCaAndKey,
"context": _httpServerOptContext,
"handler": _httpServerOptCallback,
"LocalFileSystemServe": _localFileSystemServe,
}
View Source
var IoExports = map[string]interface{}{ "ReadAll": ioutil.ReadAll, "ReadFile": ioutil.ReadFile, "ReadEvery1s": func(c context.Context, reader io.Reader, f func([]byte) bool) { utils.ReadWithContextTickCallback(c, reader, f, 1*time.Second) }, "NopCloser": ioutil.NopCloser, "Copy": io.Copy, "CopyN": io.CopyN, "Discard": ioutil.Discard, "EOF": io.EOF, "LimitReader": io.LimitReader, "MultiReader": io.MultiReader, "Pipe": io.Pipe, "TeeReader": io.TeeReader, "WriteString": io.WriteString, "ReadStable": func(conn net.Conn, float float64) []byte { return utils.StableReader(conn, utils.FloatSecondDuration(float), 10*1024*1024) }, }
View Source
var ( JSOttoExports = map[string]interface{}{ "PoweredBy": "github.com/robertkrimen/otto", "New": _jsNewEngine, "Run": otto.Run, "CallFunctionFromCode": _jsCallFuncFromCode, "NullValue": otto.NullValue, "UndefinedValue": otto.UndefinedValue, "FalseValue": otto.FalseValue, "ToValue": otto.ToValue, "NaNValue": otto.NaNValue, "TrueValue": otto.TrueValue, "ASTWalk": javascript.BasicJavaScriptASTWalker, "Parse": _Pares, "GetSTType": javascript.GetStatementType, } )
View Source
var JsonExports = map[string]interface{}{ "New": _yakJson, "Marshal": json.Marshal, "dumps": _jsonDumps, "loads": _jsonLoad, "Find": jsonpath.Find, "FindPath": jsonpath.FindFirst, "ReplaceAll": jsonpath.ReplaceAll, "ExtractJSON": jsonextractor.ExtractStandardJSON, "ExtractJSONEx": jsonextractor.ExtractJSONWithRaw, }
View Source
var LdapExports = map[string]interface{}{
"Login": _login,
"port": optLdap_Port,
"username": optLdap_Username,
"password": optLdap_Password,
}
View Source
var LogExports = map[string]interface{}{ "info": log.Infof, "setLevel": setLogLevel, "debug": log.Debugf, "warn": log.Warningf, "error": log.Errorf, }
View Source
var MathExport = map[string]interface{}{ "Round": math.Round, "Sqrt": math.Sqrt, "Pow": math.Pow, "Pow10": math.Pow10, "Floor": math.Floor, "Ceil": math.Ceil, "RoundToEven": math.RoundToEven, "Abs": math.Abs, "NaN": math.NaN, "IsNaN": math.IsNaN, "Pi": math.Pi, "Ln10": math.Ln10, "Ln2": math.Ln2, "E": math.E, "Sqrt2": math.Sqrt2, "SqrtPi": math.SqrtPi, "SqrtE": math.SqrtE, }
View Source
var (
MitmExports = map[string]interface{}{
"Start": startMitm,
"Bridge": startBridge,
"maxContentLength": mitmMaxContentLength,
"isTransparent": mitmConfigIsTransparent,
"context": mitmConfigContext,
"host": mitmConfigHost,
"callback": mitmConfigCallback,
"hijackHTTPRequest": mitmConfigHijackHTTPRequest,
"hijackHTTPResponse": mitmConfigHijackHTTPResponse,
"wscallback": mitmConfigWSCallback,
"wsforcetext": mitmConfigWSForceTextFrame,
"rootCA": mitmConfigCertAndKey,
"useDefaultCA": mitmConfigUseDefault,
}
)
View Source
var MmdbExports = map[string]interface{}{ "Open": maxminddb.Open, "QueryIPCity": func(r *maxminddb.Reader, ip string) (*geo.City, error) { var c geo.City err := r.Lookup(net.ParseIP(utils.FixForParseIP(ip)), &c) if err != nil { return nil, utils.Errorf("loop up failed: %s", err) } if c.Country.IsoCode == "HK" || c.Country.IsoCode == "MO" { c.City.Names = c.Country.Names c.City.GeoNameID = c.Country.GeoNameID c.Country = CNCountry } else if c.Country.IsoCode == "TW" { if c.City.GeoNameID > 0 { var maps = make(map[string]string) for k, v := range c.City.Names { if c.Country.Names[k] != "" { maps[k] = fmt.Sprintf("%v/%v", c.Country.Names[k], v) } } } else { c.City.Names = c.Country.Names c.City.GeoNameID = c.Country.GeoNameID } c.Country = CNCountry } return &c, nil }, }
View Source
var PingExports = map[string]interface{}{
"Scan": _pingScan,
"Ping": _ping,
"excludeHosts": _pingConfigOpt_excludeHosts,
"onResult": _pingConfigOpt_onResult,
"dnsTimeout": _pingConfigOpt_withDNSTimeout,
"timeout": _pingConfigOpt_withTimeout,
"dnsServers": _pingConfigOpt_dnsServers,
"scanCClass": _pingConfigOpt_scanCClass,
"skip": _pingConfigOpt_skipped,
"concurrent": _pingConfigOpt_concurrent,
"tcpPingPorts": _pingConfigOpt_tcpPingPorts,
"proxy": _pingConfigOpt_proxy,
}
View Source
var PoCExports = map[string]interface{}{}/* 107 elements not displayed */
View Source
var PoCOptWithFromPlugin = _pocOptWithFromPlugin
View Source
var PoCOptWithProxy = _pocOptWithProxy
View Source
var PoCOptWithRuntimeId = _pocOptWithRuntimeId
View Source
var PoCOptWithSaveHTTPFlow = _pocOptWithSave
View Source
var PoCOptWithSource = _pocOptWIthSource
View Source
var RdpExports = map[string]interface{}{ "Login": bruteutils.RDPLogin, "Version": extrafp.RDPVersion, }
View Source
var RedisExports = map[string]interface{}{
"New": newRedis,
"host": redisOpt_Host,
"port": redisOpt_Port,
"addr": redisOpt_Addr,
"username": redisOpt_Username,
"password": redisOpt_Password,
"timeoutSeconds": redisOpt_TimeoutSeconds,
"retry": redisOpt_Retry,
}
View Source
var RegenExports = map[string]interface{}{ "Generate": regen.Generate, "MustGenerate": regen.MustGenerate, }
View Source
var Regexp2Export = map[string]interface{}{ "QuoteMeta": regexp2.Escape, "Compile": re2Compile, "CompileWithOption": func(rule string, opt int) (*regexp2.Regexp, error) { return regexp2.Compile(rule, regexp2.RegexOptions(opt)) }, "OPT_None": regexp2.None, "OPT_IgnoreCase": regexp2.IgnoreCase, "OPT_Multiline": regexp2.Multiline, "OPT_ExplicitCapture": regexp2.ExplicitCapture, "OPT_Compiled": regexp2.Compiled, "OPT_Singleline": regexp2.Singleline, "OPT_IgnorePatternWhitespace": regexp2.IgnorePatternWhitespace, "OPT_RightToLeft": regexp2.RightToLeft, "OPT_Debug": regexp2.Debug, "OPT_ECMAScript": regexp2.ECMAScript, "OPT_RE2": regexp2.RE2, "Find": re2Find, "FindAll": re2FindAll, "FindSubmatch": re2FindSubmatch, "FindSubmatchAll": re2FindSubmatchAll, "FindGroup": re2ExtractGroups, "FindGroupAll": re2ExtractGroupsAll, "ReplaceAll": re2ReplaceAll, "ReplaceAllWithFunc": re2ReplaceAllFunc, }
View Source
var RegexpExport = map[string]interface{}{ "QuoteMeta": regexp.QuoteMeta, "Compile": regexp.Compile, "CompilePOSIX": regexp.CompilePOSIX, "MustCompile": regexp.MustCompile, "MustCompilePOSIX": regexp.MustCompilePOSIX, "Match": reMatch, "Grok": Grok, "ExtractIPv4": RegexpMatchIPv4, "ExtractIPv6": RegexpMatchIPv6, "ExtractIP": RegexpMatchIP, "ExtractEmail": RegexpMatchEmail, "ExtractPath": RegexpMatchPathParam, "ExtractTTY": RegexpMatchTTY, "ExtractURL": RegexpMatchURL, "ExtractHostPort": RegexpMatchHostPort, "ExtractMac": RegexpMatchMac, "Find": _find_extractByRegexp, "FindIndex": _findIndex_extractByRegexp, "FindAll": _findAll_extractByRegexp, "FindAllIndex": _findAllIndex_extractByRegexp, "FindSubmatch": _findSubmatch_extractByRegexp, "FindSubmatchIndex": _findSubmatchIndex_extractByRegexp, "FindSubmatchAll": _findSubmatchAll_extractByRegexp, "FindSubmatchAllIndex": _findSubmatchAllIndex_extractByRegexp, "FindGroup": reExtractGroups, "FindGroupAll": reExtractGroupsAll, "ReplaceAll": _replaceAll_extractByRegexp, "ReplaceAllWithFunc": _replaceAllFunc_extractByRegexp, }
View Source
var ( RiskExports = map[string]interface{}{ "CreateRisk": yakit.CreateRisk, "Save": yakit.SaveRisk, "NewRisk": yakitNewRisk, "YieldRiskByTarget": func(target string) chan *yakit.Risk { return yakit.YieldRisksByTarget(consts.GetGormProjectDatabase(), context.Background(), target) }, "YieldRiskByRuntimeId": func(runtimeId string) chan *yakit.Risk { return yakit.YieldRisksByRuntimeId(consts.GetGormProjectDatabase(), context.Background(), runtimeId) }, "YieldRiskByCreateAt": func(timestamp int64) chan *yakit.Risk { return yakit.YieldRisksByCreateAt(consts.GetGormProjectDatabase(), context.Background(), timestamp) }, "DeleteRiskByTarget": func(addr string) { yakit.DeleteRiskByTarget(consts.GetGormProjectDatabase(), addr) }, "DeleteRiskByID": func(id any) { var err = yakit.DeleteRiskByID(consts.GetGormProjectDatabase(), int64(utils.Atoi(utils.InterfaceToString(id)))) if err != nil { log.Errorf("delete risk by id error: %v", err) } }, "NewUnverifiedRisk": yakit.NewUnverifiedRisk, "NewPublicReverseRMIUrl": yakit.NewPublicReverseProtoUrl("rmi"), "NewPublicReverseHTTPSUrl": yakit.NewPublicReverseProtoUrl("https"), "NewPublicReverseHTTPUrl": yakit.NewPublicReverseProtoUrl("http"), "NewLocalReverseRMIUrl": yakit.NewLocalReverseProtoUrl("rmi"), "NewLocalReverseHTTPSUrl": yakit.NewLocalReverseProtoUrl("https"), "NewLocalReverseHTTPUrl": yakit.NewLocalReverseProtoUrl("http"), "HaveReverseRisk": yakit.HaveReverseRisk, "NewRandomPortTrigger": yakit.NewRandomPortTrigger, "NewDNSLogDomain": yakit.NewDNSLogDomain, "CheckDNSLogByToken": yakit.CheckDNSLogByToken, "CheckRandomTriggerByToken": yakit.CheckRandomTriggerByToken, "CheckICMPTriggerByLength": yakit.CheckICMPTriggerByLength, "ExtractTokenFromUrl": yakit.ExtractTokenFromUrl, "payload": yakit.WithRiskParam_Payload, "title": yakit.WithRiskParam_Title, "type": yakit.WithRiskParam_RiskType, "titleVerbose": yakit.WithRiskParam_TitleVerbose, "description": yakit.WithRiskParam_Description, "solution": yakit.WithRiskParam_Solution, "typeVerbose": yakit.WithRiskParam_RiskVerbose, "parameter": yakit.WithRiskParam_Parameter, "token": yakit.WithRiskParam_Token, "details": yakit.WithRiskParam_Details, "request": yakit.WithRiskParam_Request, "response": yakit.WithRiskParam_Response, "runtimeId": yakit.WithRiskParam_RuntimeId, "potential": yakit.WithRiskParam_Potential, "cve": yakit.WithRiskParam_CVE, "severity": yakit.WithRiskParam_Severity, "level": yakit.WithRiskParam_Severity, "fromYakScript": yakit.WithRiskParam_FromScript, } )
View Source
var SambaExports = map[string]interface{}{
"username": _smbConfig_Username,
"password": _smbConfig_Password,
"domain": _smbConfig_Domain,
"workstation": _smbConfig_Workstation,
"hash": _smbConfig_Hash,
"debug": _smbConfig_Debug,
"Connect": smbConn,
}
View Source
var SpaceEngineExports = map[string]interface{}{
"ShodanQuery": _shodan,
"FofaQuery": _fofa,
"QuakeQuery": _quake,
"HunterQuery": _hunter,
"ZoomeyeQuery": _zoomeye,
"maxPage": _spaceEngine_MaxPage,
"maxRecord": _spaceEngine_MaxRecord,
"pageSize": _spaceEngine_PageSize,
}
View Source
var (
StringsExport = map[string]interface{}{}/* 112 elements not displayed */
)
View Source
var SyncExport = map[string]interface{}{ "NewWaitGroup": NewWaitGroup, "NewSizedWaitGroup": NewSizedWaitGroup, "NewMutex": func() *sync.Mutex { return new(sync.Mutex) }, "NewLock": func() *sync.Mutex { return new(sync.Mutex) }, "NewMap": func() *sync.Map { return new(sync.Map) }, "NewOnce": func() *sync.Once { return new(sync.Once) }, "NewRWMutex": func() *sync.RWMutex { return new(sync.RWMutex) }, "NewPool": func() *sync.Pool { return new(sync.Pool) }, "NewCond": func() *sync.Cond { return sync.NewCond(new(sync.Mutex)) }, }
View Source
var SystemExports = map[string]interface{}{ "IsTCPPortOpen": func(p int) bool { return !utils.IsTCPPortAvailable(p) }, "IsUDPPortOpen": func(p int) bool { return !utils.IsUDPPortAvailable(p) }, "LookupHost": lookupHost, "LookupIP": lookupIP, "IsTCPPortAvailable": utils.IsTCPPortAvailable, "IsUDPPortAvailable": utils.IsUDPPortAvailable, "GetRandomAvailableTCPPort": utils.GetRandomAvailableTCPPort, "GetRandomAvailableUDPPort": utils.GetRandomAvailableUDPPort, "IsRemoteTCPPortOpen": func(host string, p int) bool { return utils.IsTCPPortOpen(host, p) }, "GetMachineID": utils.GetMachineCode, "Remove": os.Remove, "RemoveAll": os.RemoveAll, "Rename": os.Rename, "TempDir": os.TempDir, "Getwd": os.Getwd, "Getpid": os.Getpid, "Getppid": os.Getppid, "Getuid": os.Getuid, "Geteuid": os.Geteuid, "Getgid": os.Getgid, "Getegid": os.Getegid, "Environ": os.Environ, "Hostname": os.Hostname, "Unsetenv": os.Unsetenv, "LookupEnv": os.LookupEnv, "Clearenv": os.Clearenv, "Setenv": os.Setenv, "Getenv": os.Getenv, "Exit": os.Exit, "Args": os.Args, "Stdout": os.Stdout, "Stdin": os.Stdin, "Stderr": os.Stderr, "Executable": os.Executable, "ExpandEnv": os.ExpandEnv, "Pipe": os.Pipe, "Chdir": os.Chdir, "Chmod": os.Chmod, "Chown": os.Chown, "OS": runtime.GOOS, "ARCH": runtime.GOARCH, "IsPrivileged": privileged.GetIsPrivileged(), "GetDefaultDNSServers": func() []string { return utils.DefaultDNSServer }, "WaitConnect": utils.WaitConnect, }
View Source
var TcpExports = map[string]interface{}{ "MockServe": utils.DebugMockHTTP, "Connect": _tcpConnect, "clientTimeout": _tcpTimeout, "clientLocal": _tcpLocalAddr, "clientTls": _tcpClientTls, "cliengProxy": _tcpClientProxy, "Serve": tcpServe, "serverCallback": _tcpServeCallback, "serverContext": _tcpServeContext, "serverTls": _tcpServerTls, "Forward": _tcpPortForward, }
View Source
var TimeExports = map[string]interface{}{ "Now": time.Now, "now": time.Now, "GetCurrentMonday": utils.GetCurrentWeekMonday, "GetCurrentDate": utils.GetCurrentDate, "sleep": sleep, "Sleep": sleep, "Parse": time.Parse, "ParseDuration": time.ParseDuration, "Unix": time.Unix, "After": func(i float64) <-chan time.Time { return time.After(utils.FloatSecondDuration(i)) }, "AfterFunc": time.AfterFunc, "NewTimer": func(i float64) *time.Timer { return time.NewTimer(utils.FloatSecondDuration(i)) }, "NewTicker": func(i float64) *time.Ticker { return time.NewTicker(utils.FloatSecondDuration(i)) }, "Until": time.Until, "Since": time.Since, }
View Source
var TimeZoneExports = map[string]interface{}{ "Get": time.LoadLocation, "Now": func(i string) time.Time { loc, err := time.LoadLocation(i) if err != nil { return time.Now() } return time.Now().In(loc) }, }
View Source
var TlsExports = map[string]interface{}{ "GenerateRSAKeyPair": tlsutils.RSAGenerateKeyPair, "GenerateRSA1024KeyPair": rsaWithBitSize(1024), "GenerateRSA2048KeyPair": rsaWithBitSize(2048), "GenerateRSA4096KeyPair": rsaWithBitSize(4096), "GenerateSM2KeyPair": tlsutils.SM2GenerateKeyPair, "GenerateRootCA": func(commonName string) (ca []byte, key []byte, _ error) { return tlsutils.GenerateSelfSignedCertKeyWithCommonName(commonName, "", nil, nil) }, "SignX509ServerCertAndKey": tlsutils.SignServerCrtNKey, "SignX509ClientCertAndKey": tlsutils.SignClientCrtNKey, "SignServerCertAndKey": func(ca []byte, key []byte) (cert []byte, sKey []byte, _ error) { return tlsutils.SignServerCrtNKeyWithParams(ca, key, "Server", time.Now().Add(time.Hour*24*365*99), false) }, "SignClientCertAndKey": func(ca []byte, key []byte) (cert []byte, sKey []byte, _ error) { return tlsutils.SignClientCrtNKeyWithParams(ca, key, "Server", time.Now().Add(time.Hour*24*365*99), false) }, "Inspect": tlsutils.TLSInspect, "EncryptWithPkcs1v15": tlsutils.PemPkcs1v15Encrypt, "DecryptWithPkcs1v15": tlsutils.PemPkcs1v15Decrypt, }
View Source
var UDPExport = map[string]interface{}{ "MockUDPProtocol": DebugMockUDPProtocol, "Connect": connectUdp, "clientTimeout": clientTimeout, "clientLocalAddr": clientLocalAddr, "Serve": udpServe, "serverTimeout": func(f float64) udpServerOpt { return func(config *udpServerConfig) { config.timeout = utils.FloatSecondDuration(f) } }, "serverContext": func(ctx context.Context) udpServerOpt { return func(config *udpServerConfig) { config.ctx = ctx } }, "serverCallback": func(cb func(*udpConn, []byte, net.Addr)) udpServerOpt { return func(config *udpServerConfig) { config.callback = cb } }, }
View Source
var WaitConnect = utils.WaitConnect
View Source
var XMLExports = map[string]interface{}{ "Escape": Escape, "dumps": _xmldumps, "loads": _xmlloads, }
View Source
var YakitExports = map[string]interface{}{ "NewClient": NewYakitClient, "NewTable": NewTable, "NewLineGraph": NewLineGraph, "NewBarGraph": NewBarGraph, "NewPieGraph": NewPieGraph, "NewWordCloud": NewWordCloud, "NewHTTPFlowRisk": NewHTTPFlowRisk, "InitYakit": InitYakit, "UpdateOnlineYakitStore": updateOnlineYakitStore, "UpdateYakitStore": updateYakitStore, "UpdateYakitStoreLocal": yakit.LoadYakitFromLocalDir, "UpdateYakitStoreFromGit": yakit.LoadYakitThirdpartySourceScripts, "GenerateYakitMITMHooksParams": generateYakitMITMHookParams, "GetHomeDir": consts.GetDefaultYakitBaseDir, "GetHomeTempDir": consts.GetDefaultYakitBaseTempDir, "GetOnlineBaseUrl": consts.GetOnlineBaseUrl, "SetOnlineBaseUrl": consts.SetOnlineBaseUrl, "Info": yakitInfo(emptyVirtualClient), "Warn": yakitWarn(emptyVirtualClient), "Error": yakitError(emptyVirtualClient), "Text": yakitError(emptyVirtualClient), "Markdown": yakitMarkdown(emptyVirtualClient), "Report": yakitReport(emptyVirtualClient), "File": yakitFile(emptyVirtualClient), "Output": yakitOutput(emptyVirtualClient), "SetProgress": yakitSetProgress(emptyVirtualClient), "SetProgressEx": yakitSetProgressEx(emptyVirtualClient), }
View Source
var YamlExports = map[string]interface{}{ "Marshal": yaml.Marshal, "Unmarshal": func(b []byte) (interface{}, error) { var i interface{} err := yaml.Unmarshal(b, &i) if err != nil { return nil, err } return i, nil }, "UnmarshalStrict": func(b []byte) (interface{}, error) { var i interface{} err := yaml.UnmarshalStrict(b, &i) if err != nil { return nil, err } return i, nil }, }
View Source
var ZipExports = map[string]interface{}{ "Decompress": ziputil.DeCompress, "Compress": func(zipName string, filenames ...string) error { return ziputil.CompressByName(filenames, zipName) }, }
Functions ¶
func BuildTlsConfig ¶
func CreateYakLogger ¶
func CreateYakLogger(yakFile string) *yakLogger
func CsrfOptWithHTTPS ¶ added in v1.2.4
func CsrfOptWithHTTPS(b bool) csrfConfig
func CsrfOptWithMultipartDefaultValue ¶ added in v1.2.4
func CsrfOptWithMultipartDefaultValue(b bool) csrfConfig
func DebugMockUDP ¶ added in v1.2.3
func DebugMockUDPFromScan ¶ added in v1.2.3
func DebugMockUDPProtocol ¶ added in v1.2.3
func DebugMockUDPWithTimeout ¶ added in v1.2.3
func DownloadMMDB ¶
func DownloadMMDB() error
func DownloadOnlineAuthProxy ¶
func GenerateCSRFPoc ¶
func GetExtYakitLibByClient ¶
func GetExtYakitLibByClient(client *YakitClient) map[string]interface{}
func InitYakit ¶ added in v1.2.2
func InitYakit(y *YakitClient)
func JsonRawByteToMap ¶
func JsonRawByteToMap(jbyte json.RawMessage) (map[string]interface{}, error)
func JsonStrToVarList ¶
func JsonStreamToMapList ¶
func JsonToMapList ¶
func JsonbToVarList ¶
func MarshalYakitOutput ¶
func NewDefaultPoCConfig ¶ added in v1.2.2
func NewDefaultPoCConfig() *_pocConfig
func NewPortFromMatchResult ¶
func NewPortFromMatchResult(f *fp.MatchResult) *yakit.Port
func NewPortFromSpaceEngineResult ¶
func NewPortFromSpaceEngineResult(f *spacengine.NetSpaceEngineResult) *yakit.Port
func NewPortFromSynScanResult ¶
func NewPortFromSynScanResult(f *synscan.SynScanResult) *yakit.Port
func NewSizedWaitGroup ¶ added in v1.2.3
func NewSizedWaitGroup(size int) *utils.SizedWaitGroup
func NewYakitLogExecResult ¶
func NewYakitLogExecResult(level string, data string, items ...interface{}) *ypb.ExecResult
func NewYakitProgressExecResult ¶
func NewYakitProgressExecResult(id string, progress float64) *ypb.ExecResult
func NewYakitStatusCardExecResult ¶
func NewYakitStatusCardExecResult(status, data string, items ...string) *ypb.ExecResult
func RawHandlerToExecOutput ¶ added in v1.2.2
func RawHandlerToExecOutput(h func(any) error) func(result *ypb.ExecResult) error
func RegexpMatchEmail ¶
func RegexpMatchEmail(i interface{}) []string
func RegexpMatchIP ¶
func RegexpMatchIP(i interface{}) []string
func RegexpMatchIPv4 ¶
func RegexpMatchIPv4(i interface{}) []string
func RegexpMatchIPv6 ¶
func RegexpMatchIPv6(i interface{}) []string
func RegexpMatchMac ¶
func RegexpMatchMac(i interface{}) []string
func SetEngineClient ¶ added in v1.2.2
func SetEngineClient(e *antlr4yak.Engine, client *YakitClient)
func SetYakitServer_LogHandler ¶
func SetYakitServer_LogHandler(h func(level string, info string)) func(s *YakitServer)
func SetYakitServer_ProgressHandler ¶
func SetYakitServer_ProgressHandler(h func(id string, progress float64)) func(s *YakitServer)
func YakitInfo ¶
func YakitInfo(c *YakitClient) func(tmp string, items ...interface{})
func YakitMessageGenerator ¶
Types ¶
type GrokResult ¶
func Grok ¶
func Grok(line string, rule string) GrokResult
func GrokWithMultiPattern ¶
func GrokWithMultiPattern(line string, rule string, p map[string]string) GrokResult
func (GrokResult) Get ¶
func (g GrokResult) Get(key string) string
func (GrokResult) GetAll ¶
func (g GrokResult) GetAll(key string) []string
type HttpFlowShare ¶ added in v1.2.2
type HttpFlowShare struct {}
type HttpFlowShareRequest ¶ added in v1.2.2
type HttpFlowShareRequest struct {}
type OnlineClient ¶
type OnlineClient struct { // https://192.168.1.1:8080 BaseUrl string // contains filtered or unexported fields }
func NewOnlineClient ¶
func NewOnlineClient(baseUrl string) *OnlineClient
func (*OnlineClient) DownloadYakitPluginAll ¶
func (s *OnlineClient) DownloadYakitPluginAll( ctx context.Context, ) *OnlineDownloadStream
func (*OnlineClient) DownloadYakitPluginAllWithToken ¶
func (*OnlineClient) DownloadYakitPluginById ¶
func (s *OnlineClient) DownloadYakitPluginById(id string, token string) (*OnlinePlugin, error)
func (*OnlineClient) DownloadYakitPluginByIdWithToken ¶
func (s *OnlineClient) DownloadYakitPluginByIdWithToken(id string, token string) (*OnlinePlugin, error)
func (*OnlineClient) DownloadYakitPluginIDWithToken ¶
func (s *OnlineClient) DownloadYakitPluginIDWithToken( ctx context.Context, token string, ids ...string) *OnlineDownloadStream
func (*OnlineClient) DownloadYakitPluginWithTokenBindMe ¶
func (*OnlineClient) DownloadYakitPluginsEx ¶
func (s *OnlineClient) DownloadYakitPluginsEx( ctx context.Context, all bool, ids []string, userToken string, bindMe bool, keywords string, pluginType string, status string, isPrivate string, tags string, userId int64, userName string, scriptName []string, timeSearch string, group string, ) *OnlineDownloadStream
func (*OnlineClient) DownloadYakitScriptName ¶
func (s *OnlineClient) DownloadYakitScriptName( ctx context.Context, token string, scriptName ...string) *OnlineDownloadStream
func (*OnlineClient) HttpFlowShare ¶ added in v1.2.2
func (*OnlineClient) HttpFlowShareWithToken ¶ added in v1.2.2
func (*OnlineClient) Save ¶
func (s *OnlineClient) Save(db *gorm.DB, plugins ...*OnlinePlugin) error
func (*OnlineClient) UploadRiskToOnline ¶
func (s *OnlineClient) UploadRiskToOnline(ctx context.Context, token string, hash string, ip string, ipInteger int64, Url string, port int, host string, title string, titleVerbose string, riskType string, riskTypeVerbose string, parameter string, payload string, details string, fromYakScript string, waitingVerified bool, reverseToken string, severity string, request string, response string, runtimeId string, cve string, description string, solution string, riskCreatedAt int64) error
func (*OnlineClient) UploadRiskToOnlineWithToken ¶
func (*OnlineClient) UploadScreenRecordersToOnline ¶ added in v1.2.2
func (*OnlineClient) UploadScreenRecordersWithToken ¶ added in v1.2.2
func (s *OnlineClient) UploadScreenRecordersWithToken(ctx context.Context, token string, file os.File, screenRecorders *yakit.ScreenRecorder) error
type OnlineDownloadStream ¶
type OnlineDownloadStream struct { Total int64 Page int64 PageTotal int64 Limit int64 Chan chan *OnlinePluginItem }
type OnlinePaging ¶
type OnlinePlugin ¶
type OnlinePlugin struct { Id int64 `json:"id"` UpdatedAt int64 `json:"updated_at"` Type string `json:"type"` ScriptName string `json:"script_name"` Content string `json:"content"` PublishedAt int64 `json:"published_at"` Tags string `json:"tags"` DefaultOpen bool `json:"default_open"` DownloadedTotal int64 `json:"downloaded_total"` Stars int64 `json:"stars"` Status int64 `json:"status"` Official bool `json:"official"` IsPrivate bool `json:"is_private"` Params []*OnlinePluginParam `json:"params"` UserId int64 `json:"user_id"` Author string `json:"authors"` Help string `json:"help"` EnablePluginSelector bool `json:"enable_plugin_selector"` PluginSelectorTypes string `json:"plugin_selector_types"` IsGeneralModule bool `json:"is_general_module"` OnlineContributors string `json:"online_contributors"` UUID string `json:"uuid"` HeadImg string `json:"head_img"` BasePluginId int64 `json:"base_plugin_id"` Group string `json:"group"` }
type OnlinePluginItem ¶
type OnlinePluginItem struct { Plugin *OnlinePlugin Total int64 }
type OnlinePluginParam ¶
type OnlinePluginParam struct { Field string `json:"field"` DefaultValue string `json:"default_value"` TypeVerbose string `json:"type_verbose"` FieldVerbose string `json:"field_verbose"` Help string `json:"help"` Required bool `json:"required"` Group string `json:"group"` ExtraSetting string `json:"extra_setting"` }
type ProtobufRecord ¶
type ProtobufRecord struct { Index protowire.Number `json:"index" yaml:"index"` Type string `json:"type" yaml:"type"` Value interface{} `json:"value,omitempty" yaml:"value,omitempty,flow"` }
protobuf
func (*ProtobufRecord) String ¶
func (r *ProtobufRecord) String() string
func (*ProtobufRecord) ToBytes ¶
func (r *ProtobufRecord) ToBytes() []byte
type ProtobufRecords ¶
type ProtobufRecords struct { Records []*ProtobufRecord // contains filtered or unexported fields }
func (*ProtobufRecords) Error ¶
func (r *ProtobufRecords) Error() error
func (*ProtobufRecords) FuzzEveryIndex ¶
func (r *ProtobufRecords) FuzzEveryIndex(callback func(index int, typ string, data interface{}) interface{}) ([][]byte, error)
func (*ProtobufRecords) MarshalJSON ¶
func (r *ProtobufRecords) MarshalJSON() ([]byte, error)
marshal / unmarshal
func (*ProtobufRecords) MarshalYAML ¶
func (r *ProtobufRecords) MarshalYAML() (interface{}, error)
func (*ProtobufRecords) ToBytes ¶
func (r *ProtobufRecords) ToBytes() []byte
func (*ProtobufRecords) ToHex ¶
func (r *ProtobufRecords) ToHex() string
func (*ProtobufRecords) ToJSON ¶
func (r *ProtobufRecords) ToJSON() string
func (*ProtobufRecords) ToYAML ¶
func (r *ProtobufRecords) ToYAML() string
func (*ProtobufRecords) UnmarshalJSON ¶
func (r *ProtobufRecords) UnmarshalJSON(data []byte) error
func (*ProtobufRecords) UnmarshalYAML ¶
func (r *ProtobufRecords) UnmarshalYAML(node *yaml.Node) error
type QueryOnlinePluginRequest ¶
type QueryOnlinePluginRequest struct { Type string `json:"type"` UUID []string `json:"uuid"` Token string `json:"token"` Page int `json:"page"` Limit int `json:"limit"` BindMe bool `json:"bind_me"` Keywords string `json:"keywords"` PluginType string `json:"plugin_type"` Status string `json:"status"` User bool `json:"user"` IsPrivate string `json:"is_private"` Tags string `json:"tags"` UserId int64 `json:"user_id"` UserName string `json:"user_name"` ScriptName []string `json:"script_name"` TimeSearch string `json:"time_search"` Group string `json:"group"` }
type QueryUploadRiskOnlineRequest ¶
type QueryUploadRiskOnlineRequest struct { Token string `json:"token"` RiskHash string `json:"risk_hash"` IP string `json:"ip"` IPInteger int64 `json:"ip_integer"` Url string `json:"url"` Port int `json:"port"` Host string `json:"host"` Title string `json:"title"` TitleVerbose string `json:"title_verbose"` RiskType string `json:"risk_type"` RiskTypeVerbose string `json:"risk_type_verbose"` Parameter string `json:"parameter"` Payload string `json:"payload"` Details string `json:"details"` FromYakScript string `json:"from_yak_script"` WaitingVerified bool `json:"waiting_verified"` ReverseToken string `json:"reverse_token"` Severity string `json:"severity"` Request string `json:"request"` Response string `json:"response"` RuntimeId string `json:"runtime_id"` CVE string `json:"cve"` Description string `json:"description"` Solution string `json:"solution"` RiskCreatedAt int64 `json:"risk_created_at"` }
type RegisterOutputFuncType ¶
type RegisterOutputFuncType func(tag string, cb _outputCallback)
type ScreenRecordersUploadToOnlineRequest ¶ added in v1.2.2
type ScreenRecordersUploadToOnlineRequest struct { //Filename string `json:"filename"` NoteInfo string `json:"note_info"` Project string `json:"project"` Hash string `json:"hash"` VideoName string `json:"video_name"` Cover string `json:"cover"` Token string `json:"token"` VideoFile os.File `json:"video_file"` ScreenRecordersCreatedAt int64 `json:"screen_recorders_created_at"` }
type StringMap ¶ added in v1.2.4
type StringMap map[string]interface{}
func (StringMap) MarshalXML ¶ added in v1.2.4
func (*StringMap) UnmarshalXML ¶ added in v1.2.4
type TagAndTypeValue ¶
type TagStat ¶
type TagStat struct {
// contains filtered or unexported fields
}
func NewTagStat ¶
func (*TagStat) ForceUpdate ¶
type UnregisterOutputFuncType ¶
type UnregisterOutputFuncType func(tag string)
type WaitGroupProxy ¶ added in v1.2.3
func NewWaitGroup ¶ added in v1.2.3
func NewWaitGroup() *WaitGroupProxy
func (*WaitGroupProxy) Add ¶ added in v1.2.3
func (w *WaitGroupProxy) Add(delta ...int)
type YakitClient ¶
type YakitClient struct {
// contains filtered or unexported fields
}
func AutoInitYakit ¶
func AutoInitYakit() *YakitClient
func GetYakitClientInstance ¶
func GetYakitClientInstance() *YakitClient
func NewVirtualYakitClient ¶
func NewVirtualYakitClient(h YakitMessageHandleFunc) *YakitClient
func NewVirtualYakitClientWithExecResult ¶ added in v1.2.2
func NewVirtualYakitClientWithExecResult(h func(result *ypb.ExecResult) error) *YakitClient
func NewYakitClient ¶
func NewYakitClient(addr string) *YakitClient
func (*YakitClient) Error ¶
func (c *YakitClient) Error(tmp string, items ...interface{}) error
func (*YakitClient) Info ¶
func (c *YakitClient) Info(info string, items ...interface{}) error
func (*YakitClient) Output ¶
func (c *YakitClient) Output(t interface{}) error
func (*YakitClient) OutputLog ¶
func (c *YakitClient) OutputLog(level string, info string, items ...interface{}) error
输入
func (*YakitClient) Save ¶
func (c *YakitClient) Save(t interface{}) error
func (*YakitClient) SendRaw ¶
func (c *YakitClient) SendRaw(y *YakitLog) error
func (*YakitClient) SetProgress ¶
func (c *YakitClient) SetProgress(id string, progress float64) error
func (*YakitClient) Warn ¶
func (c *YakitClient) Warn(info string, items ...interface{}) error
type YakitFeature ¶
type YakitFixedTableData ¶
type YakitGraph ¶
type YakitGraph struct { // line / bar / pie Type string `json:"type"` Data []*yakitGraphValue `json:"data"` }
设置基本图形
func NewBarGraph ¶
func NewBarGraph() *YakitGraph
func NewLineGraph ¶
func NewLineGraph() *YakitGraph
func NewPieGraph ¶
func NewPieGraph() *YakitGraph
func NewWordCloud ¶
func NewWordCloud() *YakitGraph
func (*YakitGraph) Add ¶
func (y *YakitGraph) Add(k string, v interface{}, id ...string)
type YakitHTTPFlowRisk ¶
type YakitHTTPFlowRisk struct { RiskName string `json:"risk_name"` Url string `json:"url"` IsHTTPS bool `json:"is_https"` Highlight string `json:"highlight"` Request []byte `json:"request"` Response []byte `json:"response"` Fragment []string `json:"fragment"` // low / middle / high / critical Level string `json:"level"` }
mitm risk
func NewHTTPFlowRisk ¶
func (*YakitHTTPFlowRisk) SetFragment ¶
func (y *YakitHTTPFlowRisk) SetFragment(item ...string)
func (*YakitHTTPFlowRisk) SetLevel ¶
func (y *YakitHTTPFlowRisk) SetLevel(l string)
type YakitMessage ¶
type YakitMessage struct { Type string `json:"type"` Content json.RawMessage `json:"content"` }
type YakitMessageHandleFunc ¶
type YakitMessageHandleFunc func(i interface{}) error
type YakitProgress ¶
type YakitServer ¶
type YakitServer struct {
// contains filtered or unexported fields
}
func NewYakitServer ¶
func NewYakitServer(port int, opts ...func(server *YakitServer)) *YakitServer
func (*YakitServer) Addr ¶
func (s *YakitServer) Addr() string
func (*YakitServer) Shutdown ¶
func (s *YakitServer) Shutdown()
func (*YakitServer) Start ¶
func (s *YakitServer) Start()
type YakitStatusCard ¶
type YakitTable ¶
yaktable
func NewTable ¶
func NewTable(head ...string) *YakitTable
func (*YakitTable) Append ¶
func (y *YakitTable) Append(data ...interface{})
func (*YakitTable) SetHead ¶
func (y *YakitTable) SetHead(head ...string)
Source Files
¶
- base_funcs.go
- bot.go
- bufio.go
- cli.go
- codec.go
- context.go
- crawler.go
- csrf.go
- db.go
- dictutil.go
- dns.go
- env.go
- exec.go
- file.go
- funk.go
- fuzz.go
- geojson.go
- global.go
- grok.go
- gzip.go
- hook.go
- http.go
- http_pool.go
- http_server.go
- httpex.go
- httpflow_share.go
- icmp.go
- ioutil.go
- jpath.go
- js.go
- json.go
- ldap.go
- log.go
- math.go
- mitm.go
- mmdb.go
- ping.go
- poc.go
- rdp.go
- redis.go
- regen.go
- regexp.go
- regexp2.go
- regexp_extract.go
- risk.go
- risk_online.go
- smb.go
- spacengine.go
- strings.go
- sync.go
- system.go
- tcp.go
- tcp_serve.go
- tcp_util.go
- time.go
- tls.go
- udp.go
- upload_screenrecorders.go
- xml.go
- yakit.go
- yakit_client.go
- yakit_db.go
- yakit_online.go
- yakit_tags.go
- yakit_viewer.go
- yaml.go
- zip.go
Click to show internal directories.
Click to hide internal directories.