Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/bytewatch/dolphinbeat
/ types & classes
Types & classes
94 in github.com/bytewatch/dolphinbeat
⨍
Functions
510
◇
Types & classes
94
↓ 1 callers
TypeAlias
IndexType
schema/definition.go:55
↓ 1 callers
TypeAlias
InnerType
sink/kafka/protocol/protocol.pb.go:69
↓ 1 callers
TypeAlias
PrimitiveConfig
sink/config.go:21
Struct
Application
cmd/dolphinbeat/app.go:34
Struct
Canal
Canal can sync your MySQL data into everywhere, like Elasticsearch, Redis, etc... MySQL must open row format for binlog
canal/canal.go:45
Struct
Checkpoint
ckp/checkpoint.go:67
Struct
CheckpointConfig
cmd/dolphinbeat/config.go:26
Interface
Checkpointer
ckp/checkpoint.go:78
Struct
CkpManager
ckp/manager.go:33
Interface
CkpStorage
ckp/storage.go:23
Struct
Column
sink/stdout/operation.go:45
Struct
Column
sink/kafka/protocol/protocol.pb.go:340
Struct
ColumnDef
sink/kafka/protocol/protocol.pb.go:434
Struct
ColumnDef
schema/definition.go:71
TypeAlias
Compression
sink/kafka/protocol/protocol.pb.go:181
Struct
Config
sink/stdout/config.go:17
Struct
Config
sink/kafka/config.go:23
Struct
Config
sink/kafka/client/go/config.go:17
Struct
Config
canal/config.go:79
Struct
Config
cmd/dolphinbeat/config.go:73
Struct
Config
ckp/config.go:17
Struct
Data
ckp/manager.go:27
Struct
DummyEventHandler
canal/handler.go:48
Struct
DumpConfig
canal/config.go:33
Struct
Dumper
Unlick mysqldump, Dumper is designed for parsing and syning data easily.
dump/dump.go:35
Struct
ElectionConfig
cmd/dolphinbeat/config.go:65
Interface
EventHandler
canal/handler.go:27
Struct
EventHandlerConfig
canal/handler_mux.go:25
Struct
EventHandlerWrapper
canal/handler_mux.go:36
FuncType
Factory
func(name string, primCfg PrimitiveConfig, logger Logger) (Sink, error)
sink/sink.go:42
Struct
FailedDDLRes
cmd/dolphinbeat/http_handler.go:33
Struct
FileStorage
ckp/storage_file.go:26
Struct
GtidEvent
canal/gtid.go:21
Struct
HandlerMux
canal/handler_mux.go:105
Struct
HttpServer
cmd/dolphinbeat/http.go:24
Struct
HttpServerConfig
cmd/dolphinbeat/config.go:61
Struct
InputArg
InputArg holds kafka message data and offset.User send InputArg to the decoder, and the decoder will decode kafka message and return OutputResult to u
sink/kafka/client/go/decoder.go:29
Interface
Iterator
schema/storage.go:38
Struct
KafkaSink
sink/kafka/kafka.go:46
Struct
LogConfig
cmd/dolphinbeat/config.go:21
Interface
Logger
sink/logger.go:17
Interface
Logger
Logger is an interface that can be implemented to provide custom log output.
sink/kafka/client/go/logger.go:22
Struct
Message
sink/kafka/protocol/protocol.pb.go:209
Struct
MockCheckpointer
ckp/checkpoint.go:134
Struct
MockStorage
ckp/storage_mock.go:21
Struct
Observer
canal/hook.go:17
Struct
Operation
sink/stdout/operation.go:75
Struct
Operation
sink/kafka/operation.go:28
Struct
Operation
sink/kafka/protocol/protocol.pb.go:702
Struct
OperationDecoder
sink/kafka/client/go/decoder.go:56
Struct
OperationHeader
sink/stdout/operation.go:68
Struct
OperationHeader
sink/kafka/protocol/protocol.pb.go:639
TypeAlias
OperationType
sink/stdout/operation.go:26
TypeAlias
OperationType
please upgrade the proto package
sink/kafka/protocol/protocol.pb.go:23
Struct
OutputResult
OutputResult holds operations decoded from kafka message, seq info, offset info and commit info. Once user has handled/consumed this OutputResult, use
sink/kafka/client/go/decoder.go:37
Interface
ParseHandler
dump/parser.go:38
Struct
Payload
sink/kafka/protocol/protocol.pb.go:301
Struct
Position
canal/prog/position.go:26
Struct
Progress
sink/stdout/operation.go:60
Struct
Progress
sink/kafka/protocol/protocol.pb.go:568
Struct
Progress
canal/prog/progress.go:21
Struct
Progress
ckp/checkpoint.go:24
Struct
Row
sink/stdout/operation.go:40
Struct
Row
sink/kafka/protocol/protocol.pb.go:387
Struct
RowsEvent
RowsEvent is the event for row replication.
canal/rows.go:35
Interface
SchemaStorage
schema/storage.go:21
Struct
SchemaTracker
schema/tracker.go:26
Interface
Sink
sink/sink.go:25
Struct
SinkConfig
cmd/dolphinbeat/config.go:51
Struct
SinkLogger
cmd/dolphinbeat/sink_logger.go:23
Struct
StatusRes
cmd/dolphinbeat/http_handler.go:26
Struct
StdoutSink
sink/stdout/stdout.go:30
Struct
Table
sink/stdout/operation.go:54
Struct
TableDef
sink/kafka/protocol/protocol.pb.go:513
Struct
TableDef
schema/definition.go:64
Struct
TrackerConfig
canal/config.go:61
Struct
TrackerConfig
cmd/dolphinbeat/config.go:37
Struct
TrackerConfig
schema/config.go:22
Struct
ZookeeperStorage
ckp/storage_zookeeper.go:25
Struct
boltdbStorage
schema/storage_boltdb.go:37
Struct
boltdbStorageIterator
schema/storage_boltdb.go:275
Struct
canalTestSuite
canal/canal_test.go:44
Struct
defaultLogger
sink/kafka/client/go/logger.go:29
Struct
dumpParseHandler
canal/dump.go:30
Struct
groupInfo
sink/kafka/client/go/decoder.go:47
Struct
masterInfo
canal/master.go:29
Struct
msgMetadata
sink/kafka/kafka.go:41
Struct
mysqlStorage
schema/storage_mysql.go:39
Struct
mysqlStorageIterator
schema/storage_mysql.go:183
Struct
parserTestSuite
dump/dump_test.go:171
Struct
schemaTestSuite
dump/dump_test.go:47
Struct
testEventHandler
canal/canal_test.go:108
Struct
testParseHandler
dump/dump_test.go:136
Struct
value
The value of blotdb
schema/storage_boltdb.go:28