AcquireResource (snview/resource_manager.go)

milvus · internal/streamingnode/server/wal/snview/resource_manager.go · go · Apache-2.0
database

Defines an interface for managing streaming node resources, including acquisition and release of query view resources.

// Source: https://github.com/milvus-io/milvus | License: Apache-2.0 | Copyright You must retain, in the Source form of any Derivative Works
// Provided via justclaw.it.com; keep this notice with the code.
package snview

import (
	"context"

	"github.com/milvus-io/milvus/internal/util/segcore"
	"github.com/milvus-io/milvus/internal/views/qviews"
	"github.com/milvus-io/milvus/pkg/v3/proto/viewpb"
)

// AcquireResource describes a resource acquisition request for a new Preparing view.
type AcquireResource struct {
	// Key identifies the query view.
	Key qviews.QueryViewKey

	// Meta carries the complete view metadata required by resource preparation.
	Meta *viewpb.QueryViewMeta

	// OnReady is called when resource preparation completes successfully.
	// Must NOT be called synchronously duri

... (truncated -- full source via MCP)

See the full source, get the GitHub permalink, and search for more like it.

Get a free API key