mirror of
https://github.com/milvus-io/milvus.git
synced 2026-07-21 10:15:43 +00:00
444050550d
- Split the metastore catalog interfaces into coordinator-specific files so follow-up coordinator refactors can move their catalog surfaces independently. - Preserve the existing interfaces, signatures, and behavior; the rework only fixes gci import grouping in the split RootCoord and StreamingNode catalog files. related: #50917 --------- Signed-off-by: shaoting-huang <shaoting.huang@zilliz.com> Co-authored-by: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
42 lines
1.9 KiB
Go
42 lines
1.9 KiB
Go
package metastore
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/milvus-io/milvus-proto/go-api/v3/commonpb"
|
|
"github.com/milvus-io/milvus/pkg/v3/proto/streamingpb"
|
|
)
|
|
|
|
// StreamingNodeCataLog is the interface for streamingnode catalog
|
|
type StreamingNodeCataLog interface {
|
|
// WAL select the wal related recovery infos.
|
|
// Which must give the pchannel name.
|
|
|
|
// ListVChannel list all vchannels on current pchannel.
|
|
ListVChannel(ctx context.Context, pchannelName string) ([]*streamingpb.VChannelMeta, error)
|
|
|
|
// SaveVChannels save vchannel on current pchannel.
|
|
SaveVChannels(ctx context.Context, pchannelName string, vchannels map[string]*streamingpb.VChannelMeta) error
|
|
|
|
// ListSegmentAssignment list all segment assignments for the wal.
|
|
ListSegmentAssignment(ctx context.Context, pChannelName string) ([]*streamingpb.SegmentAssignmentMeta, error)
|
|
|
|
// SaveSegmentAssignments save the segment assignments for the wal.
|
|
SaveSegmentAssignments(ctx context.Context, pChannelName string, infos map[int64]*streamingpb.SegmentAssignmentMeta) error
|
|
|
|
// GetConsumeCheckpoint gets the consuming checkpoint of the wal.
|
|
// Return nil, nil if the checkpoint is not exist.
|
|
GetConsumeCheckpoint(ctx context.Context, pChannelName string) (*streamingpb.WALCheckpoint, error)
|
|
|
|
// SaveConsumeCheckpoint saves the consuming checkpoint of the wal.
|
|
SaveConsumeCheckpoint(ctx context.Context, pChannelName string, checkpoint *streamingpb.WALCheckpoint) error
|
|
|
|
// SaveSalvageCheckpoint saves the salvage checkpoint.
|
|
// The checkpoint is captured during force promote.
|
|
SaveSalvageCheckpoint(ctx context.Context, pChannelName string, checkpoint *commonpb.ReplicateCheckpoint) error
|
|
|
|
// GetSalvageCheckpoint gets all salvage checkpoints for a channel.
|
|
// Returns an empty slice if none exist. One checkpoint per source cluster.
|
|
GetSalvageCheckpoint(ctx context.Context, pChannelName string) ([]*commonpb.ReplicateCheckpoint, error)
|
|
}
|