data

Documentation

Overview

Package data contains data transmission topics.

Index

• Variables

Variables

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

MeasureQueryKindVersion is the version tag of measure query kind.

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

MeasureWriteKindVersion is the version tag of measure write kind.

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

StreamQueryKindVersion is the version tag of stream query kind.

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

StreamWriteKindVersion is the version tag of stream write kind.

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

TopNQueryKindVersion is the version tag of top-n query kind.

var TopicMap = map[string]bus.Topic{
	TopicStreamWrite.String():  TopicStreamWrite,
	TopicStreamQuery.String():  TopicStreamQuery,
	TopicMeasureWrite.String(): TopicMeasureWrite,
	TopicMeasureQuery.String(): TopicMeasureQuery,
	TopicTopNQuery.String():    TopicTopNQuery,
}

TopicMap is the map of topic name to topic.

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

TopicMeasureQuery is the measure query topic.

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

TopicMeasureWrite is the measure write topic.

var 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{}
	},
}

TopicRequestMap is the map of topic name to request message. nolint: exhaustruct

var 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{}
	},
}

TopicResponseMap is the map of topic name to response message. nolint: exhaustruct

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

TopicStreamQuery is the stream query topic.

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

TopicStreamWrite is the stream write topic.

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

TopicTopNQuery is the top-n query topic.