forked from h2oai/wave
-
Notifications
You must be signed in to change notification settings - Fork 0
/
protocol.go
92 lines (80 loc) · 3.07 KB
/
protocol.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
// Copyright 2020 H2O.ai, Inc.
//
// 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.
package wave
// OpsD represents the set of changes to be applied to a Page. This is a discriminated union.
type OpsD struct {
P *PageD `json:"p,omitempty"` // page
C map[string]interface{} `json:"c,omitempty"` // FIXME comment - is this required?
D []OpD `json:"d,omitempty"` // deltas
R int `json:"r,omitempty"` // reset
}
// OpD represents a delta operation (effector)
// Discriminated union; valid combos: K, set:KV|KC|KF|KM, put:KD|KDB
type OpD struct {
K string `json:"k,omitempty"` // key; ""=drop page
V interface{} `json:"v,omitempty"` // value
C *CycBufD `json:"c,omitempty"` // value
F *FixBufD `json:"f,omitempty"` // value
M *MapBufD `json:"m,omitempty"` // value
D map[string]interface{} `json:"d,omitempty"` // card data
B []BufD `json:"b,omitempty"` // card buffers
}
// PageD represents the marshaled data for a Page.
type PageD struct {
C map[string]CardD `json:"c"` // cards
}
// CardD represents the marshaled data for a Card.
type CardD struct {
D map[string]interface{} `json:"d"` // data
B []BufD `json:"b,omitempty"` // buffers
}
// BufD represents the marshaled data for a buffer. This is a discriminated union.
type BufD struct {
C *CycBufD `json:"c,omitempty"`
F *FixBufD `json:"f,omitempty"`
M *MapBufD `json:"m,omitempty"`
}
// MapBufD represents the marshaled data for a MapBuf.
type MapBufD struct {
F []string `json:"f"` // fields
D map[string][]interface{} `json:"d"` // tuples
}
// FixBufD represents the marshaled data for a FixBuf.
type FixBufD struct {
F []string `json:"f"` // fields
D [][]interface{} `json:"d"` // tuples
N int `json:"n"` // size
}
// CycBufD represents the marshaled data for a CycBuf.
type CycBufD struct {
F []string `json:"f"` // fields
D [][]interface{} `json:"d"` // tuples
N int `json:"n"` // size
I int `json:"i"` // index
}
// AppRequest represents a request from an app.
type AppRequest struct {
RegisterApp *RegisterApp `json:"register_app,omitempty"`
UnregisterApp *UnregisterApp `json:"unregister_app,omitempty"`
}
// RegisterApp represents a request to register an app.
type RegisterApp struct {
Mode string `json:"mode"`
Route string `json:"route"`
Address string `json:"address"`
}
// UnregisterApp represents a request to unregister an app.
type UnregisterApp struct {
Route string `json:"route"`
}