MCPcopy Create free account

hub / github.com/bytewatch/dolphinbeat / types & classes

Types & classes94 in github.com/bytewatch/dolphinbeat

↓ 1 callersTypeAliasIndexType
schema/definition.go:55
↓ 1 callersTypeAliasInnerType
sink/kafka/protocol/protocol.pb.go:69
↓ 1 callersTypeAliasPrimitiveConfig
sink/config.go:21
StructApplication
cmd/dolphinbeat/app.go:34
StructCanal
Canal can sync your MySQL data into everywhere, like Elasticsearch, Redis, etc... MySQL must open row format for binlog
canal/canal.go:45
StructCheckpoint
ckp/checkpoint.go:67
StructCheckpointConfig
cmd/dolphinbeat/config.go:26
InterfaceCheckpointer
ckp/checkpoint.go:78
StructCkpManager
ckp/manager.go:33
InterfaceCkpStorage
ckp/storage.go:23
StructColumn
sink/stdout/operation.go:45
StructColumn
sink/kafka/protocol/protocol.pb.go:340
StructColumnDef
sink/kafka/protocol/protocol.pb.go:434
StructColumnDef
schema/definition.go:71
TypeAliasCompression
sink/kafka/protocol/protocol.pb.go:181
StructConfig
sink/stdout/config.go:17
StructConfig
sink/kafka/config.go:23
StructConfig
sink/kafka/client/go/config.go:17
StructConfig
canal/config.go:79
StructConfig
cmd/dolphinbeat/config.go:73
StructConfig
ckp/config.go:17
StructData
ckp/manager.go:27
StructDummyEventHandler
canal/handler.go:48
StructDumpConfig
canal/config.go:33
StructDumper
Unlick mysqldump, Dumper is designed for parsing and syning data easily.
dump/dump.go:35
StructElectionConfig
cmd/dolphinbeat/config.go:65
InterfaceEventHandler
canal/handler.go:27
StructEventHandlerConfig
canal/handler_mux.go:25
StructEventHandlerWrapper
canal/handler_mux.go:36
FuncTypeFactory
func(name string, primCfg PrimitiveConfig, logger Logger) (Sink, error)
sink/sink.go:42
StructFailedDDLRes
cmd/dolphinbeat/http_handler.go:33
StructFileStorage
ckp/storage_file.go:26
StructGtidEvent
canal/gtid.go:21
StructHandlerMux
canal/handler_mux.go:105
StructHttpServer
cmd/dolphinbeat/http.go:24
StructHttpServerConfig
cmd/dolphinbeat/config.go:61
StructInputArg
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
InterfaceIterator
schema/storage.go:38
StructKafkaSink
sink/kafka/kafka.go:46
StructLogConfig
cmd/dolphinbeat/config.go:21
InterfaceLogger
sink/logger.go:17
InterfaceLogger
Logger is an interface that can be implemented to provide custom log output.
sink/kafka/client/go/logger.go:22
StructMessage
sink/kafka/protocol/protocol.pb.go:209
StructMockCheckpointer
ckp/checkpoint.go:134
StructMockStorage
ckp/storage_mock.go:21
StructObserver
canal/hook.go:17
StructOperation
sink/stdout/operation.go:75
StructOperation
sink/kafka/operation.go:28
StructOperation
sink/kafka/protocol/protocol.pb.go:702
StructOperationDecoder
sink/kafka/client/go/decoder.go:56
StructOperationHeader
sink/stdout/operation.go:68
StructOperationHeader
sink/kafka/protocol/protocol.pb.go:639
TypeAliasOperationType
sink/stdout/operation.go:26
TypeAliasOperationType
please upgrade the proto package
sink/kafka/protocol/protocol.pb.go:23
StructOutputResult
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
InterfaceParseHandler
dump/parser.go:38
StructPayload
sink/kafka/protocol/protocol.pb.go:301
StructPosition
canal/prog/position.go:26
StructProgress
sink/stdout/operation.go:60
StructProgress
sink/kafka/protocol/protocol.pb.go:568
StructProgress
canal/prog/progress.go:21
StructProgress
ckp/checkpoint.go:24
StructRow
sink/stdout/operation.go:40
StructRow
sink/kafka/protocol/protocol.pb.go:387
StructRowsEvent
RowsEvent is the event for row replication.
canal/rows.go:35
InterfaceSchemaStorage
schema/storage.go:21
StructSchemaTracker
schema/tracker.go:26
InterfaceSink
sink/sink.go:25
StructSinkConfig
cmd/dolphinbeat/config.go:51
StructSinkLogger
cmd/dolphinbeat/sink_logger.go:23
StructStatusRes
cmd/dolphinbeat/http_handler.go:26
StructStdoutSink
sink/stdout/stdout.go:30
StructTable
sink/stdout/operation.go:54
StructTableDef
sink/kafka/protocol/protocol.pb.go:513
StructTableDef
schema/definition.go:64
StructTrackerConfig
canal/config.go:61
StructTrackerConfig
cmd/dolphinbeat/config.go:37
StructTrackerConfig
schema/config.go:22
StructZookeeperStorage
ckp/storage_zookeeper.go:25
StructboltdbStorage
schema/storage_boltdb.go:37
StructboltdbStorageIterator
schema/storage_boltdb.go:275
StructcanalTestSuite
canal/canal_test.go:44
StructdefaultLogger
sink/kafka/client/go/logger.go:29
StructdumpParseHandler
canal/dump.go:30
StructgroupInfo
sink/kafka/client/go/decoder.go:47
StructmasterInfo
canal/master.go:29
StructmsgMetadata
sink/kafka/kafka.go:41
StructmysqlStorage
schema/storage_mysql.go:39
StructmysqlStorageIterator
schema/storage_mysql.go:183
StructparserTestSuite
dump/dump_test.go:171
StructschemaTestSuite
dump/dump_test.go:47
StructtestEventHandler
canal/canal_test.go:108
StructtestParseHandler
dump/dump_test.go:136
Structvalue
The value of blotdb
schema/storage_boltdb.go:28