data

var (
	// TopicMap is the map of topic name to topic.
	TopicMap = map[string]bus.Topic{
		TopicStreamWrite.String():               TopicStreamWrite,
		TopicStreamQuery.String():               TopicStreamQuery,
		TopicMeasureWrite.String():              TopicMeasureWrite,
		TopicMeasureQuery.String():              TopicMeasureQuery,
		TopicInternalMeasureQuery.String():      TopicInternalMeasureQuery,
		TopicTopNQuery.String():                 TopicTopNQuery,
		TopicPropertyDelete.String():            TopicPropertyDelete,
		TopicPropertyQuery.String():             TopicPropertyQuery,
		TopicPropertyUpdate.String():            TopicPropertyUpdate,
		TopicStreamPartSync.String():            TopicStreamPartSync,
		TopicMeasurePartSync.String():           TopicMeasurePartSync,
		TopicMeasureSeriesIndexInsert.String():  TopicMeasureSeriesIndexInsert,
		TopicMeasureSeriesIndexUpdate.String():  TopicMeasureSeriesIndexUpdate,
		TopicMeasureSeriesSync.String():         TopicMeasureSeriesSync,
		TopicPropertyRepair.String():            TopicPropertyRepair,
		TopicStreamSeriesIndexWrite.String():    TopicStreamSeriesIndexWrite,
		TopicStreamLocalIndexWrite.String():     TopicStreamLocalIndexWrite,
		TopicStreamSeriesSync.String():          TopicStreamSeriesSync,
		TopicStreamElementIndexSync.String():    TopicStreamElementIndexSync,
		TopicTraceWrite.String():                TopicTraceWrite,
		TopicTraceQuery.String():                TopicTraceQuery,
		TopicTracePartSync.String():             TopicTracePartSync,
		TopicTraceSeriesSync.String():           TopicTraceSeriesSync,
		TopicTraceSidxSeriesWrite.String():      TopicTraceSidxSeriesWrite,
		TopicMeasureCollectDataInfo.String():    TopicMeasureCollectDataInfo,
		TopicMeasureCollectLiaisonInfo.String(): TopicMeasureCollectLiaisonInfo,
		TopicStreamCollectDataInfo.String():     TopicStreamCollectDataInfo,
		TopicStreamCollectLiaisonInfo.String():  TopicStreamCollectLiaisonInfo,
		TopicTraceCollectDataInfo.String():      TopicTraceCollectDataInfo,
		TopicTraceCollectLiaisonInfo.String():   TopicTraceCollectLiaisonInfo,
		TopicMeasureDropGroup.String():          TopicMeasureDropGroup,
		TopicStreamDropGroup.String():           TopicStreamDropGroup,
		TopicTraceDropGroup.String():            TopicTraceDropGroup,
	}

	// TopicRequestMap is the map of topic name to request message.
	// nolint: exhaustruct
	TopicRequestMap = map[bus.Topic]func() proto.Message{
		TopicStreamWrite: func() proto.Message {
			return &streamv1.InternalWriteRequest{}
		},
		TopicStreamQuery: func() proto.Message {
			return &streamv1.QueryRequest{}
		},
		TopicMeasureWrite: func() proto.Message {
			return &measurev1.InternalWriteRequest{}
		},
		TopicMeasureQuery: func() proto.Message {
			return &measurev1.QueryRequest{}
		},
		TopicInternalMeasureQuery: func() proto.Message {
			return &measurev1.InternalQueryRequest{}
		},
		TopicTopNQuery: func() proto.Message {
			return &measurev1.TopNRequest{}
		},
		TopicPropertyUpdate: func() proto.Message {
			return &propertyv1.InternalUpdateRequest{}
		},
		TopicPropertyQuery: func() proto.Message {
			return &propertyv1.QueryRequest{}
		},
		TopicPropertyDelete: func() proto.Message {
			return &propertyv1.InternalDeleteRequest{}
		},
		TopicStreamPartSync: func() proto.Message {
			return nil
		},
		TopicMeasurePartSync: func() proto.Message {
			return nil
		},
		TopicMeasureSeriesIndexInsert: func() proto.Message {
			return nil
		},
		TopicMeasureSeriesIndexUpdate: func() proto.Message {
			return nil
		},
		TopicMeasureSeriesSync: func() proto.Message {
			return nil
		},
		TopicPropertyRepair: func() proto.Message {
			return &propertyv1.InternalRepairRequest{}
		},
		TopicStreamSeriesIndexWrite: func() proto.Message {
			return nil
		},
		TopicStreamLocalIndexWrite: func() proto.Message {
			return nil
		},
		TopicStreamSeriesSync: func() proto.Message {
			return nil
		},
		TopicStreamElementIndexSync: func() proto.Message {
			return nil
		},
		TopicTraceWrite: func() proto.Message {
			return &tracev1.InternalWriteRequest{}
		},
		TopicTraceQuery: func() proto.Message {
			return &tracev1.QueryRequest{}
		},
		TopicTracePartSync: func() proto.Message {
			return nil
		},
		TopicTraceSeriesSync: func() proto.Message {
			return nil
		},
		TopicTraceSidxSeriesWrite: func() proto.Message {
			return nil
		},
		TopicMeasureCollectDataInfo: func() proto.Message {
			return &databasev1.GroupRegistryServiceInspectRequest{}
		},
		TopicMeasureCollectLiaisonInfo: func() proto.Message {
			return &databasev1.GroupRegistryServiceInspectRequest{}
		},
		TopicStreamCollectDataInfo: func() proto.Message {
			return &databasev1.GroupRegistryServiceInspectRequest{}
		},
		TopicStreamCollectLiaisonInfo: func() proto.Message {
			return &databasev1.GroupRegistryServiceInspectRequest{}
		},
		TopicTraceCollectDataInfo: func() proto.Message {
			return &databasev1.GroupRegistryServiceInspectRequest{}
		},
		TopicTraceCollectLiaisonInfo: func() proto.Message {
			return &databasev1.GroupRegistryServiceInspectRequest{}
		},
		TopicMeasureDropGroup: func() proto.Message {
			return &databasev1.GroupRegistryServiceDeleteRequest{}
		},
		TopicStreamDropGroup: func() proto.Message {
			return &databasev1.GroupRegistryServiceDeleteRequest{}
		},
		TopicTraceDropGroup: func() proto.Message {
			return &databasev1.GroupRegistryServiceDeleteRequest{}
		},
	}

	// TopicResponseMap is the map of topic name to per-topic response codec.
	// Every proto-bodied topic is wrapped in a behavior-preserving ProtoCodec
	// (byte-identical to the pre-G9f.0 proto.Marshal/proto.Unmarshal path).
	// TopicInternalMeasureQuery uses a wire-mode-dispatching codec: flag-on
	// processes encode/decode the raw vec columnar frame via RawFrameCodec,
	// flag-off processes keep the proto body via ProtoCodec (one static
	// supplier serves both modes on the same topic — topic-AND-process-wire-
	// mode selection, G9f spec G9f.0).
	// nolint: exhaustruct
	TopicResponseMap = map[bus.Topic]ResponseCodec{
		TopicStreamQuery: &streamQueryResponseCodec{
			proto: NewProtoCodec(func() proto.Message {
				return &streamv1.QueryResponse{}
			}),
			raw: NewRawFrameCodec(),
		},
		TopicMeasureQuery: NewProtoCodec(func() proto.Message {
			return &measurev1.QueryResponse{}
		}),
		TopicInternalMeasureQuery: &measureQueryResponseCodec{
			proto: NewProtoCodec(func() proto.Message {
				return &measurev1.InternalQueryResponse{}
			}),
			raw: NewRawFrameCodec(),
		},
		TopicTopNQuery: NewProtoCodec(func() proto.Message {
			return &measurev1.TopNResponse{}
		}),
		TopicPropertyQuery: NewProtoCodec(func() proto.Message {
			return &propertyv1.InternalQueryResponse{}
		}),
		TopicPropertyDelete: NewProtoCodec(func() proto.Message {
			return &propertyv1.DeleteResponse{}
		}),
		TopicPropertyUpdate: NewProtoCodec(func() proto.Message {
			return &propertyv1.ApplyResponse{}
		}),
		TopicPropertyRepair: NewProtoCodec(func() proto.Message {
			return &propertyv1.InternalRepairResponse{}
		}),
		TopicTraceQuery: &traceQueryResponseCodec{
			proto: NewProtoCodec(func() proto.Message {
				return &tracev1.InternalQueryResponse{}
			}),
			raw: NewRawFrameCodec(),
		},
		TopicMeasureCollectDataInfo: NewProtoCodec(func() proto.Message {
			return &databasev1.DataInfo{}
		}),
		TopicStreamCollectDataInfo: NewProtoCodec(func() proto.Message {
			return &databasev1.DataInfo{}
		}),
		TopicTraceCollectDataInfo: NewProtoCodec(func() proto.Message {
			return &databasev1.DataInfo{}
		}),
		TopicMeasureCollectLiaisonInfo: NewProtoCodec(func() proto.Message {
			return &databasev1.LiaisonInfo{}
		}),
		TopicStreamCollectLiaisonInfo: NewProtoCodec(func() proto.Message {
			return &databasev1.LiaisonInfo{}
		}),
		TopicTraceCollectLiaisonInfo: NewProtoCodec(func() proto.Message {
			return &databasev1.LiaisonInfo{}
		}),
		TopicMeasureDropGroup: NewProtoCodec(func() proto.Message {
			return &databasev1.GroupRegistryServiceDeleteRequest{}
		}),
		TopicStreamDropGroup: NewProtoCodec(func() proto.Message {
			return &databasev1.GroupRegistryServiceDeleteRequest{}
		}),
		TopicTraceDropGroup: NewProtoCodec(func() proto.Message {
			return &databasev1.GroupRegistryServiceDeleteRequest{}
		}),
	}

	// TopicCommon is the common topic for data transmission.
	TopicCommon = bus.Topic{}
)

var InternalMeasureQueryKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "internal-measure-query",
}

var MeasureDeleteExpiredSegmentsKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "measure-delete-expired-segments",
}

var MeasurePartSyncKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "measure-part-sync",
}

var MeasureQueryKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "measure-query",
}

var MeasureSeriesIndexInsertKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "measure-series-index-insert",
}

var MeasureSeriesIndexUpdateKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "measure-series-index-update",
}

var MeasureSeriesSyncKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "measure-series-sync",
}

var MeasureWriteKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "measure-write",
}

var PropertyDeleteKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "property-delete",
}

var PropertyQueryKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "property-query",
}

var PropertyRepairKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "property-repair",
}

var PropertyUpdateKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "property-update",
}

var SnapshotKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "snapshot",
}

var StreamDeleteExpiredSegmentsKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "stream-delete-expired-segments",
}

var StreamElementIndexSyncKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "stream-element-index-sync",
}

var StreamLocalIndexWriteKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "stream-local-index-write",
}

var StreamPartSyncKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "stream-part-sync",
}

var StreamQueryKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "stream-query",
}

var StreamSeriesIndexWriteKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "stream-series-index-write",
}

var StreamSeriesSyncKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "stream-series-sync",
}

var StreamWriteKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "stream-write",
}

var TopNQueryKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "topN-query",
}

