replaceEnvVars replaces any string in the format ${VALUE} or $VALUE with the corresponding $VALUE environment variable

runSQLCommands is an helper function that will run some commands on an SQL transaction.

setBit sets bit i (0-based, starting from LSB)

uncompress uncompresses b into the decompressor internal buffer, starting at pos. Returns how many uncompressed bytes have been written.

CanShards returns true if this output supports sharding.

Del removes the given cache entry.

DeleteMessageWithContext does nothing since messages are removed from the queue as soon as they're requested.

DiffBytes fails the test and shows differences, line by line, if any

GenerateMarkdownHelp generates markdown-formatted textual help for a Baker component from its description structure. Markdown is written into w.

GenerateTextHelp generates non-formatted textual help for a Baker component from its description structure, into w.

IsValidRegion reports whether a region is a valid aws region identifier.

Listen and serve. It serves client connection and broadcast request.

NewClearFields returns a ClearFields filter.

NewNotNull creates and configures a new NotNull filter.

NewRegexMatch returns a RegexMatch filter.

NewServer creates new chat server.

NewSlice creates a new Slice filter

NewStringMatch returns a StringMatch filter.

Process implements baker.Filter.

Process is where the actual filtering takes place.

Process is where the actual filtering takes place.

Process implements baker.Filter.

Process is where the actual filtering takes place.

Process records, slicing src field and saving the result to the dest field

Process implements baker.Filter.

ReceiveMessageWithContext sends the first message for the requested queue, if any, then removes it from the queue.

RecordConformanceTest is a test helper that verifies the conformance of Record implementation with a set of requirements.

SendAll sends a message to all connected clients. Used by the output component to broadcast the message to the clients

SetGCPercentIfNotSet sets the GC target percentage, unless GOGC environment variable is set, in which case SetGCPercentIfNotSet doesn't not override i

SetLogLevel sets the global log level for the execution of the current tb. Though setting the log level is safe for use from concurrent goroutines, it

SetS3API allows to replace the S3API, for tests.

Shutdown is invoked by the Amazon Kinesis Client Library to indicate it will no longer send data records to this RecordProcessor instance.

Stop requires the currently running topology to stop safely, but as soon as possible. The stop request is handled by the input component. You can call

bytes returns the decompressor internal buffer, resliced up until byte n.

checkHostPort checks that addr ("host:port" format) is a free tcp port suitable for binding a listener. NOTE: use 'localhost:' to let the OS find a fr

clear must be called with lock already held!

coldLocation returns a location pointing to a cold cache entry.

constructKey builds a key by concatenating field values

convert to raw config, which is a superset, so that the sqlite output can always use one type only

copy copies buf at index pos of the internal buffer, growing it if necessary.

decompressFilesInDir decompresses all compressed (zstd/gzip) files it finds under root (recursively), and removes the compressed files in files with t