Documentation ¶
Index ¶
- Constants
- func CanonizeDynamicYtTable(t *testing.T, ytClient yt.Client, tablePath ypath.Path, fileName string)
- func ChSchemaForYtTypesTestData() string
- func DumpDynamicYtTable(ytClient yt.Client, tablePath ypath.Path, writer io.Writer) error
- func Main(m *testing.M)
- func NewEnv(t *testing.T, opts ...yttest.Option) (*yttest.Env, func())
- func NewEnvWithNode(t *testing.T, path string) *yttest.Env
- func RecipeYtTarget(path string) (yt_provider.YtDestinationModel, func() error, error)
- func SetRecipeYt(dst *yt_provider.YtDestination) *yt_provider.YtDestination
- func TestContainerEnabled() bool
- func WithAuth() testcontainers.CustomizeRequestOption
- func YtReadAllRowsFromAllTables[OutRow any](t *testing.T, cluster string, path string, expectedResCount int) []OutRow
- func YtTestDir(t *testing.T, testSuiteName string) ypath.Path
- func YtTypesTestData() ([]schema.Column, []map[string]any)
- type YTsaurusContainer
Constants ¶
View Source
const ( DefaultUser = "admin" DefaultPassword = "password" DefaultToken = "password" )
Variables ¶
This section is empty.
Functions ¶
func CanonizeDynamicYtTable ¶
func ChSchemaForYtTypesTestData ¶
func ChSchemaForYtTypesTestData() string
func DumpDynamicYtTable ¶
func RecipeYtTarget ¶
func RecipeYtTarget(path string) (yt_provider.YtDestinationModel, func() error, error)
func SetRecipeYt ¶
func SetRecipeYt(dst *yt_provider.YtDestination) *yt_provider.YtDestination
func TestContainerEnabled ¶
func TestContainerEnabled() bool
func WithAuth ¶
func WithAuth() testcontainers.CustomizeRequestOption
WithAuth enables authentication on http proxies and creates `admin` user with password and token `password`.
Types ¶
type YTsaurusContainer ¶
type YTsaurusContainer struct {
testcontainers.Container
}
YTsaurusContainer represents the YTsaurus container type used in the module.
func RunContainer ¶
func RunContainer(ctx context.Context, opts ...testcontainers.ContainerCustomizer) (*YTsaurusContainer, error)
RunContainer creates and starts an instance of the YTsaurus container.
func (*YTsaurusContainer) ConnectionHost ¶
func (y *YTsaurusContainer) ConnectionHost(ctx context.Context) (string, error)
ConnectionHost returns the host and dynamic port for accessing the YTsaurus container.
func (*YTsaurusContainer) GetProxy ¶
func (y *YTsaurusContainer) GetProxy(ctx context.Context) (string, error)
GetProxy is an alias for ConnectionHost since `proxy` is more familiar term for in YTsaurus.
func (*YTsaurusContainer) NewClient ¶
NewClient creates a new YT client connected to the YTsaurus container.
func (*YTsaurusContainer) Token ¶
func (y *YTsaurusContainer) Token() string
Token returns the token for the YTsaurus container.
Click to show internal directories.
Click to hide internal directories.