env

type AutoDetectSettings struct {
	Enabled        bool     `cfg:"enabled" default:"true"`
	SkipComponents []string `cfg:"skip_components"`
}

type ChannelRecords []LogRecord

type Component interface {
	SetT(t *testing.T)
}

type ComponentAddressAware interface {
	Address() string
}

type ComponentBaseSettings struct {
	Name string `cfg:"name" default:"default"`
	Type string `cfg:"type" validate:"required"`
}

type ComponentBaseSettingsAware interface {
	GetName() string
	GetType() string
	SetName(name string)
	SetType(typ string)
}

type ComponentCfgOptionAware interface {
	CfgOptions() []cfg.Option
}

type ComponentContainerDescription struct {
	ContainerConfig  *ContainerConfig
	HealthCheck      ComponentHealthCheck
	ShutdownCallback ComponentShutdownCallback
}

type ComponentContainerDescriptions map[string]*ComponentContainerDescription

type ComponentContainerSettings struct {
	Image ContainerImageSettings `cfg:"image"`
	Tmpfs []TmpfsSettings        `cfg:"tmpfs"`
}

type ComponentHealthCheck func(container *Container) error

type ComponentOption func(componentConfigManger *ComponentsConfigManager) error

type ComponentShutdownCallback func(container *Container) func() error

type ComponentsConfigManager struct {
	// contains filtered or unexported fields
}

type ComponentsContainer struct {
	// contains filtered or unexported fields
}

type ConfigOption func(config cfg.GosoConf) error

type Container struct {
	// contains filtered or unexported fields
}

type ContainerBinding struct {
	// contains filtered or unexported fields
}

type ContainerBindingSettings struct {
	Host string `cfg:"host" default:"127.0.0.1"`
	Port int    `cfg:"port" default:"0"`
}

type ContainerConfig struct {
	RunnerType   string
	Hostname     string
	ExternalHost string // Host address for external containers (used by external runner)
	Auth         authSettings
	Repository   string
	Tmpfs        []TmpfsSettings
	Tag          string
	Env          map[string]string
	Cmd          []string
	PortBindings PortBindings
	ExposedPorts []string
}

type ContainerImageSettings struct {
	Auth       authSettings `cfg:"auth"`
	Repository string       `cfg:"repository"`
	Tag        string       `cfg:"tag"`
}

type ContainerManager interface {
	RunContainers(ctx context.Context, skeletons []*componentSkeleton) error
	Stop(ctx context.Context) error
}

type ContainerManagerSettings struct {
	RunnerType  string              `cfg:"runner_type"  default:"local"`
	NamePrefix  string              `cfg:"name_prefix"  default:"goso"`
	HealthCheck HealthCheckSettings `cfg:"health_check"`
	ExpireAfter time.Duration       `cfg:"expire_after" default:"5m"`
}

type ContainerRefreshInput struct {
	PoolId   string        `json:"pool_id"`
	TestId   string        `json:"test_id"`
	Duration time.Duration `json:"duration"`
}

type ContainerRequest struct {
	TestName             string
	ComponentType        string
	ComponentName        string
	ContainerName        string
	ContainerDescription *ComponentContainerDescription
	ExpireAfter          time.Duration
}

type ContainerRunner interface {
	RunContainer(ctx context.Context, request ContainerRequest) (*Container, error)
	Stop(ctx context.Context) error
}

type ContainerRunnerLocalSettings struct {
	Endpoint string       `cfg:"endpoint"`
	Auth     authSettings `cfg:"auth"`
}

type ContainerRunnerRemoteHttpClientSettings struct {
	Timeout       time.Duration `cfg:"timeout"     default:"30s"`
	RetryCount    int           `cfg:"retry_count" default:"32"`
	RetryWaitTime time.Duration `cfg:"retry_wait"  default:"3s"`
}

type ContainerRunnerRemoteSettings struct {
	Endpoint   string                                  `cfg:"endpoint"    default:"http://localhost:8890"`
	PoolId     string                                  `cfg:"pool_id"`
	HttpClient ContainerRunnerRemoteHttpClientSettings `cfg:"http_client"`
}

type ContainerSpec struct {
	Repository   string            `json:"repository"`
	Tag          string            `json:"tag"`
	Env          map[string]string `json:"env"`
	Cmd          []string          `json:"cmd"`
	PortBindings PortBindings      `json:"port_bindings"`
}

type ContainerStartInput struct {
	PoolId        string        `json:"pool_id"`
	TestId        string        `json:"test_id"`
	TestName      string        `json:"test_name"`
	ComponentType string        `json:"component_type"`
	ComponentName string        `json:"component_name"`
	ContainerName string        `json:"container_name"`
	Spec          ContainerSpec `json:"spec"`
	ExpireAfter   time.Duration `json:"expire_after"`
}

type ContainerStopInput struct {
	PoolId string `json:"pool_id"`
	TestId string `json:"test_id"`
}

type Environment struct {
	// contains filtered or unexported fields
}

type HealthCheckSettings struct {
	InitialInterval time.Duration `cfg:"initial_interval" default:"1s"`
	MaxInterval     time.Duration `cfg:"max_interval"     default:"3s"`
	MaxElapsedTime  time.Duration `cfg:"max_elapsed_time" default:"1m"`
}

type KafkaComponent struct {
	// contains filtered or unexported fields
}

type LogRecord struct {
	Timestamp    time.Time
	Level        int
	Msg          string
	Args         []any
	Err          error
	Data         log.Data
	FormattedMsg string
}

type LogRecords map[string]ChannelRecords

type LoggerOption func(settings *LoggerSettings) error

type LoggerSettings struct {
	Level      string
	RecordLogs bool
}

type Option func(env *Environment)

type PortBinding struct {
	ContainerPort int    `json:"container_port"`
	HostPort      int    `json:"host_port"`
	Protocol      string `json:"protocol"`
}

type PortBindings map[string]PortBinding

type RecordingLogger interface {
	log.GosoLogger
	Records() LogRecords
	Reset()
}

type RedisComponent struct {
	// contains filtered or unexported fields
}

type StreamInputComponent struct {
	// contains filtered or unexported fields
}

type TmpfsSettings struct {
	Path string `cfg:"path"`
	Size string `cfg:"size"`
	Mode string `cfg:"mode"`
}