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,
		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,
		TopicTraceSidxSeriesWrite.String():     TopicTraceSidxSeriesWrite,
	}

	// 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{}
		},
		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
		},
		TopicTraceSidxSeriesWrite: func() proto.Message {
			return nil
		},
	}

	// TopicResponseMap is the map of topic name to response message.
	// nolint: exhaustruct
	TopicResponseMap = map[bus.Topic]func() proto.Message{
		TopicStreamQuery: func() proto.Message {
			return &streamv1.QueryResponse{}
		},
		TopicMeasureQuery: func() proto.Message {
			return &measurev1.QueryResponse{}
		},
		TopicTopNQuery: func() proto.Message {
			return &measurev1.TopNResponse{}
		},
		TopicPropertyQuery: func() proto.Message {
			return &propertyv1.InternalQueryResponse{}
		},
		TopicPropertyDelete: func() proto.Message {
			return &propertyv1.DeleteResponse{}
		},
		TopicPropertyUpdate: func() proto.Message {
			return &propertyv1.ApplyResponse{}
		},
		TopicPropertyRepair: func() proto.Message {
			return &propertyv1.InternalRepairResponse{}
		},
		TopicTraceQuery: func() proto.Message {
			return &tracev1.InternalQueryResponse{}
		},
	}

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

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 TopicMeasureDeleteExpiredSegments = bus.BiTopic(MeasureDeleteExpiredSegmentsKindVersion.String())

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 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 TopicTracePartSync = bus.BiTopic(TracePartSyncKindVersion.String())

var TopicTraceQuery = bus.BiTopic(TraceQueryKindVersion.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 TraceSidxSeriesWriteKindVersion = common.KindVersion{
	Version: "v1",
	Kind:    "trace-sidx-series-write",
}

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