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
|
package logger
import (
"errors"
"io"
)
type client interface {
Call(string, interface{}, interface{}) error
Stream(string, interface{}) (io.ReadCloser, error)
}
type logPluginProxy struct {
client
}
type logPluginProxyStartLoggingRequest struct {
File string
Info Info
}
type logPluginProxyStartLoggingResponse struct {
Err string
}
func (pp *logPluginProxy) StartLogging(file string, info Info) (err error) {
var (
req logPluginProxyStartLoggingRequest
ret logPluginProxyStartLoggingResponse
)
req.File = file
req.Info = info
if err = pp.Call("LogDriver.StartLogging", req, &ret); err != nil {
return err
}
if ret.Err != "" {
return errors.New(ret.Err)
}
return nil
}
type logPluginProxyStopLoggingRequest struct {
File string
}
type logPluginProxyStopLoggingResponse struct {
Err string
}
func (pp *logPluginProxy) StopLogging(file string) (err error) {
var (
req logPluginProxyStopLoggingRequest
ret logPluginProxyStopLoggingResponse
)
req.File = file
if err = pp.Call("LogDriver.StopLogging", req, &ret); err != nil {
return err
}
if ret.Err != "" {
return errors.New(ret.Err)
}
return nil
}
type logPluginProxyCapabilitiesResponse struct {
Cap Capability
Err string
}
func (pp *logPluginProxy) Capabilities() (Capability, error) {
var ret logPluginProxyCapabilitiesResponse
if err := pp.Call("LogDriver.Capabilities", nil, &ret); err != nil {
return Capability{}, err
}
if ret.Err != "" {
return Capability{}, errors.New(ret.Err)
}
return ret.Cap, nil
}
type logPluginProxyReadLogsRequest struct {
Info Info
Config ReadConfig
}
func (pp *logPluginProxy) ReadLogs(info Info, config ReadConfig) (stream io.ReadCloser, _ error) {
return pp.Stream("LogDriver.ReadLogs", logPluginProxyReadLogsRequest{
Info: info,
Config: config,
})
}
|
