Versions in this module Expand all Collapse all v0 v0.2.0 Apr 23, 2023 v0.1.0 Mar 5, 2023 v0.1.0-bugfix Mar 5, 2023 v0.0.6 Mar 5, 2023 v0.0.5 Mar 4, 2023 v0.0.4 Mar 4, 2023 v0.0.3 Mar 4, 2023 v0.0.2 Mar 4, 2023 Changes in this version type ExporterTable + TableNameEventOrphan string v0.0.1 Feb 11, 2023 Changes in this version + type ExporterInfo struct + CurrentProgress ExporterProgress + JoinTimestamp common.Timestamp + QuitTimestamp common.Timestamp + ResolverTag string + StatusCode ExporterStatusCode + Table ExporterTable + type ExporterProgress struct + CurrentDay string + CurrentFileID int64 + CurrentN int64 + type ExporterStatusCode int + const StatusActive + const StatusDead + const StatusLazyQuit + const StatusUnknown + type ExporterTable struct + TableNameRevision string + TableNameSnapshotData string + TableNameSnapshotSync string + TableNameState string + type MetaClearAllExporterInfoArgs struct + type MetaClearAllExporterInfoReply struct + Number int + OK bool + type MetaDeleteExporterInfoArgs struct + Key string + type MetaDeleteExporterInfoReply struct + HasJoin bool + Info ExporterInfo + OK bool + type MetaExporterHasJoinArgs struct + Key string + type MetaExporterHasJoinReply struct + HasJoin bool + OK bool + type MetaGetAllExporterInfoArgs struct + type MetaGetAllExporterInfoReply struct + ExporterInfo map[string]ExporterInfo + OK bool + type MetaGetExporterInfoArgs struct + Key string + type MetaGetExporterInfoReply struct + HasJoin bool + Info ExporterInfo + OK bool + type MetaGetExporterProgressArgs struct + Key string + type MetaGetExporterProgressReply struct + CurrentProgress ExporterProgress + HasJoin bool + OK bool + type MetaGetExporterResolverArgs struct + Key string + type MetaGetExporterResolverReply struct + HasJoin bool + OK bool + ResolverTag string + type MetaGetExporterStatusArgs struct + Key string + type MetaGetExporterStatusReply struct + HasJoin bool + JoinTimestamp common.Timestamp + OK bool + QuitTimestamp common.Timestamp + StatusCode ExporterStatusCode + type MetaGetExporterTableArgs struct + Key string + type MetaGetExporterTableReply struct + HasJoin bool + OK bool + Table ExporterTable + type MetaNewExporterInfoArgs struct + Info ExporterInfo + Key string + type MetaNewExporterInfoReply struct + HasJoin bool + OK bool + type MetaUpdateExporterProgressArgs struct + CurrentProgress ExporterProgress + Key string + type MetaUpdateExporterProgressReply struct + HasJoin bool + OK bool + type MetaUpdateExporterStatusArgs struct + Key string + QuitTimestamp common.Timestamp + StatusCode ExporterStatusCode + type MetaUpdateExporterStatusReply struct + HasJoin bool + OK bool + type MqClearMessageArgs struct + Tag string + type MqClearMessageReply struct + Number int + OK bool + type MqFilterMessageArgs struct + Tag string + type MqFilterMessageReply struct + HasNext bool + Message MqMessage + OK bool + type MqMessage struct + Msg []byte + Tag string + type MqPushMessageArgs struct + Message MqMessage + type MqPushMessageReply struct + OK bool + type ReceiverDataPackage struct + DataPackage [][]byte + Day string + EOF bool + LeftSeq int64 + RightSeq int64 + type ReceiverDataRequest struct + CurrentProgress ExporterProgress + DataPackage ReceiverDataPackage + ExporterTag string + type ReceiverDataResponse struct + OK bool + type ReceiverJoinRequest struct + ExporterTag string + type ReceiverJoinResponse struct + Info ExporterInfo + Msg string + OK bool + type ReceiverQueryRequest struct + ExporterTag string + type ReceiverQueryResponse struct + Info ExporterInfo + Msg string + OK bool + type ReceiverQuitRequest struct + ExporterTag string + LazyQuit bool + type ReceiverQuitResponse struct + Msg string + OK bool + type ResolverShutdownArgs struct + ExporterTag string + LazyShutdown bool + type ResolverShutdownReply struct + OK bool + type ResolverStartArgs struct + ExporterTag string + type ResolverStartReply struct + OK bool + ResolverTag string