var TopicDeleteExpiredStreamSegments = bus.BiTopic(StreamDeleteExpiredSegmentsKindVersion.String())

var TopicDeleteExpiredTraceSegments = bus.BiTopic(TraceDeleteExpiredSegmentsKindVersion.String())

var TopicInternalMeasureQuery = bus.BiTopic(InternalMeasureQueryKindVersion.String())

var TopicMeasureCollectDataInfo = bus.BiTopic("measure-collect-data-info")

var TopicMeasureCollectLiaisonInfo = bus.BiTopic("measure-collect-liaison-info")

var TopicMeasureDeleteExpiredSegments = bus.BiTopic(MeasureDeleteExpiredSegmentsKindVersion.String())

var TopicMeasureDropGroup = bus.BiTopic("measure-drop-group")

var TopicMeasurePartSync = bus.BiTopic(MeasurePartSyncKindVersion.String())

var TopicMeasureQuery = bus.BiTopic(MeasureQueryKindVersion.String())

var TopicMeasureSeriesIndexInsert = bus.BiTopic(MeasureSeriesIndexInsertKindVersion.String())

var TopicMeasureSeriesIndexUpdate = bus.BiTopic(MeasureSeriesIndexUpdateKindVersion.String())

var TopicMeasureSeriesSync = bus.BiTopic(MeasureSeriesSyncKindVersion.String())

