add msaaging job

Author: optim-kazuhiro-seida

.gitignore

@@ -9,3 +9,4 @@ cios*
 **node.yml
 **produce.yml
 
+test.yml

cli/publishsubscribe/messaging.go

@@ -3,13 +3,19 @@ package publishsubscribe
 import (
 	"context"
 	"errors"
+	"fmt"
 	"os"
 	"strconv"
+	"sync"
 	"time"
 
+	"github.com/optim-kazuhiro-seida/go-advance-type/convert"
+	"gopkg.in/yaml.v2"
+
 	. "github.com/optim-corp/cios-cli/cli"
 	"github.com/optim-corp/cios-cli/models"
 	"github.com/optim-corp/cios-cli/utils"
+	"github.com/optim-corp/cios-golang-sdk/cios"
 	ciossdk "github.com/optim-corp/cios-golang-sdk/sdk"
 	log "github.com/optim-kazuhiro-seida/loglog"
 	"github.com/urfave/cli/v2"
@@ -31,6 +37,7 @@ func GetMessagingCommand() *cli.Command {
 			listChannels(),
 			publishMessage(),
 			autoMessage(),
+			registerJob(),
 		},
 		Action: func(c *cli.Context) error {
 			var (
@@ -299,3 +306,87 @@ func autoMessage() *cli.Command {
 		},
 	}
 }
+
+func registerJob() *cli.Command {
+	return &cli.Command{
+		Name:    "job",
+		Aliases: []string{"register", "reg", "j"},
+		Usage:   "cios messaging job | register",
+		Flags: []cli.Flag{
+			&cli.StringFlag{Name: "path", Aliases: []string{"file_path", "f", "p", "file"}},
+			&cli.Int64Flag{Name: "beginning_timestamp", Aliases: []string{"start", "b", "start_timestamp", "beginning"}, Value: time.Now().UnixNano(), DefaultText: "Now Timestamp"},
+		},
+		Action: func(c *cli.Context) error {
+			var (
+				filePath           = c.String("file_path")
+				beginningTimestamp = c.Int64("beginning_timestamp")
+				jobYaml            models.Job
+				byts, err          = path(filePath).ReadFile()
+				wg                 = sync.WaitGroup{}
+			)
+			fmt.Println(filePath, beginningTimestamp)
+			check := func(jobYaml models.Job) error {
+				for _, jobs := range jobYaml {
+					for _, job := range jobs {
+						for _, v := range job.Value {
+							var formatJson cios.PackerFormatJson
+							if err := convert.UnMarshalJson([]byte(v.Data), &formatJson); err != nil {
+								return err
+							}
+
+						}
+					}
+				}
+				return nil
+			}
+			send := func(v models.MessagingJobValue, formatJson cios.PackerFormatJson, loop int, SendJson func(interface{}) error) error {
+				for i, cnt := int64(0), 0; cnt < loop; i++ {
+					switch {
+					case i%v.Timestamp == 0:
+						formatJson.Header.Timestamp = str(beginningTimestamp + i)
+						fallthrough
+					case v.Timestamp == -1 || i%v.Timestamp == 0:
+						fmt.Println("Publish", formatJson.Header.Timestamp)
+						if err := SendJson(formatJson); err != nil {
+							return err
+						}
+						cnt++
+					}
+					time.Sleep(time.Nanosecond)
+				}
+				return nil
+			}
+			execJob := func(jobs models.MessagingJobs, name string) {
+				defer wg.Done()
+				for _, job := range jobs {
+					ms := Client.PubSub.NewMessaging(job.Channel, "publish", "json")
+					if err := ms.Start(context.Background()); err != nil {
+						log.Error(err)
+						return
+					}
+					fmt.Println(fmt.Sprintf("Start Job: %s", name))
+
+					for _, v := range job.Value {
+						var formatJson cios.PackerFormatJson
+						_ = convert.UnMarshalJson([]byte(v.Data), &formatJson)
+						if err := send(v, formatJson, job.Loop, ms.SendJson); err != nil {
+							break
+						}
+					}
+
+				}
+			}
+			return assert(err).Log().
+				NoneErrAssert(yaml.Unmarshal(byts, &jobYaml)).Log().
+				NoneErrAssert(check(jobYaml)).Log().
+				NoneErr(func() {
+					for name, jobs := range jobYaml {
+						wg.Add(1)
+						go execJob(jobs, name)
+					}
+					wg.Wait()
+				}).
+				Err
+		},
+	}
+}

go.mod

@@ -7,14 +7,14 @@ require (
 	github.com/k0kubun/colorstring v0.0.0-20150214042306-9440f1994b88 // indirect
 	github.com/k0kubun/pp v3.0.1+incompatible
 	github.com/mitchellh/go-homedir v1.1.0
-	github.com/optim-corp/cios-golang-sdk v0.1.0
+	github.com/optim-corp/cios-golang-sdk v0.2.0
 	github.com/optim-kazuhiro-seida/ftil v1.0.0
-	github.com/optim-kazuhiro-seida/go-advance-type v1.3.0
-	github.com/optim-kazuhiro-seida/loglog v0.5.0
+	github.com/optim-kazuhiro-seida/go-advance-type v1.5.1
+	github.com/optim-kazuhiro-seida/loglog v0.8.0
 	github.com/skratchdot/open-golang v0.0.0-20200116055534-eef842397966
-	github.com/tidwall/gjson v1.6.4
+	github.com/tidwall/gjson v1.7.5
 	github.com/urfave/cli/v2 v2.2.0
 	golang.org/x/sync v0.0.0-20201207232520-09787c993a3a
 	gopkg.in/AlecAivazis/survey.v1 v1.8.8
-	gopkg.in/yaml.v2 v2.3.0 // indirect
+	gopkg.in/yaml.v2 v2.4.0
 )

go.sum

@@ -55,6 +55,7 @@ github.com/envoyproxy/go-control-plane v0.9.0/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymF
 github.com/envoyproxy/go-control-plane v0.9.1-0.20191026205805-5f8ba28d4473/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
 github.com/envoyproxy/go-control-plane v0.9.4/go.mod h1:6rpuAdCZL397s3pYoYcLgu1mIlRU8Am5FuJP05cCM98=
 github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c=
+github.com/fatih/color v1.10.0/go.mod h1:ELkj/draVOlAH/xkhN6mQ50Qd0MPOk5AAr3maGEBuJM=
 github.com/go-errors/errors v1.1.1 h1:ljK/pL5ltg3qoN+OtN6yCv9HWSfMwxSx90GJCZQxYNg=
 github.com/go-errors/errors v1.1.1/go.mod h1:psDX2osz5VnTOnFWbDeWwS7yejl+uV3FEWEp4lssFEs=
 github.com/go-gl/glfw v0.0.0-20190409004039-e6da0acd62b1/go.mod h1:vR7hzQXu2zJy9AVAgeJqvqgH9Q5CA+iKCZ2gyEVpxRU=
@@ -142,8 +143,12 @@ github.com/kr/text v0.1.0 h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/mattn/go-colorable v0.1.2 h1:/bC9yWikZXAL9uJdulbSfyVNIR3n3trXl+v8+1sx8mU=
 github.com/mattn/go-colorable v0.1.2/go.mod h1:U0ppj6V5qS13XJ6of8GYAs25YV2eR4EVcfRqFIhoBtE=
+github.com/mattn/go-colorable v0.1.8 h1:c1ghPdyEDarC70ftn0y+A/Ee++9zz8ljHG1b13eJ0s8=
+github.com/mattn/go-colorable v0.1.8/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc=
 github.com/mattn/go-isatty v0.0.8 h1:HLtExJ+uU2HOZ+wI0Tt5DtUDrx8yhUqDcp7fYERX4CE=
 github.com/mattn/go-isatty v0.0.8/go.mod h1:Iq45c/XA43vh69/j3iqttzPXn0bhXyGjM0Hdxcsrc5s=
+github.com/mattn/go-isatty v0.0.12 h1:wuysRhFDzyxgEmMf5xjvJ2M9dZoWAXNNr5LSBS7uHXY=
+github.com/mattn/go-isatty v0.0.12/go.mod h1:cbi8OIDigv2wuxKPP5vlRcQ1OAZbq2CE4Kysco4FUpU=
 github.com/mgutz/ansi v0.0.0-20170206155736-9520e82c474b h1:j7+1HpAFS1zy5+Q4qx1fWh90gTKwiN4QCGoY9TWyyO4=
 github.com/mgutz/ansi v0.0.0-20170206155736-9520e82c474b/go.mod h1:01TrycV0kFyexm33Z7vhZRXopbI8J3TDReVlkTgMUxE=
 github.com/mitchellh/go-homedir v1.1.0 h1:lukF9ziXFxDFPkA1vsr5zpc1XuPDn/wFntq5mG+4E0Y=
@@ -157,18 +162,17 @@ github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJ
 github.com/modern-go/reflect2 v0.0.0-20180701023420-4b7aa43c6742/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
 github.com/modern-go/reflect2 v1.0.1 h1:9f412s+6RmYXLWZSEzVVgPGK7C2PphHj5RJrvfx9AWI=
 github.com/modern-go/reflect2 v1.0.1/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
-github.com/optim-corp/cios-golang-sdk v0.0.6 h1:yPXciFu45QG308Ocqd9v+xbtRhuAMBYSSdrH8HbtNdI=
-github.com/optim-corp/cios-golang-sdk v0.0.6/go.mod h1:L2RQeKwAavA8J8YYpkwwLdFy3cjcIpppQOAPqzxkNXI=
-github.com/optim-corp/cios-golang-sdk v0.1.0 h1:AcRJVZMkoxmyWGU6qycgRBgXGnso4v7Zppcf1juaOkQ=
-github.com/optim-corp/cios-golang-sdk v0.1.0/go.mod h1:L2RQeKwAavA8J8YYpkwwLdFy3cjcIpppQOAPqzxkNXI=
+github.com/optim-corp/cios-golang-sdk v0.2.0 h1:O5fl5iL3qhw7AaE4VvcgDHP+M79/VAQLyTIoYFfFiKc=
+github.com/optim-corp/cios-golang-sdk v0.2.0/go.mod h1:L2RQeKwAavA8J8YYpkwwLdFy3cjcIpppQOAPqzxkNXI=
 github.com/optim-kazuhiro-seida/ftil v1.0.0 h1:f+dj6KIPzRLTrq1oHY18eKDnXIqEhfNN0uRt2ticp+s=
 github.com/optim-kazuhiro-seida/ftil v1.0.0/go.mod h1:dTGehrWE16Kye+Ww40G8wSLjKKXOfWqgHSwISWrHpmU=
 github.com/optim-kazuhiro-seida/go-advance-type v1.2.4 h1:LUk8wNjGfO7/SYhW8ejmcrl3A4187jB2aW9VQaLPneI=
 github.com/optim-kazuhiro-seida/go-advance-type v1.2.4/go.mod h1:t8CQQ6DsvogVqWuXuTIaCQsbfSYqDJ1YOXm+RtZd2H0=
-github.com/optim-kazuhiro-seida/go-advance-type v1.3.0 h1:YNe0LH1d+hMiYRdg8g37VomGH97sDFvGXMese2HC2Ns=
-github.com/optim-kazuhiro-seida/go-advance-type v1.3.0/go.mod h1:t8CQQ6DsvogVqWuXuTIaCQsbfSYqDJ1YOXm+RtZd2H0=
-github.com/optim-kazuhiro-seida/loglog v0.5.0 h1:cjE7K/UVDfbs+JGnamLElFHVRg04xOxA1lQSNCp57FM=
-github.com/optim-kazuhiro-seida/loglog v0.5.0/go.mod h1:ng87+rDVhUYVvJzd0c7T3paBwXNXhxlNGPmo7usFtkM=
+github.com/optim-kazuhiro-seida/go-advance-type v1.5.0/go.mod h1:t8CQQ6DsvogVqWuXuTIaCQsbfSYqDJ1YOXm+RtZd2H0=
+github.com/optim-kazuhiro-seida/go-advance-type v1.5.1 h1:e9We0VuIdgn+xrCKcANYL491Wpen82kh65UKhpUcicE=
+github.com/optim-kazuhiro-seida/go-advance-type v1.5.1/go.mod h1:t8CQQ6DsvogVqWuXuTIaCQsbfSYqDJ1YOXm+RtZd2H0=
+github.com/optim-kazuhiro-seida/loglog v0.8.0 h1:5JnsASjrz2y1t2BhqOrq4D9uGWHTrcxbp38Q2UXuY3Q=
+github.com/optim-kazuhiro-seida/loglog v0.8.0/go.mod h1:8ZAzbswlnGNjj4paaj1NPUZYsnrtH7dCNZnmp02l5pE=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
@@ -190,10 +194,16 @@ github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5
 github.com/tidwall/gjson v1.6.3/go.mod h1:BaHyNc5bjzYkPqgLq7mdVzeiRtULKULXLgZFKsxEHI0=
 github.com/tidwall/gjson v1.6.4 h1:JKsCsJqRVFz8eYCsQ5E/ANRbK6CanAtA9IUvGsXklyo=
 github.com/tidwall/gjson v1.6.4/go.mod h1:BaHyNc5bjzYkPqgLq7mdVzeiRtULKULXLgZFKsxEHI0=
+github.com/tidwall/gjson v1.7.5 h1:zmAN/xmX7OtpAkv4Ovfso60r/BiCi5IErCDYGNJu+uc=
+github.com/tidwall/gjson v1.7.5/go.mod h1:5/xDoumyyDNerp2U36lyolv46b3uF/9Bu6OfyQ9GImk=
 github.com/tidwall/match v1.0.1 h1:PnKP62LPNxHKTwvHHZZzdOAOCtsJTjo6dZLCwpKm5xc=
 github.com/tidwall/match v1.0.1/go.mod h1:LujAq0jyVjBy028G1WhWfIzbpQfMO8bBZ6Tyb0+pL9E=
+github.com/tidwall/match v1.0.3 h1:FQUVvBImDutD8wJLN6c5eMzWtjgONK9MwIBCOrUJKeE=
+github.com/tidwall/match v1.0.3/go.mod h1:eRSPERbgtNPcGhD8UCthc6PmLEQXEWd3PRB5JTxsfmM=
 github.com/tidwall/pretty v1.0.2 h1:Z7S3cePv9Jwm1KwS0513MRaoUe3S01WPbLNV40pwWZU=
 github.com/tidwall/pretty v1.0.2/go.mod h1:XNkn88O1ChpSDQmQeStsy+sBenx6DDtFZJxhVysOjyk=
+github.com/tidwall/pretty v1.1.0 h1:K3hMW5epkdAVwibsQEfR/7Zj0Qgt4DxtNumTq/VloO8=
+github.com/tidwall/pretty v1.1.0/go.mod h1:XNkn88O1ChpSDQmQeStsy+sBenx6DDtFZJxhVysOjyk=
 github.com/urfave/cli/v2 v2.2.0 h1:JTTnM6wKzdA0Jqodd966MVj4vWbbquZykeX1sKbe2C4=
 github.com/urfave/cli/v2 v2.2.0/go.mod h1:SE9GqnLQmjVa0iPEY0f1w3ygNIYcIJ0OKPMoW2caLfQ=
 github.com/yuin/goldmark v1.1.25/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
@@ -309,6 +319,7 @@ golang.org/x/sys v0.0.0-20191001151750-bb3f8db39f24/go.mod h1:h1NjWce9XRLGQEsW7w
 golang.org/x/sys v0.0.0-20191204072324-ce4227a45e2e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20191228213918-04cbcbbfeed8/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20200113162924-86b910548bc1/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200116001909-b77594299b42/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20200122134326-e047566fdf82/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20200202164722-d101bd2416d5/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20200212091648-12a6c2dcc1e4/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -464,8 +475,8 @@ gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 h1:qIbj1fsPNlZgppZ+VLlY7N33
 gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI=
 gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
-gopkg.in/yaml.v2 v2.3.0 h1:clyUAQHOM3G0M3f5vQj7LuJrETvjVot3Z5el9nffUtU=
-gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=
+gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=
 honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
 honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
 honnef.co/go/tools v0.0.0-20190418001031-e561f6794a2a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=

main.go

@@ -43,16 +43,16 @@ func init() {
 	if os.Getenv("AUTH_TYPE") == "client" {
 		setClientType()
 	} else {
-		path(topDir).CreateDir()
+		assert(path(topDir).CreateDir()).Log()
 		configFile := path(configPath)
 		urlFile := path(urlDir)
 		file, configErr := configFile.ReadFile()
 		urls, urlErr := urlFile.ReadFile()
 		assert(urlErr).
-			OnErr(func() { urlFile.CreateFile() }).
+			OnErr(func() { assert(urlFile.CreateFile()).Log() }).
 			OnErr(func() { assert(urlFile.WriteFileAsString(models.URL_JSON)) })
 		assert(configErr).
-			OnErr(func() { configFile.CreateFile() }).
+			OnErr(func() { assert(configFile.CreateFile()).Log() }).
 			ExitWith(0)
 		assert(json.Unmarshal(file, &config)).
 			NoneErr(func() { setConfig(config, urls, config.Stage) })
@@ -94,7 +94,6 @@ func main() {
 		log.Error(err.Error())
 	}
 }
-
 func setClientType() {
 	logLevel := os.Getenv("LOG_LEVEL")
 	log.SetLevelOrDefault(is(logLevel == "").T("info").F(logLevel).Value.(string), log.LOG_LEVEL_WARN)
@@ -116,7 +115,6 @@ func setClientType() {
 		},
 	})
 }
