Go to main page
Imports
- github.com/numaproj/numaflow-go/pkg/apis/proto/map/v1
- github.com/numaproj/numaflow-go/pkg/apis/proto/mapstream/v1
- github.com/numaproj/numaflow-go/pkg/apis/proto/reduce/v1
- github.com/numaproj/numaflow-go/pkg/apis/proto/sessionreduce/v1
- golang.org/x/sync/errgroup
- google.golang.org/grpc/metadata
- google.golang.org/protobuf/types/known/emptypb
- google.golang.org/protobuf/types/known/timestamppb
- k8s.io/apimachinery/pkg/util/wait
Imports in module “github.com/numaproj/numaflow”
- github.com/numaproj/numaflow/pkg/isb
- github.com/numaproj/numaflow/pkg/reduce/pbq/partition
- github.com/numaproj/numaflow/pkg/sdkclient
- github.com/numaproj/numaflow/pkg/sdkclient/error
- github.com/numaproj/numaflow/pkg/sdkclient/mapper
- github.com/numaproj/numaflow/pkg/sdkclient/mapstreamer
- github.com/numaproj/numaflow/pkg/sdkclient/reducer
- github.com/numaproj/numaflow/pkg/sdkclient/sessionreducer
- github.com/numaproj/numaflow/pkg/shared/logging
- github.com/numaproj/numaflow/pkg/window