EncodeBase64ToString stores the base64 encoding of src in dest.

GenerateCACert generates a new self-signed CA cert using priv.

GenerateClientCertAndKey generates a client certificate and client key that is signed by the given caCert.

GetHydratedTableDescriptor returns a table descriptor for the specified table.

MakeRangeFeedValueReader starts rangefeed on the specified table and returns a function that returns the next *kvpb.RangeFeedValue from the table.

MakeRangeFeedValueReaderExtended is like MakeRangeFeedValueReader, but it can return a RangeFeedDeleteRange too.

NewBeforeAfterValidator returns a Validator verifies that the "before" and "after" fields in each row agree with the source table when performing AS OF SYSTEM TIME lookups before and at the row's timestamp.

NewCACertBase64Encoded generates a new CA cert and returns the cert object as well as a base 64 encoded PEM version.

NewCountValidator returns a CountValidator wrapping the given Validator.

NewFingerprintValidator returns a new FingerprintValidator that uses `fprintTable` as scratch space to recreate `origTable`.

NewKeyInValueValidator returns a Validator that verifies that the emitted row includes the key inside a field named "key" inside the value.

NewOrderValidator returns a Validator that checks the row and resolved timestamp ordering guarantees.

NewStreamOrderValidator wraps an orderValidator as described above, and exposes additional methods for introspection.

NewTopicValidator returns a Validator that verifies that the topic field of the row agrees with the name of the table.

ParseJSONValueTimestamps returns the updated or resolved timestamp set in the provided `format=json` value.

PemEncodeCert encodes cert in PEM format.

PemEncodePrivateKey encodes key in PEM format.

RunNemesis runs a jepsen-style validation of whether a changefeed meets our user-facing guarantees.

StartErrorTestSchemaRegistry creates and starts schema registry for tests which will return the supplied statusCode on each request.

StartMockWebhookSink creates and starts a mock webhook sink for tests.

StartMockWebhookSinkInsecure starts a mock webhook sink without TLS.

StartMockWebhookSinkSecure creates and starts a mock webhook sink server that requires clients to provide client certificates for authentication.

StartMockWebhookSinkWithBasicAuth creates and starts a mock webhook sink for tests with basic username/password auth.

StartTestSchemaRegistry creates and starts schema registry for tests.

StartTestSchemaRegistryWithTLS creates and starts schema registry for tests with TLS enabled.

NoOpValidator is a validator that does nothing.

CountValidator wraps a Validator and keeps count of how many rows and resolved timestamps have been seen.

FingerprintValidator verifies that recreating a table from its changefeed will fingerprint the same at all "interesting" points in time.

MockWebhookSink is the Webhook sink used in tests.

SchemaRegistry is the kafka schema registry used in tests.

TestFeedMessage represents one row update or resolved timestamp message from a changefeed.

EnterpriseTestFeed augments TestFeed with additional methods applicable to enterprise feeds.

StreamValidator wraps a Validator and exposes additional methods for introspection.

TestFeed abstracts over reading from the various types of changefeed sinks.

TestFeedFactory is an interface to create changefeeds.

Validator checks for violations of our changefeed ordering and delivery guarantees in a single table.

Validators abstracts over running multiple `Validator`s at once on the same feed.