-
 func setConfig(config models.Config, urls []byte, stage string) {
 	_ = models.SetStage(stage)
 	log.SetLevelOrDefault(config.LogLevel, log.LOG_LEVEL_WARN)

models/enum.go

@@ -0,0 +1,56 @@
+package models
+
+import (
+	"github.com/optim-kazuhiro-seida/go-advance-type/convert"
+)
+
+var (
+	LIST         = "list"
+	PATCH        = "patch"
+	CREATE       = "create"
+	DELETE       = "delete"
+	ALIAS_LIST   = []string{"ls", "show", "out", "output"}
+	ALIAS_PATCH  = []string{"patch", "update", "up", "pct", "upgrade", "upd"}
+	ALIAS_CREATE = []string{"cre", "add", "sub", "subscribe"}
+	ALIAS_DELETE = []string{"del", "rm", "remove", "clean", "clear", "cle"}
+
+	Stages    = createStages()
+	FullScope = "openid email profile address user.profile user.read user.write " +
+		"group.read group.write group.relation.read group.relation.write" +
+		"corporation.read corporation.write corporation.user.read corporation.user.write corporation.group.read  corporation.group.write " +
+		"oauth2_client.read oauth2_client.write license.read license.write acl.read acl.write resource_owner.read " +
+		"resource_owner.read " +
+		"channel_protocol.read channel_protocol.write.internal channel.read  channel.write  " +
+		"messaging.subscribe  messaging.publish " +
+		"datastore.read  datastore.write  datastore.upload  datastore.download " +
+		"file_storage.read file_storage.write file_storage.upload  file_storage.download  " +
+		"device.read  device.write  device_model.read device_model.write device.group_policy.read devices.group_policies.write " +
+		"geo.area.read geo.area.write geo.area-kind.read geo.area-kind.write geo.area.content.write geo.circle.read geo.circle.write geo.map.read geo.map.write geo.point.read geo.point.write geo.polygon.read geo.polygon.write geo.route.read geo.route.write " +
+		"active_license.read active_license.write product.read " +
+		"videostream.read videostream.view "
+	URL_JSON = convert.MustIndentJson(URLs{
+		"prod": {
+			DeviceManagement:      "device-management.optimcloudapis.com",
+			DeviceAssetManagement: "device-asset-lifecycle.optimcloudapis.com",
+			Monitoring:            "monitoring.optimcloudapis.com",
+			Messaging:             "messaging.optimcloudapis.com",
+			Location:              "location.optimcloudapis.com",
+			Accounts:              "accounts.optimcloudapis.com",
+			Storage:               "storage.optimcloudapis.com",
+			Iam:                   "iam.optimcloudapis.com",
+			Auth:                  "auth.optim.cloud",
+			VideoStreams:          "video-streaming.optim.cloud",
+		},
+		"pre": {
+			DeviceManagement: "device-management.preapis.cios.dev",
+			Monitoring:       "monitoring.preapis.cios.dev",
+			Messaging:        "messaging.preapis.cios.dev",
+			Location:         "location.preapis.cios.dev",
+			Accounts:         "accounts.preapis.cios.dev",
+			Storage:          "storage.preapis.cios.dev",
+			Iam:              "iam.preapis.cios.dev",
+			Auth:             "auth.pre.cios.dev",
+			VideoStreams:     "video-streaming.preapis.cios.dev",
+		},
+	})
+)

models/model_job.go

@@ -0,0 +1,16 @@
+package models
+
+type (
+	Job               map[string]MessagingJobs
+	MessagingJobs     []MessagingJob
+	MessagingJobValue struct {
+		Data      string `yaml:"data"`
+		Timestamp int64  `yaml:"timestamp"`
+	}
+	MessagingJob struct {
+		Channel string              `yaml:"channel"`
+		Loop    int                 `yaml:"loop"`
+		Plugin  string              `yaml:"plugin"`
+		Value   []MessagingJobValue `yaml:"value,flow"`
+	}
+)