Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/uber/aresdb
/ GetSinkMode
Method
GetSinkMode
subscriber/config/service_config.go:260–265 ·
view source on GitHub ↗
()
Source
from the content-addressed store, hash-verified
258
}
259
260
func
(s SinkConfig) GetSinkMode() SinkMode {
261
if
val, ok := sinkModeStr[s.SinkModeStr]; ok {
262
return
val
263
}
264
return
Sink_Undefined
265
}
Callers
4
NewAresDatabase
Function · 0.80
NewKafkaPublisher
Function · 0.80
SyncUpJobConfigs
Method · 0.80
service_config_test.go
File · 0.80
Calls
no outgoing calls
Tested by
no test coverage detected