var TopicMeasureWrite = bus.BiTopic(MeasureWriteKindVersion.String())

var TopicPropertyDelete = bus.BiTopic(PropertyDeleteKindVersion.String())

var TopicPropertyQuery = bus.BiTopic(PropertyQueryKindVersion.String())

var TopicPropertyRepair = bus.BiTopic(PropertyRepairKindVersion.String())

var TopicPropertyUpdate = bus.BiTopic(PropertyUpdateKindVersion.String())

var TopicSnapshot = bus.BiTopic(SnapshotKindVersion.String())

var TopicStreamCollectDataInfo = bus.BiTopic("stream-collect-data-info")

var TopicStreamCollectLiaisonInfo = bus.BiTopic("stream-collect-liaison-info")

var TopicStreamDropGroup = bus.BiTopic("stream-drop-group")

var TopicStreamElementIndexSync = bus.BiTopic(StreamElementIndexSyncKindVersion.String())

var TopicStreamLocalIndexWrite = bus.BiTopic(StreamLocalIndexWriteKindVersion.String())

var TopicStreamPartSync = bus.BiTopic(StreamPartSyncKindVersion.String())

var TopicStreamQuery = bus.BiTopic(StreamQueryKindVersion.String())

var TopicStreamSeriesIndexWrite = bus.BiTopic(StreamSeriesIndexWriteKindVersion.String())

var TopicStreamSeriesSync = bus.BiTopic(StreamSeriesSyncKindVersion.String())

var TopicStreamWrite = bus.BiTopic(StreamWriteKindVersion.String())

var TopicTopNQuery = bus.BiTopic(TopNQueryKindVersion.String())

var TopicTraceCollectDataInfo = bus.BiTopic("trace-collect-data-info")

var TopicTraceCollectLiaisonInfo = bus.BiTopic("trace-collect-liaison-info")

var TopicTraceDropGroup = bus.BiTopic("trace-drop-group")

var TopicTracePartSync = bus.BiTopic(TracePartSyncKindVersion.String())

var TopicTraceQuery = bus.BiTopic(TraceQueryKindVersion.String())

var TopicTraceSeriesSync = bus.BiTopic(TraceSeriesSyncKindVersion.String())

var TopicTraceSidxSeriesWrite = bus.BiTopic(TraceSidxSeriesWriteKindVersion.String())

var TopicTraceWrite = bus.BiTopic(TraceWriteKindVersion.String())

var TraceDeleteExpiredSegmentsKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "trace-delete-expired-segments",
}

var TracePartSyncKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "trace-part-sync",
}

var TraceQueryKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "trace-query",
}

var TraceSeriesSyncKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "trace-series-sync",
}

var TraceSidxSeriesWriteKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "trace-sidx-series-write",
}

var TraceWriteKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "trace-write",
}