Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/OpenSOC/opensoc-streaming
/ functions
Functions
1,123 in github.com/OpenSOC/opensoc-streaming
⨍
Functions
1,123
◇
Types & classes
222
↓ 2 callers
Method
getGrokMap
()
OpenSOC-MessageParsers/src/main/java/com/opensoc/parsing/parsers/GrokAsaParser.java:87
↓ 2 callers
Method
getJsonIndexDoc
Gets the json doc. @return the json doc
OpenSOC-Common/src/main/java/com/opensoc/pcap/PacketInfo.java:280
↓ 2 callers
Method
getMacAddress
(Buffer data)
OpenSOC-Common/src/main/java/com/opensoc/pcap/OpenSocEthernetDecoder.java:74
↓ 2 callers
Method
getMaxLimitForAppendingTokens
Gets the max limit for appending tokens. @return the max limit for appending tokens
OpenSOC-Pcap_Service/src/main/java/com/opensoc/pcapservice/PcapGetterHBaseImpl.java:755
↓ 2 callers
Method
getMaxLimitForAppendingTokens
Gets the max limit for appending tokens. @return the max limit for appending tokens
OpenSOC-DataServices/src/main/java/com/opensoc/pcapservice/PcapGetterHBaseImpl.java:755
↓ 2 callers
Method
getMaxResultSize
Returns the configured max result size in bytes. @return long
OpenSOC-DataServices/src/main/java/com/opensoc/pcapservice/ConfigurationUtil.java:104
↓ 2 callers
Method
getPacketTimeInNanos
()
OpenSOC-Common/src/main/java/com/opensoc/pcap/PacketInfo.java:437
↓ 2 callers
Method
getPatternMap
()
OpenSOC-MessageParsers/src/main/java/com/opensoc/parsing/parsers/GrokAsaParser.java:102
↓ 2 callers
Method
getPcaps
Gets the pcaps for the input list of keys and lastRowKey. @param keys the list of keys for which pcaps are to be retrieved @param lastRowKey
OpenSOC-Pcap_Service/src/main/java/com/opensoc/pcapservice/IPcapGetter.java:41
↓ 2 callers
Method
getPcaps
Gets the pcaps for the input list of keys and lastRowKey. @param keys the list of keys for which pcaps are to be retrieved @param lastRowKey
OpenSOC-DataServices/src/main/java/com/opensoc/pcapservice/IPcapGetter.java:41
↓ 2 callers
Method
getPort
()
OpenSOC-Common/src/main/java/com/opensoc/helpers/services/PcapServiceCli.java:19
↓ 2 callers
Method
getRowSizeUnit
Gets the row size unit. @return the row size unit
OpenSOC-DataServices/src/main/java/com/opensoc/pcapservice/ConfigurationUtil.java:136
↓ 2 callers
Method
getSettings
Returns the settings. @return the settings.
OpenSOC-Common/src/main/java/com/opensoc/test/AbstractConfigTest.java:270
↓ 2 callers
Method
getSubject
Retrurn the single line of log. @return the single line of log
OpenSOC-MessageParsers/src/main/java/com/opensoc/parsing/parsers/OpenSOCMatch.java:111
↓ 2 callers
Method
getTokens
Returns the first 'noOfTokens' tokens from the given key; token delimiter "-";. @param key given key @param noOfTokens number of to
OpenSOC-Pcap_Service/src/main/java/com/opensoc/pcapservice/PcapGetterHBaseImpl.java:269
↓ 2 callers
Method
getTokens
Returns the first 'noOfTokens' tokens from the given key; token delimiter "-";. @param key given key @param noOfTokens number of to
OpenSOC-DataServices/src/main/java/com/opensoc/pcapservice/PcapGetterHBaseImpl.java:269
↓ 2 callers
Method
init
()
OpenSOC-Common/src/main/java/com/opensoc/tldextractor/BasicTldExtractor.java:33
↓ 2 callers
Method
init
(String topicname)
OpenSOC-DataServices/src/main/java/com/opensoc/dataservices/common/OpenSOCService.java:9
↓ 2 callers
Method
isDefaultIncludeReverseTraffic
Checks if is default include reverse traffic. @return true, if is default include reverse traffic
OpenSOC-Pcap_Service/src/main/java/com/opensoc/pcapservice/ConfigurationUtil.java:157
↓ 2 callers
Method
isDefaultIncludeReverseTraffic
Checks if is default include reverse traffic. @return true, if is default include reverse traffic
OpenSOC-DataServices/src/main/java/com/opensoc/pcapservice/ConfigurationUtil.java:157
↓ 2 callers
Method
isGenerator_spout
()
OpenSOC-Common/src/main/java/com/opensoc/helpers/topology/Cli.java:23
↓ 2 callers
Method
jjFillToken
()
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParserTokenManager.java:548
↓ 2 callers
Method
jj_3R_4
()
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParser.java:261
↓ 2 callers
Method
jj_3R_5
()
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParser.java:250
↓ 2 callers
Method
jj_3R_6
()
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParser.java:304
↓ 2 callers
Method
jj_3R_7
()
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParser.java:319
↓ 2 callers
Method
jj_3_1
()
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParser.java:283
↓ 2 callers
Method
jj_3_2
()
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParser.java:273
↓ 2 callers
Method
jj_3_3
()
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParser.java:256
↓ 2 callers
Method
jj_3_4
()
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParser.java:245
↓ 2 callers
Method
jj_3_5
()
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParser.java:240
↓ 2 callers
Method
jj_add_error_token
(int kind, int pos)
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParser.java:537
↓ 2 callers
Method
makeKey
(String ip1, String ip2, int alert_type)
OpenSOC-Alerts/src/main/java/com/opensoc/alerts/adapters/AbstractAlertAdapter.java:59
↓ 2 callers
Method
makeKey
(String ip1, String ip2, int alert_type)
OpenSOC-Alerts/src/main/java/com/opensoc/alerts/adapters/ThreatAlertsAdapter.java:308
↓ 2 callers
Method
makeKey
(String ip1, String ip2, int alert_type)
OpenSOC-Alerts/src/main/java/com/opensoc/alerts/adapters/HbaseWhiteAndBlacklistAdapter.java:210
↓ 2 callers
Method
makeKey
(String ip1, String ip2, int alert_type)
OpenSOC-Alerts/src/main/java/com/opensoc/alerts/adapters/CIFAlertsAdapter.java:308
↓ 2 callers
Method
makeKey
(String ip1, String ip2, int alert_type)
OpenSOC-Alerts/src/main/java/com/opensoc/alerts/adapters/AllAlertAdapter.java:271
↓ 2 callers
Method
parse
Parses the. @param pcap the pcap @return the list @throws IOException Signals that an I/O exception has occurred. @throws IOExceptio
OpenSOC-MessageParsers/src/main/java/com/opensoc/parsing/parsers/PcapParser.java:76
↓ 2 callers
Method
parse
()
OpenSOC-Common/src/main/java/com/opensoc/helpers/services/PcapServiceCli.java:51
↓ 2 callers
Method
printOptionalSettings
(Map<String, String> settings)
OpenSOC-Common/src/main/java/com/opensoc/helpers/topology/SettingsLoader.java:122
↓ 2 callers
Method
printUsage
()
OpenSOC-DataLoads/src/main/java/com/opensoc/dataloads/cif/HBaseTableLoad.java:162
↓ 2 callers
Method
processKey
Process key. @param pcapsResponse the pcaps response @param key the key @param startTime the start time @param endTime
OpenSOC-Pcap_Service/src/main/java/com/opensoc/pcapservice/PcapGetterHBaseImpl.java:308
↓ 2 callers
Method
processKey
Process key. @param pcapsResponse the pcaps response @param key the key @param startTime the start time @param endTime
OpenSOC-DataServices/src/main/java/com/opensoc/pcapservice/PcapGetterHBaseImpl.java:308
↓ 2 callers
Method
read
This method creates Configuration with HBase resources using configuration properties. The same Configuration object will be used to communicate with
OpenSOC-Pcap_Service/src/main/java/com/opensoc/pcapservice/HBaseConfigurationUtil.java:134
↓ 2 callers
Method
register
(EthernetProcessor processor)
OpenSOC-Common/src/main/java/com/opensoc/pcap/OpenSocEthernetDecoder.java:27
↓ 2 callers
Method
removeDuplicateKeys
Removes the duplicate keys. @param keys the keys @return the list
OpenSOC-Pcap_Service/src/main/java/com/opensoc/pcapservice/PcapGetterHBaseImpl.java:215
↓ 2 callers
Method
scanPcaps
Scan pcaps. @param pcaps the pcaps @param table the table @param scan the scan @param cf the cf @param cq
OpenSOC-DataServices/src/main/java/com/opensoc/pcapservice/PcapScannerHBaseImpl.java:183
↓ 2 callers
Method
setDurability
@param setDurability Sets whether to write to HBase's edit log. <p> Setting to false will mean fewer operations to perform
OpenSOC-Common/src/main/java/com/opensoc/hbase/TupleTableConfig.java:234
↓ 2 callers
Method
setGeoMySqlAdapter
Sets the geoMySqlAdapter. @param geoMySqlAdapter the geoMySqlAdapter.
OpenSOC-EnrichmentAdapters/src/test/java/com/opensoc/enrichment/adapters/geo/GeoMysqlAdapterTest.java:160
↓ 2 callers
Method
setGrokAsaStrings
Sets GrokAsa Input String
OpenSOC-MessageParsers/src/test/java/com/opensoc/parsing/test/GrokAsaParserTest.java:125
↓ 2 callers
Method
setInputStrings
Sets SourceFire Input String
OpenSOC-MessageParsers/src/test/java/com/opensoc/parsing/test/BasicFireEyeParserTest.java:121
↓ 2 callers
Method
setPAStrings
Sets Input String
OpenSOC-MessageParsers/src/test/java/com/opensoc/parsing/test/BasicPaloAltoFirewallParserTest.java:114
↓ 2 callers
Method
setSourceFireStrings
Sets SourceFire Input String
OpenSOC-MessageParsers/src/test/java/com/opensoc/parsing/test/BasicSourcefireParserTest.java:121
↓ 2 callers
Method
shortToByteArray
Short to byte array. @param number the number @return the byte[]
OpenSOC-Common/src/main/java/com/opensoc/pcap/PcapByteOutputStream.java:241
↓ 2 callers
Method
shutdown
()
OpenSOC-DataServices/src/main/java/com/opensoc/dataservices/kafkaclient/KafkaClient.java:48
↓ 2 callers
Method
string
()
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParser.java:179
↓ 2 callers
Method
toJson
Get the json representation of the matched element. <p> example: map [ {IP: 127.0.0.1}, {status:200}] will return {"IP":"127.0.0.1", "status":200} </p
OpenSOC-MessageParsers/src/main/java/com/opensoc/parsing/parsers/OpenSOCMatch.java:202
↓ 2 callers
Method
validateMaxResultSize
Returns the configured default result size in bytes, if the user input is null; otherwise, returns the user input after validating with the configured
OpenSOC-Pcap_Service/src/main/java/com/opensoc/pcapservice/ConfigurationUtil.java:62
↓ 2 callers
Method
validateMaxResultSize
Returns the configured default result size in bytes, if the user input is null; otherwise, returns the user input after validating with the configured
OpenSOC-DataServices/src/main/java/com/opensoc/pcapservice/ConfigurationUtil.java:62
↓ 2 callers
Method
validateToken
( final Properties configProps, String authToken )
OpenSOC-DataServices/src/main/java/com/opensoc/dataservices/auth/AuthToken.java:71
↓ 2 callers
Method
write
(Kryo kryo, Output output, JSONObject json)
OpenSOC-Common/src/main/java/com/opensoc/json/serialization/JSONKryoSerializer.java:35
↓ 1 callers
Method
BeginToken
@return starting character for token.
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/JavaCharStream.java:176
↓ 1 callers
Method
Clean
@param jsonString @return @throws ParseException Takes a json String as input and removes any Special Chars (^ a-z A-Z 0-9) in the keys
OpenSOC-MessageParsers/src/main/java/com/opensoc/parsing/parsers/JSONCleaner.java:30
↓ 1 callers
Method
FillBuff
()
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/JavaCharStream.java:135
↓ 1 callers
Method
HBaseBulkPut
@param input @param hbaseTable @param col_family @throws IOException @throws ParseException Inserts all json records picked up from the inputStr
OpenSOC-DataLoads/src/main/java/com/opensoc/dataloads/cif/HBaseTableLoad.java:127
↓ 1 callers
Method
LexicalError
Returns a detailed message for the Error when it is thrown by the token manager to indicate a lexical error. Parameters : EOFSeen : indicates i
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/TokenMgrError.java:107
↓ 1 callers
Method
LoadFileList
(String filename)
OpenSOC-DataLoads/src/main/java/com/opensoc/dataloads/cif/HBaseTableLoad.java:214
↓ 1 callers
Method
LogstashToEpoch
(String timestamp)
OpenSOC-MessageParsers/src/main/java/com/opensoc/parsing/parsers/BasicLogstashParser.java:57
↓ 1 callers
Method
ReInit
Reinitialise.
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParser.java:407
↓ 1 callers
Method
addPatternFromFile
Add patterns to {@code Grok} from the given file. @param file : Path of the grok pattern @throws Exception
OpenSOC-MessageParsers/src/main/java/com/opensoc/parsing/parsers/OpenSOCGrok.java:170
↓ 1 callers
Method
addPatternFromReader
Add patterns to {@code Grok} from a Reader. @param r : Reader with {@code Grok} patterns @throws Exception
OpenSOC-MessageParsers/src/main/java/com/opensoc/parsing/parsers/OpenSOCGrok.java:206
↓ 1 callers
Method
addShutdownHook
Adds the shutdown hook.
OpenSOC-Pcap_Service/src/main/java/com/opensoc/pcapservice/HBaseConfigurationUtil.java:99
↓ 1 callers
Method
addShutdownHook
Adds the shutdown hook.
OpenSOC-DataServices/src/main/java/com/opensoc/pcapservice/HBaseConfigurationUtil.java:99
↓ 1 callers
Method
add_escapes
Used to convert raw characters to their escaped version when these raw version cannot be used as part of an ASCII string literal.
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ParseException.java:141
↓ 1 callers
Method
alert
(JSONObject raw_message)
OpenSOC-Common/src/main/java/com/opensoc/alerts/interfaces/AlertsAdapter.java:13
↓ 1 callers
Method
blankValue
()
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParser.java:173
↓ 1 callers
Method
braced_string
()
OpenSOC-Common/src/main/java/com/opensoc/ise/parser/ISEParser.java:187
↓ 1 callers
Method
bulkIndex
(JSONObject raw_message)
OpenSOC-Common/src/main/java/com/opensoc/index/interfaces/IndexAdapter.java:12
↓ 1 callers
Method
checkForSchemaCorrectness
@param parser The parser class for parsing the incoming raw message byte stream @return Instance of this class
OpenSOC-MessageParsers/src/main/java/com/opensoc/parsing/AbstractParserBolt.java:103
↓ 1 callers
Method
checkIfReachable
Check if we can reach the IP where geo data is storred @param ip - ip of geo database @param timeout - timeout for a connection
OpenSOC-EnrichmentAdapters/src/main/java/com/opensoc/enrichment/adapters/geo/AbstractGeoAdapter.java:51
↓ 1 callers
Method
checkIfValidInput
Returns false if keys is empty or null AND lastRowKey is null or empty; otherwise returns true;. @param keys input row keys @param lastRowKe
OpenSOC-DataServices/src/main/java/com/opensoc/pcapservice/PcapGetterHBaseImpl.java:523
↓ 1 callers
Method
cleanString
remove from the string the quote and double quote. @param string to pure: "my/text" @return unquoted string: my/text
OpenSOC-MessageParsers/src/main/java/com/opensoc/parsing/parsers/OpenSOCMatch.java:174
↓ 1 callers
Method
close
Method close. @throws IOException @see org.krakenapps.pcap.PcapOutputStream#close() @see org.krakenapps.pcap.PcapOutputStream#close()
OpenSOC-Common/src/main/java/com/opensoc/pcap/PcapByteOutputStream.java:284
↓ 1 callers
Method
closeInput
Close input. @param is the is
OpenSOC-Common/src/main/java/com/opensoc/pcap/PcapMerger.java:190
↓ 1 callers
Method
closeOutput
Close output. @param os the os
OpenSOC-Common/src/main/java/com/opensoc/pcap/PcapMerger.java:207
↓ 1 callers
Method
columnFamilyExists
Checks to see if table contains the given column family @param columnFamily The column family name @return boolean @throws IOException
OpenSOC-Common/src/main/java/com/opensoc/hbase/HTableConnector.java:85
↓ 1 callers
Method
compile
()
OpenSOC-Common/src/main/java/com/opensoc/tldextractor/BasicTldExtractor.java:67
↓ 1 callers
Method
configure
()
OpenSOC-DataServices/src/main/java/com/opensoc/dataservices/Main.java:118
↓ 1 callers
Method
containsAlertId
(String alert)
OpenSOC-Common/src/main/java/com/opensoc/alerts/interfaces/AlertsAdapter.java:15
↓ 1 callers
Method
convert
(String key, Object value)
OpenSOC-MessageParsers/src/main/java/com/opensoc/parsing/parsers/OpenSOCConverter.java:37
↓ 1 callers
Method
convertIpSegmentToHex
Convert ip segment to hex. @param ipSegment the ip segment @return the string
OpenSOC-Common/src/main/java/com/opensoc/pcap/PcapUtils.java:336
↓ 1 callers
Method
convertMicrosToDataCreationTimeUnit
Convert micros to data creation time unit. @param inputTime the input time @return the long
OpenSOC-Pcap_Service/src/main/java/com/opensoc/pcapservice/PcapHelper.java:192
↓ 1 callers
Method
convertMicrosToDataCreationTimeUnit
Convert micros to data creation time unit. @param inputTime the input time @return the long
OpenSOC-DataServices/src/main/java/com/opensoc/pcapservice/PcapHelper.java:192
↓ 1 callers
Method
convertMillisToDataCreationTimeUnit
Convert millis to data creation time unit. @param inputTime the input time @return the long
OpenSOC-Pcap_Service/src/main/java/com/opensoc/pcapservice/PcapHelper.java:171
↓ 1 callers
Method
convertMillisToDataCreationTimeUnit
Convert millis to data creation time unit. @param inputTime the input time @return the long
OpenSOC-DataServices/src/main/java/com/opensoc/pcapservice/PcapHelper.java:171
↓ 1 callers
Method
convertSecondsToDataCreationTimeUnit
Convert seconds to data creation time unit. @param inputTime the input time @return the long
OpenSOC-DataServices/src/main/java/com/opensoc/pcapservice/PcapHelper.java:86
↓ 1 callers
Method
convertToEpoch
(String m, String d, String ts, boolean adjust_timezone)
OpenSOC-MessageParsers/src/main/java/com/opensoc/parsing/parsers/GrokAsaParser.java:148
↓ 1 callers
Method
convertToEpoch
(String m, String d, String ts, boolean adjust_timezone)
OpenSOC-MessageParsers/src/main/java/com/opensoc/parsing/parsers/BasicFireEyeParser.java:93
↓ 1 callers
Method
convertToHex
Convert to hex. @param number the number @param length the length @return the string
OpenSOC-Common/src/main/java/com/opensoc/pcap/PcapUtils.java:362
↓ 1 callers
Method
copyGlobalHeader
Copy global header. @param header the header
OpenSOC-Common/src/main/java/com/opensoc/pcap/PcapByteOutputStream.java:117
← previous
next →
201–300 of 1,123, ranked by callers