| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/rabbitpubsub/ |
| H A D | fake_test.go | 39 type fakeChannel struct { struct
79 return &fakeChannel{
96 func (ch *fakeChannel) getExchange(name string) (*exchange, error) { argument
112 func (ch *fakeChannel) isClosed() bool { argument
118 func (ch *fakeChannel) ExchangeDeclare(name string) error { argument
277 func (ch *fakeChannel) Ack(tag uint64) error { argument
295 func (ch *fakeChannel) Nack(tag uint64) error { argument
313 func (ch *fakeChannel) Cancel(consumerName string) error { argument
358 func (ch *fakeChannel) Close() error { argument
376 func (ch *fakeChannel) ExchangeDelete(name string) error { argument
[all …]
|
| /dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/pubsub/rabbitpubsub/ |
| H A D | fake_test.go | 39 type fakeChannel struct { struct
79 return &fakeChannel{
96 func (ch *fakeChannel) getExchange(name string) (*exchange, error) { argument
112 func (ch *fakeChannel) isClosed() bool { argument
118 func (ch *fakeChannel) ExchangeDeclare(name string) error { argument
277 func (ch *fakeChannel) Ack(tag uint64) error { argument
295 func (ch *fakeChannel) Nack(tag uint64) error { argument
313 func (ch *fakeChannel) Cancel(consumerName string) error { argument
358 func (ch *fakeChannel) Close() error { argument
376 func (ch *fakeChannel) ExchangeDelete(name string) error { argument
[all …]
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/rabbitpubsub/ |
| H A D | fake_test.go | 39 type fakeChannel struct { struct
79 return &fakeChannel{
96 func (ch *fakeChannel) getExchange(name string) (*exchange, error) { argument
112 func (ch *fakeChannel) isClosed() bool { argument
118 func (ch *fakeChannel) ExchangeDeclare(name string) error { argument
277 func (ch *fakeChannel) Ack(tag uint64) error { argument
295 func (ch *fakeChannel) Nack(tag uint64) error { argument
313 func (ch *fakeChannel) Cancel(consumerName string) error { argument
358 func (ch *fakeChannel) Close() error { argument
376 func (ch *fakeChannel) ExchangeDelete(name string) error { argument
[all …]
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/rabbitpubsub/ |
| H A D | fake_test.go | 39 type fakeChannel struct { struct
79 return &fakeChannel{
96 func (ch *fakeChannel) getExchange(name string) (*exchange, error) { argument
112 func (ch *fakeChannel) isClosed() bool { argument
118 func (ch *fakeChannel) ExchangeDeclare(name string) error { argument
277 func (ch *fakeChannel) Ack(tag uint64) error { argument
295 func (ch *fakeChannel) Nack(tag uint64) error { argument
313 func (ch *fakeChannel) Cancel(consumerName string) error { argument
358 func (ch *fakeChannel) Close() error { argument
376 func (ch *fakeChannel) ExchangeDelete(name string) error { argument
[all …]
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/internal/sshd/ |
| H A D | session_test.go | 17 type fakeChannel struct { struct
23 func (f *fakeChannel) Read(data []byte) (int, error) { argument
27 func (f *fakeChannel) Write(data []byte) (int, error) { argument
31 func (f *fakeChannel) Close() error { argument
35 func (f *fakeChannel) CloseWrite() error { argument
39 func (f *fakeChannel) SendRequest(name string, wantReply bool, payload []byte) (bool, error) { argument
46 func (f *fakeChannel) Stderr() io.ReadWriter { argument
122 f := &fakeChannel{stdErr: out}
180 channel: &fakeChannel{stdErr: out},
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/ |
| H A D | secure_channel_test.go | 12 type fakeChannel struct { struct
16 func (fc *fakeChannel) Send(cmd *apdu.Command) (*apdu.Response, error) { argument
22 c := &fakeChannel{}
|
| /dports/multimedia/kaffeine/kaffeine-2.0.18/src/dvb/ |
| H A D | dvbepg.cpp | 997 DvbChannel fakeChannel; in processSection() local
998 fakeChannel.source = source; in processSection()
999 fakeChannel.transponder = transponder; in processSection()
1000 fakeChannel.networkId = eitSection.originalNetworkId(); in processSection()
1002 fakeChannel.serviceId = eitSection.serviceId(); in processSection()
1006 fakeChannel.networkId = -1; in processSection()
1007 channel = channelModel->findChannelById(fakeChannel); in processSection()
1245 DvbChannel fakeChannel; in processEitSection() local
1246 fakeChannel.source = source; in processEitSection()
1247 fakeChannel.transponder = transponder; in processEitSection()
[all …]
|
| /dports/databases/opentsdb/opentsdb-2.3.0/test/tsd/ |
| H A D | NettyMocks.java | 67 public static Channel fakeChannel() { in fakeChannel() method in NettyMocks
90 final Channel channelMock = NettyMocks.fakeChannel(); in getQuery()
195 final Channel channelMock = NettyMocks.fakeChannel(); in contentQuery()
|
| H A D | TestHttpQuery.java | 91 final Channel channelMock = NettyMocks.fakeChannel(); in getQueryString()
422 final Channel channelMock = NettyMocks.fakeChannel(); in getCharsetDefault()
438 final Channel channelMock = NettyMocks.fakeChannel(); in getCharsetSupplied()
448 final Channel channelMock = NettyMocks.fakeChannel(); in getCharsetInvalid()
476 final Channel channelMock = NettyMocks.fakeChannel(); in getContentEncoding()
489 final Channel channelMock = NettyMocks.fakeChannel(); in getContentDefault()
501 final Channel channelMock = NettyMocks.fakeChannel(); in getContentBadEncoding()
530 final Channel channelMock = NettyMocks.fakeChannel(); in getAPIMethodPut()
539 final Channel channelMock = NettyMocks.fakeChannel(); in getAPIMethodDelete()
734 final Channel channelMock = NettyMocks.fakeChannel(); in setSerializerCT()
[all …]
|
| H A D | TestPutRpc.java | 134 final Channel chan = NettyMocks.fakeChannel(); in execute()
147 final Channel chan = NettyMocks.fakeChannel(); in executeBadValue()
160 final Channel chan = NettyMocks.fakeChannel(); in executeMissingMetric()
174 final Channel chan = NettyMocks.fakeChannel(); in executeMissingMetricNotWriteable()
190 final Channel chan = NettyMocks.fakeChannel(); in executeUnknownMetric()
209 final Channel chan = NettyMocks.fakeChannel(); in executeRuntimeException()
222 final Channel chan = NettyMocks.fakeChannel(); in executeHBaseError()
242 final Channel chan = NettyMocks.fakeChannel(); in executeHBaseErrorNotWriteable()
264 final Channel chan = NettyMocks.fakeChannel(); in executeHBaseErrorHandler()
281 final Channel chan = NettyMocks.fakeChannel(); in executeNullTSDB()
[all …]
|
| H A D | TestRpcHandler.java | 330 final Channel mockChan = NettyMocks.fakeChannel(); in createQueryInstanceForBuiltin()
361 final Channel mockChan = NettyMocks.fakeChannel(); in createQueryInstanceEmptyRequestInvalid()
392 final Channel channel = NettyMocks.fakeChannel(); in handleHttpRpc()
|
| H A D | TestHttpRpcPluginQuery.java | 41 mockChannel = NettyMocks.fakeChannel(); in before()
|
| H A D | TestTreeRpc.java | 147 final HttpQuery query = new HttpQuery(tsdb, req, NettyMocks.fakeChannel()); in handleTreeBadMethod()
436 final HttpQuery query = new HttpQuery(tsdb, req, NettyMocks.fakeChannel()); in handleBranchBadMethod()
658 final HttpQuery query = new HttpQuery(tsdb, req, NettyMocks.fakeChannel()); in handleRuleBadMethod()
917 final HttpQuery query = new HttpQuery(tsdb, req, NettyMocks.fakeChannel()); in handleTestBadMethod()
1029 final HttpQuery query = new HttpQuery(tsdb, req, NettyMocks.fakeChannel()); in handleCollissionsBadMethod()
1141 final HttpQuery query = new HttpQuery(tsdb, req, NettyMocks.fakeChannel()); in handleNotMatchedBadMethod()
|
| H A D | TestSuggestRpc.java | 138 final Channel channelMock = NettyMocks.fakeChannel(); in badMethod()
|
| H A D | TestAnnotationRpc.java | 110 final Channel channelMock = NettyMocks.fakeChannel(); in badMethod()
|
| H A D | TestSearchRpc.java | 193 final HttpQuery query = new HttpQuery(tsdb, req, NettyMocks.fakeChannel()); in searchBadMethod()
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/store/localcachelayer/ |
| H A D | channel_layer_test.go | 253 fakeChannel := model.Channel{Id: channelId}
262 assert.Equal(t, channel, &fakeChannel)
266 assert.Equal(t, channel, &fakeChannel)
|