mocknode

package
v2.0.0-beta.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 14, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const TIMELEAP = 200

Variables

View Source 
var Image, _ = GetImg()
View Source 
var TestData = map[string][]*xsql.Tuple{
	"sharedDemo": {
		{
			Emitter: "sharedDemo",
			Message: map[string]interface{}{
				"a": 1,
				"b": 2,
				"c": 3,
			},
			Timestamp: time.UnixMilli(1541152486013),
		},
	},
	"demo": {
		{
			Emitter: "demo",
			Message: map[string]interface{}{
				"color": "red",
				"size":  3,
				"ts":    1541152486013,
			},
			Timestamp: time.UnixMilli(1541152486013),
		},
		{
			Emitter: "demo",
			Message: map[string]interface{}{
				"color": "blue",
				"size":  6,
				"ts":    1541152486822,
			},
			Timestamp: time.UnixMilli(1541152486822),
		},
		{
			Emitter: "demo",
			Message: map[string]interface{}{
				"color": "blue",
				"size":  2,
				"ts":    1541152487632,
			},
			Timestamp: time.UnixMilli(1541152487632),
		},
		{
			Emitter: "demo",
			Message: map[string]interface{}{
				"color": "yellow",
				"size":  4,
				"ts":    1541152488442,
			},
			Timestamp: time.UnixMilli(1541152488442),
		},
		{
			Emitter: "demo",
			Message: map[string]interface{}{
				"color": "red",
				"size":  1,
				"ts":    1541152489252,
			},
			Timestamp: time.UnixMilli(1541152489252),
		},
	},
	"demoError": {
		{
			Emitter: "demoError",
			Message: map[string]interface{}{
				"color": "blue",
				"size":  "red",
				"ts":    1541152486013,
			},
			Timestamp: time.UnixMilli(1541152486013),
		},
		{
			Emitter: "demoError",
			Message: map[string]interface{}{
				"color": "blue",
				"size":  6,
				"ts":    1541152486822,
			},
			Timestamp: time.UnixMilli(1541152486822),
		},
		{
			Emitter: "demoError",
			Message: map[string]interface{}{
				"color": "blue",
				"size":  2,
				"ts":    1541152487632,
			},
			Timestamp: time.UnixMilli(1541152487632),
		},
		{
			Emitter: "demoError",
			Message: map[string]interface{}{
				"color": 7,
				"size":  4,
				"ts":    1541152488442,
			},
			Timestamp: time.UnixMilli(1541152488442),
		},
		{
			Emitter: "demoError",
			Message: map[string]interface{}{
				"color": "red",
				"size":  "blue",
				"ts":    1541152489252,
			},
			Timestamp: time.UnixMilli(1541152489252),
		},
	},
	"demo1": {
		{
			Emitter: "demo1",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  65,
				"from": "device1",
				"ts":   1541152486013,
			},
			Timestamp: time.UnixMilli(1541152486115),
		},
		{
			Emitter: "demo1",
			Message: map[string]interface{}{
				"temp": 27.5,
				"hum":  59,
				"from": "device2",
				"ts":   1541152486823,
			},
			Timestamp: time.UnixMilli(1541152486903),
		},
		{
			Emitter: "demo1",
			Message: map[string]interface{}{
				"temp": 28.1,
				"hum":  75,
				"from": "device3",
				"ts":   1541152487632,
			},
			Timestamp: time.UnixMilli(1541152487702),
		},
		{
			Emitter: "demo1",
			Message: map[string]interface{}{
				"temp": 27.4,
				"hum":  80,
				"from": "device1",
				"ts":   1541152488442,
			},
			Timestamp: time.UnixMilli(1541152488605),
		},
		{
			Emitter: "demo1",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  62,
				"from": "device3",
				"ts":   1541152489252,
			},
			Timestamp: time.UnixMilli(1541152489305),
		},
	},
	"sessionDemo": {
		{
			Emitter: "sessionDemo",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  65,
				"ts":   1541152486013,
			},
			Timestamp: time.UnixMilli(1541152486013),
		},
		{
			Emitter: "sessionDemo",
			Message: map[string]interface{}{
				"temp": 27.5,
				"hum":  59,
				"ts":   1541152486823,
			},
			Timestamp: time.UnixMilli(1541152486823),
		},
		{
			Emitter: "sessionDemo",
			Message: map[string]interface{}{
				"temp": 28.1,
				"hum":  75,
				"ts":   1541152487932,
			},
			Timestamp: time.UnixMilli(1541152487932),
		},
		{
			Emitter: "sessionDemo",
			Message: map[string]interface{}{
				"temp": 27.4,
				"hum":  80,
				"ts":   1541152488442,
			},
			Timestamp: time.UnixMilli(1541152488442),
		},
		{
			Emitter: "sessionDemo",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  62,
				"ts":   1541152489252,
			},
			Timestamp: time.UnixMilli(1541152489252),
		},
		{
			Emitter: "sessionDemo",
			Message: map[string]interface{}{
				"temp": 26.2,
				"hum":  63,
				"ts":   1541152490062,
			},
			Timestamp: time.UnixMilli(1541152490062),
		},
		{
			Emitter: "sessionDemo",
			Message: map[string]interface{}{
				"temp": 26.8,
				"hum":  71,
				"ts":   1541152490872,
			},
			Timestamp: time.UnixMilli(1541152490872),
		},
		{
			Emitter: "sessionDemo",
			Message: map[string]interface{}{
				"temp": 28.9,
				"hum":  85,
				"ts":   1541152491682,
			},
			Timestamp: time.UnixMilli(1541152491682),
		},
		{
			Emitter: "sessionDemo",
			Message: map[string]interface{}{
				"temp": 29.1,
				"hum":  92,
				"ts":   1541152492492,
			},
			Timestamp: time.UnixMilli(1541152492492),
		},
		{
			Emitter: "sessionDemo",
			Message: map[string]interface{}{
				"temp": 32.2,
				"hum":  99,
				"ts":   1541152493202,
			},
			Timestamp: time.UnixMilli(1541152493202),
		},
		{
			Emitter: "sessionDemo",
			Message: map[string]interface{}{
				"temp": 30.9,
				"hum":  87,
				"ts":   1541152494112,
			},
			Timestamp: time.UnixMilli(1541152494112),
		},
	},
	"demoE": {
		{
			Emitter: "demoE",
			Message: map[string]interface{}{
				"color": "red",
				"size":  3,
				"ts":    1541152486013,
			},
			Timestamp: time.UnixMilli(1541152586023),
		},
		{
			Emitter: "demoE",
			Message: map[string]interface{}{
				"color": "blue",
				"size":  2,
				"ts":    1541152487632,
			},
			Timestamp: time.UnixMilli(1541152587822),
		},
		{
			Emitter: "demoE",
			Message: map[string]interface{}{
				"color": "red",
				"size":  1,
				"ts":    1541152489252,
			},
			Timestamp: time.UnixMilli(1541152589632),
		},
		{
			Emitter: "demoE",
			Message: map[string]interface{}{
				"color": "blue",
				"size":  6,
				"ts":    1541152486822,
			},
			Timestamp: time.UnixMilli(1541152589842),
		},
		{
			Emitter: "demoE",
			Message: map[string]interface{}{
				"color": "yellow",
				"size":  4,
				"ts":    1541152488442,
			},
			Timestamp: time.UnixMilli(1541152590052),
		},
		{
			Emitter: "demoE",
			Message: map[string]interface{}{
				"color": "yellow",
				"size":  4,
				"ts":    1541152492342,
			},
			Timestamp: time.UnixMilli(1541152598888),
		},
	},
	"demo1E": {
		{
			Emitter: "demo1E",
			Message: map[string]interface{}{
				"temp": 27.5,
				"hum":  59,
				"ts":   1541152486823,
			},
			Timestamp: time.UnixMilli(1541152587250),
		},
		{
			Emitter: "demo1E",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  65,
				"ts":   1541152486013,
			},
			Timestamp: time.UnixMilli(1541152587751),
		},
		{
			Emitter: "demo1E",
			Message: map[string]interface{}{
				"temp": 27.4,
				"hum":  80,
				"ts":   1541152488442,
			},
			Timestamp: time.UnixMilli(1541152589252),
		},
		{
			Emitter: "demo1E",
			Message: map[string]interface{}{
				"temp": 28.1,
				"hum":  75,
				"ts":   1541152487632,
			},
			Timestamp: time.UnixMilli(1541152589753),
		},
		{
			Emitter: "demo1E",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  62,
				"ts":   1541152489252,
			},
			Timestamp: time.UnixMilli(1541152589954),
		},
		{
			Emitter: "demo1E",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  62,
				"ts":   1541152499252,
			},
			Timestamp: time.UnixMilli(1541152599755),
		},
	},
	"sessionDemoE": {
		{
			Emitter: "sessionDemoE",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  65,
				"ts":   1541152486013,
			},
			Timestamp: time.UnixMilli(1541152586250),
		},
		{
			Emitter: "sessionDemoE",
			Message: map[string]interface{}{
				"temp": 28.1,
				"hum":  75,
				"ts":   1541152487932,
			},
			Timestamp: time.UnixMilli(1541152587951),
		},
		{
			Emitter: "sessionDemoE",
			Message: map[string]interface{}{
				"temp": 27.5,
				"hum":  59,
				"ts":   1541152486823,
			},
			Timestamp: time.UnixMilli(1541152588552),
		},
		{
			Emitter: "sessionDemoE",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  62,
				"ts":   1541152489252,
			},
			Timestamp: time.UnixMilli(1541152589353),
		},
		{
			Emitter: "sessionDemoE",
			Message: map[string]interface{}{
				"temp": 27.4,
				"hum":  80,
				"ts":   1541152488442,
			},
			Timestamp: time.UnixMilli(1541152589854),
		},
		{
			Emitter: "sessionDemoE",
			Message: map[string]interface{}{
				"temp": 26.2,
				"hum":  63,
				"ts":   1541152490062,
			},
			Timestamp: time.UnixMilli(1541152590155),
		},
		{
			Emitter: "sessionDemoE",
			Message: map[string]interface{}{
				"temp": 28.9,
				"hum":  85,
				"ts":   1541152491682,
			},
			Timestamp: time.UnixMilli(1541152591686),
		},
		{
			Emitter: "sessionDemoE",
			Message: map[string]interface{}{
				"temp": 26.8,
				"hum":  71,
				"ts":   1541152490872,
			},
			Timestamp: time.UnixMilli(1541152591972),
		},
		{
			Emitter: "sessionDemoE",
			Message: map[string]interface{}{
				"temp": 29.1,
				"hum":  92,
				"ts":   1541152492492,
			},
			Timestamp: time.UnixMilli(1541152592592),
		},
		{
			Emitter: "sessionDemoE",
			Message: map[string]interface{}{
				"temp": 30.9,
				"hum":  87,
				"ts":   1541152494112,
			},
			Timestamp: time.UnixMilli(1541152594212),
		},
		{
			Emitter: "sessionDemoE",
			Message: map[string]interface{}{
				"temp": 32.2,
				"hum":  99,
				"ts":   1541152493202,
			},
			Timestamp: time.UnixMilli(1541152595202),
		},
		{
			Emitter: "sessionDemoE",
			Message: map[string]interface{}{
				"temp": 32.2,
				"hum":  99,
				"ts":   1541152499202,
			},
			Timestamp: time.UnixMilli(1541152599402),
		},
	},
	"demoErr": {
		{
			Emitter: "demoErr",
			Message: map[string]interface{}{
				"color": "red",
				"size":  3,
				"ts":    1541152486013,
			},
			Timestamp: time.UnixMilli(1541152486221),
		},
		{
			Emitter: "demoErr",
			Message: map[string]interface{}{
				"color": 2,
				"size":  5,
				"ts":    1541152487632,
			},
			Timestamp: time.UnixMilli(1541152487722),
		},
		{
			Emitter: "demoErr",
			Message: map[string]interface{}{
				"color": "red",
				"size":  1,
				"ts":    1541152489252,
			},
			Timestamp: time.UnixMilli(1541152489332),
		},
		{
			Emitter: "demoErr",
			Message: map[string]interface{}{
				"color": "blue",
				"size":  6,
				"ts":    1541152486822,
			},
			Timestamp: time.UnixMilli(1541152489822),
		},
		{
			Emitter: "demoErr",
			Message: map[string]interface{}{
				"color": "yellow",
				"size":  4,
				"ts":    1541152488442,
			},
			Timestamp: time.UnixMilli(1541152490042),
		},
		{
			Emitter: "demoErr",
			Message: map[string]interface{}{
				"color": "yellow",
				"size":  4,
				"ts":    1541152492342,
			},
			Timestamp: time.UnixMilli(1541152493842),
		},
	},
	"ldemo": {
		{
			Emitter: "ldemo",
			Message: map[string]interface{}{
				"color": "red",
				"size":  3,
				"ts":    1541152486013,
			},
			Timestamp: time.UnixMilli(1541152486013),
		},
		{
			Emitter: "ldemo",
			Message: map[string]interface{}{
				"color": "blue",
				"size":  "string",
				"ts":    1541152486822,
			},
			Timestamp: time.UnixMilli(1541152486822),
		},
		{
			Emitter: "ldemo",
			Message: map[string]interface{}{
				"size": 3,
				"ts":   1541152487632,
			},
			Timestamp: time.UnixMilli(1541152487632),
		},
		{
			Emitter: "ldemo",
			Message: map[string]interface{}{
				"color": 49,
				"size":  2,
				"ts":    1541152488442,
			},
			Timestamp: time.UnixMilli(1541152488442),
		},
		{
			Emitter: "ldemo",
			Message: map[string]interface{}{
				"color": "red",
				"ts":    1541152489252,
			},
			Timestamp: time.UnixMilli(1541152489252),
		},
	},
	"ldemo1": {
		{
			Emitter: "ldemo1",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  65,
				"ts":   1541152486013,
			},
			Timestamp: time.UnixMilli(1541152486013),
		},
		{
			Emitter: "ldemo1",
			Message: map[string]interface{}{
				"temp": 27.5,
				"hum":  59,
				"ts":   1541152486823,
			},
			Timestamp: time.UnixMilli(1541152486823),
		},
		{
			Emitter: "ldemo1",
			Message: map[string]interface{}{
				"temp": 28.1,
				"hum":  75,
				"ts":   1541152487632,
			},
			Timestamp: time.UnixMilli(1541152487632),
		},
		{
			Emitter: "ldemo1",
			Message: map[string]interface{}{
				"temp": 27.4,
				"hum":  80,
				"ts":   "1541152488442",
			},
			Timestamp: time.UnixMilli(1541152488442),
		},
		{
			Emitter: "ldemo1",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  62,
				"ts":   1541152489252,
			},
			Timestamp: time.UnixMilli(1541152489252),
		},
	},
	"lsessionDemo": {
		{
			Emitter: "lsessionDemo",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  65,
				"ts":   1541152486013,
			},
			Timestamp: time.UnixMilli(1541152486013),
		},
		{
			Emitter: "lsessionDemo",
			Message: map[string]interface{}{
				"temp": 27.5,
				"hum":  59,
				"ts":   1541152486823,
			},
			Timestamp: time.UnixMilli(1541152486823),
		},
		{
			Emitter: "lsessionDemo",
			Message: map[string]interface{}{
				"temp": 28.1,
				"hum":  75,
				"ts":   1541152487932,
			},
			Timestamp: time.UnixMilli(1541152487932),
		},
		{
			Emitter: "lsessionDemo",
			Message: map[string]interface{}{
				"temp": 27.4,
				"hum":  80,
				"ts":   1541152488442,
			},
			Timestamp: time.UnixMilli(1541152488442),
		},
		{
			Emitter: "lsessionDemo",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  62,
				"ts":   1541152489252,
			},
			Timestamp: time.UnixMilli(1541152489252),
		},
		{
			Emitter: "lsessionDemo",
			Message: map[string]interface{}{
				"temp": 26.2,
				"hum":  63,
				"ts":   1541152490062,
			},
			Timestamp: time.UnixMilli(1541152490062),
		},
		{
			Emitter: "lsessionDemo",
			Message: map[string]interface{}{
				"temp": 26.8,
				"hum":  71,
				"ts":   1541152490872,
			},
			Timestamp: time.UnixMilli(1541152490872),
		},
		{
			Emitter: "lsessionDemo",
			Message: map[string]interface{}{
				"temp": 28.9,
				"hum":  85,
				"ts":   1541152491682,
			},
			Timestamp: time.UnixMilli(1541152491682),
		},
		{
			Emitter: "lsessionDemo",
			Message: map[string]interface{}{
				"temp": 29.1,
				"hum":  92,
				"ts":   1541152492492,
			},
			Timestamp: time.UnixMilli(1541152492492),
		},
		{
			Emitter: "lsessionDemo",
			Message: map[string]interface{}{
				"temp": 2.2,
				"hum":  99,
				"ts":   1541152493202,
			},
			Timestamp: time.UnixMilli(1541152493202),
		},
		{
			Emitter: "lsessionDemo",
			Message: map[string]interface{}{
				"temp": 30.9,
				"hum":  87,
				"ts":   1541152494112,
			},
			Timestamp: time.UnixMilli(1541152494112),
		},
	},
	"text": {
		{
			Emitter: "text",
			Message: map[string]interface{}{
				"slogan": "Impossible is nothing",
				"brand":  "Adidas",
			},
			Timestamp: time.UnixMilli(1541152486500),
		},
		{
			Emitter: "text",
			Message: map[string]interface{}{
				"slogan": "Stronger than dirt",
				"brand":  "Ajax",
			},
			Timestamp: time.UnixMilli(1541152487400),
		},
		{
			Emitter: "text",
			Message: map[string]interface{}{
				"slogan": "Belong anywhere",
				"brand":  "Airbnb",
			},
			Timestamp: time.UnixMilli(1541152488300),
		},
		{
			Emitter: "text",
			Message: map[string]interface{}{
				"slogan": "I can'T believe I ate the whole thing",
				"brand":  "Alka Seltzer",
			},
			Timestamp: time.UnixMilli(1541152489200),
		},
		{
			Emitter: "text",
			Message: map[string]interface{}{
				"slogan": "You're in good hands",
				"brand":  "Allstate",
			},
			Timestamp: time.UnixMilli(1541152490100),
		},
		{
			Emitter: "text",
			Message: map[string]interface{}{
				"slogan": "Don'T leave home without it",
				"brand":  "American Express",
			},
			Timestamp: time.UnixMilli(1541152491200),
		},
		{
			Emitter: "text",
			Message: map[string]interface{}{
				"slogan": "Think different",
				"brand":  "Apple",
			},
			Timestamp: time.UnixMilli(1541152492300),
		},
		{
			Emitter: "text",
			Message: map[string]interface{}{
				"slogan": "We try harder",
				"brand":  "Avis",
			},
			Timestamp: time.UnixMilli(1541152493400),
		},
	},
	"binDemo": {
		{
			Emitter: "binDemo",
			Message: map[string]interface{}{
				"self": Image,
			},
			Timestamp: time.UnixMilli(1541152486013),
		},
	},
	"fakeBin": {
		{
			Emitter: "fakeBin",
			Message: map[string]interface{}{
				"self": []byte("golang"),
			},
			Timestamp: time.UnixMilli(1541152486013),
		},
		{
			Emitter: "fakeBin",
			Message: map[string]interface{}{
				"self": []byte("peacock"),
			},
			Timestamp: time.UnixMilli(1541152487013),
		},
		{
			Emitter: "fakeBin",
			Message: map[string]interface{}{
				"self": []byte("bullfrog"),
			},
			Timestamp: time.UnixMilli(1541152488013),
		},
	},
	"helloStr": {
		{
			Emitter: "helloStr",
			Message: map[string]interface{}{
				"name": "world",
			},
			Timestamp: time.UnixMilli(1541152486013),
		},
		{
			Emitter: "helloStr",
			Message: map[string]interface{}{
				"name": "golang",
			},
			Timestamp: time.UnixMilli(1541152487013),
		},
		{
			Emitter: "helloStr",
			Message: map[string]interface{}{
				"name": "peacock",
			},
			Timestamp: time.UnixMilli(1541152488013),
		},
	},
	"commands": {
		{
			Emitter: "commands",
			Message: map[string]interface{}{
				"cmd":          "get",
				"base64_img":   "my image",
				"encoded_json": "{\"name\": \"name1\",\"size\": 22}",
			},
			Timestamp: time.UnixMilli(1541152486013),
		},
		{
			Emitter: "commands",
			Message: map[string]interface{}{
				"cmd":          "detect",
				"base64_img":   "my image",
				"encoded_json": "{\"name\": \"name2\",\"size\": 33}",
			},
			Timestamp: time.UnixMilli(1541152487013),
		},
		{
			Emitter: "commands",
			Message: map[string]interface{}{
				"cmd":          "delete",
				"base64_img":   "my image",
				"encoded_json": "{\"name\": \"name3\",\"size\": 11}",
			},
			Timestamp: time.UnixMilli(1541152488013),
		},
	},
	"demoTable": {
		{
			Emitter: "demoTable",
			Message: map[string]interface{}{
				"ts":     1541152486013,
				"device": "device1",
			},
			Timestamp: time.UnixMilli(1541152486501),
		},
		{
			Emitter: "demoTable",
			Message: map[string]interface{}{
				"ts":     1541152486822,
				"device": "device2",
			},
			Timestamp: time.UnixMilli(1541152486502),
		},
		{
			Emitter: "demoTable",
			Message: map[string]interface{}{
				"ts":     1541152487632,
				"device": "device3",
			},
			Timestamp: time.UnixMilli(1541152488001),
		},
		{
			Emitter: "demoTable",
			Message: map[string]interface{}{
				"ts":     1541152488442,
				"device": "device4",
			},
			Timestamp: time.UnixMilli(1541152488002),
		},
		{
			Emitter: "demoTable",
			Message: map[string]interface{}{
				"ts":     1541152489252,
				"device": "device5",
			},
			Timestamp: time.UnixMilli(1541152488003),
		},
	},
	"shelves": {
		{
			Emitter: "shelves",
			Message: map[string]interface{}{
				"name": "name1",
				"size": 2,
				"shelf": map[string]interface{}{
					"id":       1541152486013,
					"theme":    "tandra",
					"subfield": "sub1",
				},
			},
			Timestamp: time.UnixMilli(1541152486501),
		},
		{
			Emitter: "shelves",
			Message: map[string]interface{}{
				"name": "name2",
				"size": 3,
				"shelf": map[string]interface{}{
					"id":       1541152486822,
					"theme":    "claro",
					"subfield": "sub2",
				},
			},
			Timestamp: time.UnixMilli(1541152486502),
		},
		{
			Emitter: "shelves",
			Message: map[string]interface{}{
				"name": "name3",
				"size": 4,
				"shelf": map[string]interface{}{
					"id":       1541152487632,
					"theme":    "dark",
					"subfield": "sub3",
				},
			},
			Timestamp: time.UnixMilli(1541152488001),
		},
	},
	"mes": {
		{
			Emitter: "mes",
			Message: map[string]interface{}{
				"message_id": "1541152486013",
				"text":       "message1",
			},
			Timestamp: time.UnixMilli(1541152486501),
		},
		{
			Emitter: "mes",
			Message: map[string]interface{}{
				"message_id": "1541152486501",
				"text":       "message2",
			},
			Timestamp: time.UnixMilli(1541152486501),
		},
		{
			Emitter: "mes",
			Message: map[string]interface{}{
				"message_id": "1541152487013",
				"text":       "message3",
			},
			Timestamp: time.UnixMilli(1541152487501),
		},
	},
	"demoArr": {
		{
			Emitter: "demoArr",
			Message: map[string]interface{}{
				"arr": []int{1, 2, 3, 4, 5},
				"x":   1,
				"y":   2,
				"arr2": []interface{}{
					map[string]interface{}{
						"a": 1,
						"b": 2,
					},
					map[string]interface{}{
						"a": 3,
						"b": 4,
					},
				},
				"a":    6,
				"arr3": []interface{}{1, 2, 3},
			},
			Timestamp: time.UnixMilli(1541152489253),
		},
	},
	"demoArr2": {
		{
			Emitter: "demoArr2",
			Message: map[string]interface{}{
				"arr": []interface{}{1, 2, 3, 4, 5},
				"x":   1,
			},
			Timestamp: time.UnixMilli(1541152489253),
		},
		{
			Emitter: "demoArr2",
			Message: map[string]interface{}{
				"arr": []interface{}{1, 2, 3, 4, 5},
				"x":   1,
			},
			Timestamp: time.UnixMilli(1541152489254),
		},
	},
	"demoE2": {
		{
			Emitter: "demoE2",
			Message: map[string]interface{}{
				"temp": 27.5,
				"hum":  59,
				"ts":   1541152486000,
			},
			Timestamp: time.UnixMilli(1541152486000),
		},
		{
			Emitter: "demoE2",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  65,
				"ts":   1541152487000,
			},
			Timestamp: time.UnixMilli(1541152487000),
		},
		{
			Emitter: "demoE2",
			Message: map[string]interface{}{
				"temp": 25.5,
				"hum":  65,
				"ts":   1541152488000,
			},
			Timestamp: time.UnixMilli(1541152488000),
		},
	},
	"demoE3": {
		{
			Emitter: "demoE3",
			Message: map[string]interface{}{
				"temp": 26.0,
				"ts":   1541152486000,
			},
			Timestamp: time.UnixMilli(1541152486000),
		},
		{
			Emitter: "demoE3",
			Message: map[string]interface{}{
				"temp": 27.0,
				"ts":   1541152487000,
			},
			Timestamp: time.UnixMilli(1541152487000),
		},
		{
			Emitter: "demoE3",
			Message: map[string]interface{}{
				"temp": 28.0,
				"ts":   1541152488000,
			},
			Timestamp: time.UnixMilli(1541152488000),
		},
		{
			Emitter: "demoE3",
			Message: map[string]interface{}{
				"temp": 28.5,
				"ts":   1541152488500,
			},
			Timestamp: time.UnixMilli(1541152488500),
		},
		{
			Emitter: "demoE3",
			Message: map[string]interface{}{
				"temp": 29.0,
				"ts":   1541152489000,
			},
			Timestamp: time.UnixMilli(1541152488500),
		},
		{
			Emitter: "demoE3",
			Message: map[string]interface{}{
				"temp": 29.5,
				"ts":   1541152489500,
			},
			Timestamp: time.UnixMilli(1541152489500),
		},
	},
	"optional_commands": {
		{
			Emitter: "optional_commands",
			Message: map[string]interface{}{
				"base64_img": "my image1",
			},
			Timestamp: time.UnixMilli(1541152486013),
		},
		{
			Emitter: "optional_commands",
			Message: map[string]interface{}{
				"base64_img": "my image2",
			},
			Timestamp: time.UnixMilli(1541152487013),
		},
		{
			Emitter: "optional_commands",
			Message: map[string]interface{}{
				"base64_img": "my image3",
			},
			Timestamp: time.UnixMilli(1541152488013),
		},
	},
	"schemaless_commands": {
		{
			Emitter: "schemaless_commands",
			Message: map[string]interface{}{
				"cmd":          "get",
				"base64_img":   "my image",
				"encoded_json": map[string]interface{}{"name": "name1", "size": 22},
			},
			Timestamp: time.UnixMilli(1541152486013),
		},
		{
			Emitter: "schemaless_commands",
			Message: map[string]interface{}{
				"cmd":          "detect",
				"base64_img":   "my image",
				"encoded_json": map[string]interface{}{"name": "name2", "size": 33},
			},
			Timestamp: time.UnixMilli(1541152487013),
		},
		{
			Emitter: "schemaless_commands",
			Message: map[string]interface{}{
				"cmd":          "delete",
				"base64_img":   "my image",
				"encoded_json": map[string]interface{}{"name": "name3", "size": 11},
			},
			Timestamp: time.UnixMilli(1541152488013),
		},
	},
}

TestData The time diff must larger than timeleap

Functions

func GetImg 

func GetImg() ([]byte, string)

Types

type MockSource 

type MockSource struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*MockSource) Close 

func (m *MockSource) Close(_ api.StreamContext) error

func (*MockSource) Connect 

func (m *MockSource) Connect(_ api.StreamContext, _ api.StatusChangeHandler) error

func (*MockSource) GetOffset 

func (m *MockSource) GetOffset() (interface{}, error)

func (*MockSource) Provision 

func (m *MockSource) Provision(ctx api.StreamContext, configs map[string]any) error

func (*MockSource) ResetOffset 

func (m *MockSource) ResetOffset(input map[string]interface{}) error

func (*MockSource) Rewind 

func (m *MockSource) Rewind(offset interface{}) error

func (*MockSource) SetEofIngest 

func (m *MockSource) SetEofIngest(eof api.EOFIngest)

func (*MockSource) Subscribe 

func (m *MockSource) Subscribe(ctx api.StreamContext, ingest api.TupleIngest, ingestError api.ErrorIngest) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.