-
Notifications
You must be signed in to change notification settings - Fork 1.2k
/
stream_ui.go
131 lines (118 loc) · 3.51 KB
/
stream_ui.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
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
// Auto-generated to Go types and interfaces using avdl-compiler v1.4.10 (https://github.com/keybase/node-avdl-compiler)
// Input file: avdl/keybase1/stream_ui.avdl
package keybase1
import (
"github.com/keybase/go-framed-msgpack-rpc/rpc"
context "golang.org/x/net/context"
"time"
)
type CloseArg struct {
SessionID int `codec:"sessionID" json:"sessionID"`
S Stream `codec:"s" json:"s"`
}
type ReadArg struct {
SessionID int `codec:"sessionID" json:"sessionID"`
S Stream `codec:"s" json:"s"`
Sz int `codec:"sz" json:"sz"`
}
type ResetArg struct {
SessionID int `codec:"sessionID" json:"sessionID"`
S Stream `codec:"s" json:"s"`
}
type WriteArg struct {
SessionID int `codec:"sessionID" json:"sessionID"`
S Stream `codec:"s" json:"s"`
Buf []byte `codec:"buf" json:"buf"`
}
type StreamUiInterface interface {
Close(context.Context, CloseArg) error
Read(context.Context, ReadArg) ([]byte, error)
Reset(context.Context, ResetArg) error
Write(context.Context, WriteArg) (int, error)
}
func StreamUiProtocol(i StreamUiInterface) rpc.Protocol {
return rpc.Protocol{
Name: "keybase.1.streamUi",
Methods: map[string]rpc.ServeHandlerDescription{
"close": {
MakeArg: func() interface{} {
var ret [1]CloseArg
return &ret
},
Handler: func(ctx context.Context, args interface{}) (ret interface{}, err error) {
typedArgs, ok := args.(*[1]CloseArg)
if !ok {
err = rpc.NewTypeError((*[1]CloseArg)(nil), args)
return
}
err = i.Close(ctx, typedArgs[0])
return
},
},
"read": {
MakeArg: func() interface{} {
var ret [1]ReadArg
return &ret
},
Handler: func(ctx context.Context, args interface{}) (ret interface{}, err error) {
typedArgs, ok := args.(*[1]ReadArg)
if !ok {
err = rpc.NewTypeError((*[1]ReadArg)(nil), args)
return
}
ret, err = i.Read(ctx, typedArgs[0])
return
},
},
"reset": {
MakeArg: func() interface{} {
var ret [1]ResetArg
return &ret
},
Handler: func(ctx context.Context, args interface{}) (ret interface{}, err error) {
typedArgs, ok := args.(*[1]ResetArg)
if !ok {
err = rpc.NewTypeError((*[1]ResetArg)(nil), args)
return
}
err = i.Reset(ctx, typedArgs[0])
return
},
},
"write": {
MakeArg: func() interface{} {
var ret [1]WriteArg
return &ret
},
Handler: func(ctx context.Context, args interface{}) (ret interface{}, err error) {
typedArgs, ok := args.(*[1]WriteArg)
if !ok {
err = rpc.NewTypeError((*[1]WriteArg)(nil), args)
return
}
ret, err = i.Write(ctx, typedArgs[0])
return
},
},
},
}
}
type StreamUiClient struct {
Cli rpc.GenericClient
}
func (c StreamUiClient) Close(ctx context.Context, __arg CloseArg) (err error) {
err = c.Cli.Call(ctx, "keybase.1.streamUi.close", []interface{}{__arg}, nil, 0*time.Millisecond)
return
}
func (c StreamUiClient) Read(ctx context.Context, __arg ReadArg) (res []byte, err error) {
err = c.Cli.Call(ctx, "keybase.1.streamUi.read", []interface{}{__arg}, &res, 0*time.Millisecond)
return
}
func (c StreamUiClient) Reset(ctx context.Context, __arg ResetArg) (err error) {
err = c.Cli.Call(ctx, "keybase.1.streamUi.reset", []interface{}{__arg}, nil, 0*time.Millisecond)
return
}
func (c StreamUiClient) Write(ctx context.Context, __arg WriteArg) (res int, err error) {
err = c.Cli.Call(ctx, "keybase.1.streamUi.write", []interface{}{__arg}, &res, 0*time.Millisecond)
return
}