forked from redpanda-data/connect
-
Notifications
You must be signed in to change notification settings - Fork 0
/
.errcheck.txt
158 lines (158 loc) · 7.56 KB
/
.errcheck.txt
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
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
(*archive/tar.Writer).Close
(*archive/zip.Writer).Close
(*bytes.Buffer).ReadFrom
(*bytes.Buffer).WriteTo
(*cloud.google.com/go/pubsub.Client).Close
(*cloud.google.com/go/storage.Client).Close
(*compress/flate.Writer).Close
(*compress/flate.Writer).Write
(*compress/gzip.Reader).Close
(*compress/gzip.Writer).Close
(*compress/gzip.Writer).Write
(*compress/zlib.Writer).Close
(*compress/zlib.Writer).Write
(*database/sql.DB).Close
(*database/sql.Rows).Close
(*database/sql.Stmt).Close
(*flag.FlagSet).Parse
(*github.com/Azure/go-amqp.Client).Close
(*github.com/Azure/go-amqp.Sender).Close
(*github.com/Azure/go-amqp.Session).Close
(*github.com/Jeffail/benthos/v3/internal/batch.Error).Failed
(*github.com/Jeffail/benthos/v3/internal/bundle.BufferSet).Add
(*github.com/Jeffail/benthos/v3/internal/bundle.CacheSet).Add
(*github.com/Jeffail/benthos/v3/internal/bundle.InputSet).Add
(*github.com/Jeffail/benthos/v3/internal/bundle.OutputSet).Add
(*github.com/Jeffail/benthos/v3/internal/bundle.ProcessorSet).Add
(*github.com/Jeffail/benthos/v3/internal/bundle.RateLimitSet).Add
(*github.com/Jeffail/benthos/v3/internal/component/output.MetadataFilter).Iter
(*github.com/Jeffail/benthos/v3/internal/impl/pulsar.pulsarReader).disconnect
(*github.com/Jeffail/benthos/v3/internal/impl/pulsar.pulsarWriter).disconnect
(*github.com/Jeffail/benthos/v3/internal/transaction.Tracked).Ack
(*github.com/Jeffail/benthos/v3/lib/api.Type).Shutdown
(*github.com/Jeffail/benthos/v3/lib/broker.FanIn).WaitForClose
(*github.com/Jeffail/benthos/v3/lib/buffer/parallel.Memory).PushMessage
(*github.com/Jeffail/benthos/v3/lib/buffer/single.MmapCache).Delete
(*github.com/Jeffail/benthos/v3/lib/buffer/single.MmapCache).Remove
(*github.com/Jeffail/benthos/v3/lib/buffer/single.MmapCache).RemoveAll
(*github.com/Jeffail/benthos/v3/lib/input/reader.AMQP).disconnect
(*github.com/Jeffail/benthos/v3/lib/input/reader.AMQP09).disconnect
(*github.com/Jeffail/benthos/v3/lib/input/reader.AMQP1).disconnect
(*github.com/Jeffail/benthos/v3/lib/input/reader.Kafka).commit
(*github.com/Jeffail/benthos/v3/lib/input/reader.Kinesis).commit
(*github.com/Jeffail/benthos/v3/lib/input/reader.NSQ).disconnect
(*github.com/Jeffail/benthos/v3/lib/input/reader.Preserver).Acknowledge
(*github.com/Jeffail/benthos/v3/lib/input/reader.RedisList).disconnect
(*github.com/Jeffail/benthos/v3/lib/input/reader.RedisPubSub).disconnect
(*github.com/Jeffail/benthos/v3/lib/input/reader.RedisStreams).disconnect
(*github.com/Jeffail/benthos/v3/lib/message.Part).SetJSON
(*github.com/Jeffail/benthos/v3/lib/message.Type).Iter
(*github.com/Jeffail/benthos/v3/lib/message/metadata.Type).Iter
(*github.com/Jeffail/benthos/v3/lib/metrics.CloudWatch).flush
(*github.com/Jeffail/benthos/v3/lib/output.MockOutputType).Consume
(*github.com/Jeffail/benthos/v3/lib/output/writer.AMQP).disconnect
(*github.com/Jeffail/benthos/v3/lib/output/writer.AMQP1).disconnect
(*github.com/Jeffail/benthos/v3/lib/output/writer.RedisHash).disconnect
(*github.com/Jeffail/benthos/v3/lib/output/writer.RedisList).disconnect
(*github.com/Jeffail/benthos/v3/lib/output/writer.RedisPubSub).disconnect
(*github.com/Jeffail/benthos/v3/lib/output/writer.RedisStreams).disconnect
(*github.com/Jeffail/benthos/v3/lib/processor.subprocWrapper).start
(*github.com/Jeffail/benthos/v3/lib/processor.subprocWrapper).stop
(*github.com/Jeffail/benthos/v3/lib/stream.Type).Stop
(*github.com/Jeffail/benthos/v3/lib/util.ClosablePool).Close
(*github.com/Jeffail/benthos/v3/public/bloblang.Environment).RegisterFunction
(*github.com/Jeffail/benthos/v3/public/bloblang.Environment).RegisterMethod
(*github.com/Jeffail/gabs/v2.Container).ArrayAppendP
(*github.com/Jeffail/gabs/v2.Container).ArrayOfSize
(*github.com/Jeffail/gabs/v2.Container).Delete
(*github.com/Jeffail/gabs/v2.Container).DeleteP
(*github.com/Jeffail/gabs/v2.Container).Merge
(*github.com/Jeffail/gabs/v2.Container).Set
(*github.com/Jeffail/gabs/v2.Container).SetIndex
(*github.com/Jeffail/gabs/v2.Container).SetP
(*github.com/OneOfOne/xxhash.XXHash64).Write
(*github.com/OneOfOne/xxhash.XXHash64).WriteString
(*github.com/Shopify/sarama.Broker).Close
(*github.com/aws/aws-sdk-go/service/dynamodb.DynamoDB).CreateTable
(*github.com/aws/aws-sdk-go/service/sqs.SQS).ChangeMessageVisibilityBatch
(*github.com/colinmarc/hdfs.Client).Remove
(*github.com/colinmarc/hdfs.FileWriter).Close
(*github.com/edsrzf/mmap-go.MMap).Unmap
(*github.com/go-redis/redis/v7.baseClient).Close
(*github.com/gocql/gocql.Query).Exec
(*github.com/gorilla/websocket.Conn).Close
(*github.com/nats-io/nats.go.Subscription).Unsubscribe
(*github.com/nats-io/stan.go.Msg).Ack
(*github.com/ory/dockertest/v3.Pool).RemoveNetwork
(*github.com/ory/dockertest/v3.Resource).Expire
(*github.com/pkg/sftp.File).Close
(*github.com/pkg/sftp.clientConn).Close
(*github.com/smira/go-statsd.Client).Close
(*github.com/streadway/amqp.Channel).Close
(*github.com/streadway/amqp.Connection).Close
(*github.com/urfave/cli/v2.App).Run
(*go.mongodb.org/mongo-driver/mongo.Client).Disconnect
(*mime/multipart.Writer).Close
(*net.TCPListener).Close
(*net/http.Server).Shutdown
(*os.File).Close
(*os.File).Write
(*runtime/pprof.Profile).WriteTo
(github.com/Jeffail/benthos/v3/internal/codec.Reader).Close
(github.com/Jeffail/benthos/v3/internal/codec.Writer).Close
(github.com/Jeffail/benthos/v3/internal/codec.Writer).EndBatch
(github.com/Jeffail/benthos/v3/lib/buffer.Single).ShiftMessage
(github.com/Jeffail/benthos/v3/lib/metrics.Flat).Decr
(github.com/Jeffail/benthos/v3/lib/metrics.Flat).Gauge
(github.com/Jeffail/benthos/v3/lib/metrics.Flat).Incr
(github.com/Jeffail/benthos/v3/lib/metrics.Flat).Timing
(github.com/Jeffail/benthos/v3/lib/metrics.StatCounter).Incr
(github.com/Jeffail/benthos/v3/lib/metrics.StatGauge).Decr
(github.com/Jeffail/benthos/v3/lib/metrics.StatGauge).Incr
(github.com/Jeffail/benthos/v3/lib/metrics.StatGauge).Set
(github.com/Jeffail/benthos/v3/lib/metrics.StatTimer).Timing
(github.com/Jeffail/benthos/v3/lib/metrics.Type).Close
(github.com/Jeffail/benthos/v3/lib/processor.hasher).Write
(github.com/Jeffail/benthos/v3/lib/tracer.Type).Close
(github.com/Jeffail/benthos/v3/lib/types.Cache).Set
(github.com/Jeffail/benthos/v3/lib/types.Closable).WaitForClose
(github.com/Jeffail/benthos/v3/lib/types.Consumer).Consume
(github.com/Jeffail/benthos/v3/lib/types.Message).Iter
(github.com/Jeffail/benthos/v3/lib/types.Metadata).Iter
(github.com/Jeffail/benthos/v3/lib/types.OutputWriter).WriteTransaction
(github.com/Jeffail/benthos/v3/lib/types.Part).JSON
(github.com/Jeffail/benthos/v3/lib/types.Part).SetJSON
(github.com/Shopify/sarama.Client).Close
(github.com/Shopify/sarama.Consumer).Close
(github.com/Shopify/sarama.ConsumerGroup).Close
(github.com/Shopify/sarama.SyncProducer).Close
(github.com/edsrzf/mmap-go.MMap).Flush
(github.com/go-redis/redis/v7.UniversalClient).Close
(github.com/influxdata/influxdb1-client/v2.Client).Close
(github.com/nats-io/stan.go.Conn).Close
(github.com/nats-io/stan.go.Subscription).Unsubscribe
(github.com/quipo/statsd.Statsd).Close
(github.com/quipo/statsd.Statsd).Decr
(github.com/quipo/statsd.Statsd).Gauge
(github.com/quipo/statsd.Statsd).Incr
(github.com/quipo/statsd.Statsd).Timing
(go.nanomsg.org/mangos/v3.Socket).Close
(golang.org/x/crypto/ssh.Conn).Close
(io.Closer).Close
(io.Writer).Write
(net.Conn).Close
(net.Conn).SetReadDeadline
(net.Conn).SetWriteDeadline
(net.Listener).Close
(net.PacketConn).Close
(net.PacketConn).SetReadDeadline
(net/http.ResponseWriter).Write
fmt.Fprintf
github.com/Jeffail/benthos/v3/lib/broker.ComplementGenericConfig
github.com/Jeffail/benthos/v3/lib/message/roundtrip.SetAsResponse
github.com/urfave/cli/v2.ShowAppHelp
internal/docs.SanitiseComponentConfig
lib/test/integration.sendBatch
os.Setenv
os.Unsetenv
syscall.Statfs