Documentation
¶
Overview ¶
Package schema contains shared test cases for schema-related functionality.
Package schema contains shared test cases for schema-related functionality.
Tombstone GC specs exercise tombstone retention behavior. The test suites wire the standalone server with --schema-server-tombstone-retention=2s in the BeforeSuite, so the specs run without requiring any environment variable.
Index ¶
- Variables
- func VerifyMeasureDeletion(ctx context.Context, clients *Clients, groupName, measureName string) error
- func VerifyStreamDeletion(ctx context.Context, clients *Clients, groupName, streamName string) error
- func VerifyTraceDeletion(ctx context.Context, clients *Clients, groupName, traceName string) error
- type Clients
Constants ¶
This section is empty.
Variables ¶
SharedContext is set by the test environment (standalone or distributed).
Functions ¶
func VerifyMeasureDeletion ¶
func VerifyMeasureDeletion(ctx context.Context, clients *Clients, groupName, measureName string) error
VerifyMeasureDeletion implements the complete deletion test process for measures.
Types ¶
type Clients ¶
type Clients struct {
GroupClient databasev1.GroupRegistryServiceClient
MeasureRegClient databasev1.MeasureRegistryServiceClient
StreamRegClient databasev1.StreamRegistryServiceClient
TraceRegClient databasev1.TraceRegistryServiceClient
IndexRuleClient databasev1.IndexRuleRegistryServiceClient
IndexRuleBindingClient databasev1.IndexRuleBindingRegistryServiceClient
TopNAggregationRegClient databasev1.TopNAggregationRegistryServiceClient
MeasureWriteClient measurev1.MeasureServiceClient
StreamWriteClient streamv1.StreamServiceClient
TraceWriteClient tracev1.TraceServiceClient
BarrierClient schemav1.SchemaBarrierServiceClient
}
Clients holds all gRPC clients required by the schema integration test helpers.
func NewClients ¶ added in v0.11.0
func NewClients(conn *grpc.ClientConn) *Clients
NewClients constructs the registry/service client bundle used by the schema integration tests.
func (*Clients) AwaitApplied ¶ added in v0.11.0
AwaitApplied blocks until every key in the list reports as present in the cluster's schema cache or the timeout elapses. Each key is encoded as "kind:group/name"; supported kinds are "measure", "stream", and "trace". Delegates to SchemaBarrierService.AwaitSchemaApplied.
func (*Clients) AwaitDeleted ¶ added in v0.11.0
AwaitDeleted blocks until every key in the list is absent from the cluster's schema cache or the timeout elapses. Encoding follows AwaitApplied. Delegates to SchemaBarrierService.AwaitSchemaDeleted.
func (*Clients) AwaitRevision ¶ added in v0.11.0
AwaitRevision blocks until the cluster's schema cache has advanced to the given mod_revision or the timeout elapses. Delegates to SchemaBarrierService.AwaitRevisionApplied.
Source Files