helpers

type Args struct {
	Begin           *timestamppb.Timestamp
	End             *timestamppb.Timestamp
	Input           string
	Want            string
	Stages          []string
	Offset          time.Duration
	Duration        time.Duration
	WantEmpty       bool
	WantErr         bool
	DisOrder        bool
	IgnoreElementID bool
}

type BackupSharedContext struct {
	DataAddr   string
	Connection *grpclib.ClientConn
	FS         remote.FS
	RootDir    string
	DestDir    string
	DestURL    string
	S3Args     []string
}

type LifecycleSharedContext struct {
	BaseTime    time.Time
	Connection  *grpclib.ClientConn
	LiaisonAddr string
	DataAddr    string
	// DataHTTPURL is the hot data node's Prometheus /metrics endpoint. Used
	// by sender-label verifications that need to scrape banyandb_queue_sub_*
	// directly from the data node.
	DataHTTPURL string
	// WarmHTTPURL is the warm data node's Prometheus /metrics endpoint. Both
	// data nodes (hot and warm) see migration writes from the lifecycle
	// publisher, so either endpoint can carry the sender labels.
	WarmHTTPURL   string
	SrcDir        string
	DestDir       string
	MetadataFlags []string
}

type SharedContext struct {
	BaseTime   time.Time
	Connection *grpclib.ClientConn
	// DataNodeAddrs lists the gRPC addresses of the cluster's data nodes.
	// Populated by the distributed BeforeSuite; nil for standalone runs.
	// Cluster-only specs ( partial-cluster barrier scenarios) pass
	// entries from this slice to setup.PauseDataNodeWatch /
	// ResumeDataNodeWatch to drive a single node out of sync while the
	// rest of the cluster stays caught up.
	DataNodeAddrs []string
	// LiaisonAddr is the receiving liaison's gRPC address. Populated by
	// the distributed BeforeSuite; empty for standalone runs. Specs use
	// it with setup.PauseDataNodeWatch when they need to pause the
	// receiving liaison's own SchemaRegistry — the cluster barrier's
	// selfName probe reads through this SR, so pausing it surfaces a
	// laggard via the public AwaitX RPCs without needing
	// NodeSchemaStatusService exposed on data-node ports.
	LiaisonAddr string
	Mode        string
}