| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/executors/kubernetes/ |
| H A D | log_processor.go | 19 type logStreamer interface { interface
78 logStreamer logStreamer member
98 logStreamer := &kubernetesLogStreamer{
108 logStreamer: logStreamer,
141 l.logStreamer,
188 err := l.logStreamer.Stream(logsOffset, writer)
196 err = fmt.Errorf("streaming logs %s: %w", l.logStreamer, err)
207 err = fmt.Errorf("reading logs %s: %w", l.logStreamer, err)
|
| H A D | log_processor_test.go | 76 require.NotNil(t, p.logStreamer)
78 k, ok := p.logStreamer.(*kubernetesLogStreamer)
83 assert.Equal(t, "namespace/pod/container:logPath", p.logStreamer.String())
269 processor.logStreamer = mockLogStreamer
331 processor.logStreamer = mockLogStreamer
364 processor.logStreamer = mockLogStreamer
399 processor.logStreamer = mockLogStreamer
470 processor.logStreamer = mockLogStreamer
|
| H A D | kubernetes_test.go | 3506 s, ok := p.logStreamer.(*kubernetesLogStreamer)
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/serf/serf-0.7.0/command/agent/ |
| H A D | ipc.go | 258 logStreamer *logStream member
414 if client.logStreamer != nil {
415 i.logWriter.DeregisterHandler(client.logStreamer)
416 client.logStreamer.Stop()
877 if client.logStreamer != nil {
883 client.logStreamer = newLogStream(client, filter, seq, i.logger)
887 defer i.logWriter.RegisterHandler(client.logStreamer)
900 if client.logStreamer != nil && client.logStreamer.seq == req.Stop {
901 i.logWriter.DeregisterHandler(client.logStreamer)
902 client.logStreamer.Stop()
[all …]
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/hashicorp/serf/command/agent/ |
| H A D | ipc.go | 258 logStreamer *logStream member
414 if client.logStreamer != nil {
415 i.logWriter.DeregisterHandler(client.logStreamer)
416 client.logStreamer.Stop()
877 if client.logStreamer != nil {
883 client.logStreamer = newLogStream(client, filter, seq, i.logger)
887 defer i.logWriter.RegisterHandler(client.logStreamer)
900 if client.logStreamer != nil && client.logStreamer.seq == req.Stop {
901 i.logWriter.DeregisterHandler(client.logStreamer)
902 client.logStreamer.Stop()
[all …]
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc.go | 261 logStreamer *logStream member
417 if client.logStreamer != nil {
418 i.logWriter.DeregisterHandler(client.logStreamer)
419 client.logStreamer.Stop()
885 if client.logStreamer != nil {
891 client.logStreamer = newLogStream(client, filter, seq, i.logger)
895 defer i.logWriter.RegisterHandler(client.logStreamer)
908 if client.logStreamer != nil && client.logStreamer.seq == req.Stop {
909 i.logWriter.DeregisterHandler(client.logStreamer)
910 client.logStreamer.Stop()
[all …]
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc.go | 261 logStreamer *logStream member
417 if client.logStreamer != nil {
418 i.logWriter.DeregisterHandler(client.logStreamer)
419 client.logStreamer.Stop()
885 if client.logStreamer != nil {
891 client.logStreamer = newLogStream(client, filter, seq, i.logger)
895 defer i.logWriter.RegisterHandler(client.logStreamer)
908 if client.logStreamer != nil && client.logStreamer.seq == req.Stop {
909 i.logWriter.DeregisterHandler(client.logStreamer)
910 client.logStreamer.Stop()
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc.go | 261 logStreamer *logStream member
417 if client.logStreamer != nil {
418 i.logWriter.DeregisterHandler(client.logStreamer)
419 client.logStreamer.Stop()
885 if client.logStreamer != nil {
891 client.logStreamer = newLogStream(client, filter, seq, i.logger)
895 defer i.logWriter.RegisterHandler(client.logStreamer)
908 if client.logStreamer != nil && client.logStreamer.seq == req.Stop {
909 i.logWriter.DeregisterHandler(client.logStreamer)
910 client.logStreamer.Stop()
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc.go | 261 logStreamer *logStream member
417 if client.logStreamer != nil {
418 i.logWriter.DeregisterHandler(client.logStreamer)
419 client.logStreamer.Stop()
885 if client.logStreamer != nil {
891 client.logStreamer = newLogStream(client, filter, seq, i.logger)
895 defer i.logWriter.RegisterHandler(client.logStreamer)
908 if client.logStreamer != nil && client.logStreamer.seq == req.Stop {
909 i.logWriter.DeregisterHandler(client.logStreamer)
910 client.logStreamer.Stop()
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc.go | 261 logStreamer *logStream member
417 if client.logStreamer != nil {
418 i.logWriter.DeregisterHandler(client.logStreamer)
419 client.logStreamer.Stop()
885 if client.logStreamer != nil {
891 client.logStreamer = newLogStream(client, filter, seq, i.logger)
895 defer i.logWriter.RegisterHandler(client.logStreamer)
908 if client.logStreamer != nil && client.logStreamer.seq == req.Stop {
909 i.logWriter.DeregisterHandler(client.logStreamer)
910 client.logStreamer.Stop()
[all …]
|
| /dports/sysutils/serf/serf-0.8.5/cmd/serf/command/agent/ |
| H A D | ipc.go | 261 logStreamer *logStream member
417 if client.logStreamer != nil {
418 i.logWriter.DeregisterHandler(client.logStreamer)
419 client.logStreamer.Stop()
885 if client.logStreamer != nil {
891 client.logStreamer = newLogStream(client, filter, seq, i.logger)
895 defer i.logWriter.RegisterHandler(client.logStreamer)
908 if client.logStreamer != nil && client.logStreamer.seq == req.Stop {
909 i.logWriter.DeregisterHandler(client.logStreamer)
910 client.logStreamer.Stop()
[all …]
|