| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocol/datatransfer/ |
| H A D | DataTransferProtoUtil.java | 52 static BlockConstructionStage fromProto( in fromProto() method in DataTransferProtoUtil
71 public static DataChecksum fromProto(ChecksumProto proto) { in fromProto() method in DataTransferProtoUtil
103 public static TraceInfo fromProto(DataTransferTraceInfoProto proto) { in fromProto() method in DataTransferProtoUtil
122 TraceInfo info = fromProto(proto); in continueTraceSpan()
|
| H A D | Receiver.java | 20 import static org.apache.hadoop.hdfs.protocol.datatransfer.DataTransferProtoUtil.fromProto;
144 fromProto(proto.getStage()), in opWriteBlock()
148 fromProto(proto.getRequestedChecksum()), in opWriteBlock()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/ |
| H A D | RemoteProcedureException.java | 102 return fromProto(ForeignExceptionMessage.parseFrom(bytes)); in deserialize()
113 public static RemoteProcedureException fromProto(final ForeignExceptionMessage eem) { in fromProto() method in RemoteProcedureException
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/containerd/containerd/containerd-1.4.3/services/events/ |
| H A D | service.go | 78 if err := s.events.Forward(ctx, fromProto(r.Envelope)); err != nil {
115 func fromProto(env *api.Envelope) *events.Envelope { func
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/containerd/containerd/services/events/ |
| H A D | service.go | 78 if err := s.events.Forward(ctx, fromProto(r.Envelope)); err != nil {
115 func fromProto(env *api.Envelope) *events.Envelope { func
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/containerd/containerd/services/events/ |
| H A D | service.go | 78 if err := s.events.Forward(ctx, fromProto(r.Envelope)); err != nil {
115 func fromProto(env *api.Envelope) *events.Envelope { func
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/containerd/containerd/services/events/ |
| H A D | service.go | 78 if err := s.events.Forward(ctx, fromProto(r.Envelope)); err != nil {
115 func fromProto(env *api.Envelope) *events.Envelope { func
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/containerd/containerd/services/events/ |
| H A D | service.go | 78 if err := s.events.Forward(ctx, fromProto(r.Envelope)); err != nil {
115 func fromProto(env *api.Envelope) *events.Envelope { func
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/containerd/containerd/services/events/ |
| H A D | service.go | 78 if err := s.events.Forward(ctx, fromProto(r.Envelope)); err != nil {
115 func fromProto(env *api.Envelope) *events.Envelope { func
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/containerd/containerd/services/events/ |
| H A D | service.go | 78 if err := s.events.Forward(ctx, fromProto(r.Envelope)); err != nil {
115 func fromProto(env *api.Envelope) *events.Envelope { func
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/containerd/containerd/services/events/ |
| H A D | service.go | 78 if err := s.events.Forward(ctx, fromProto(r.Envelope)); err != nil {
115 func fromProto(env *api.Envelope) *events.Envelope { func
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/containerd/containerd/containerd-1.4.3/vendor/github.com/containerd/continuity/ |
| H A D | manifest.go | 46 r, err := fromProto(b)
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/containerd/continuity/ |
| H A D | manifest.go | 46 r, err := fromProto(b)
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/containerd/containerd/vendor/github.com/containerd/continuity/ |
| H A D | manifest.go | 46 r, err := fromProto(b)
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/containerd/containerd/vendor/github.com/containerd/continuity/ |
| H A D | manifest.go | 46 r, err := fromProto(b)
|
| /dports/sysutils/docker/docker-ce-18.09.5/components/engine/vendor/github.com/containerd/continuity/ |
| H A D | manifest.go | 46 r, err := fromProto(b)
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/containerd/continuity/ |
| H A D | manifest.go | 30 r, err := fromProto(b)
|
| /dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/vendor/github.com/containerd/continuity/ |
| H A D | manifest.go | 46 r, err := fromProto(b)
|
| /dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/containerd/continuity/ |
| H A D | manifest.go | 46 r, err := fromProto(b)
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/containerd/containerd/vendor/github.com/containerd/continuity/ |
| H A D | manifest.go | 46 r, err := fromProto(b)
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/containerd/continuity/ |
| H A D | manifest.go | 46 r, err := fromProto(b)
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/containerd/containerd/vendor/github.com/containerd/continuity/ |
| H A D | manifest.go | 46 r, err := fromProto(b)
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/containerd/continuity/ |
| H A D | manifest.go | 46 r, err := fromProto(b)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/containerd/continuity/ |
| H A D | manifest.go | 46 r, err := fromProto(b)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/containerd/containerd/vendor/github.com/containerd/continuity/ |
| H A D | manifest.go | 46 r, err := fromProto(b)
|