X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Fkafka-procon%2Fmain.go;h=75f3163ed35ce03a7bf3d3121c77f88f19954d91;hb=30cbd4c1f33d1e97f9dca55731b9bf0811583be9;hp=43be1b5ab1f09c04933b1ff84e976de8df9be71b;hpb=dfdca185681554d67b63ec37ed19954654223e46;p=nonrtric.git diff --git a/test/kafka-procon/main.go b/test/kafka-procon/main.go index 43be1b5a..75f3163e 100644 --- a/test/kafka-procon/main.go +++ b/test/kafka-procon/main.go @@ -1,3 +1,23 @@ +// - +// ========================LICENSE_START================================= +// O-RAN-SC +// %% +// Copyright (C) 2020-2022: Nordix Foundation +// %% +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. +// ========================LICENSE_END=================================== +// + // Writing a basic HTTP server is easy using the // `net/http` package. package main @@ -20,13 +40,13 @@ import ( // Note: consumer 'group' and consumer 'user' both uses hardcoded values specific to this interface // globalCounters var holding the "global counters" -// recieved number of received messages from all topics (int) +// received number of received messages from all topics (int) // sent number of sent messages to all topics (int) // topics var holding all topic related info // name of a topic (present after topic is created) // content-type data type of the topic (string) // counters -// recieved number of received messages from the topic (int) +// received number of received messages from the topic (int) // sent number of sent messages to the topic (int) // messages // send messages waiting to be sent (set when sending is started) (fifo)