Documentation
¶
Index ¶
- Constants
- func WithCluster(ctx context.Context, k *k3s.K3sContainer) testcontainers.CustomizeRequestOption
- func WithStarted() testcontainers.CustomizeRequestOption
- func WithTmpfsMount(sizeBytes int64) testcontainers.CustomizeRequestOption
- type IngestorContainer
- type IngestorStatus
- type KustoTableSchema
Constants ¶
View Source
const ( DefaultImage = "ingestor" DefaultTag = "latest" )
Variables ¶
This section is empty.
Functions ¶
func WithCluster ¶
func WithCluster(ctx context.Context, k *k3s.K3sContainer) testcontainers.CustomizeRequestOption
func WithStarted ¶
func WithStarted() testcontainers.CustomizeRequestOption
WithStarted will start the container when it is created. You don't want to do this if you want to load the container into a k8s cluster.
func WithTmpfsMount ¶ added in v0.2.0
func WithTmpfsMount(sizeBytes int64) testcontainers.CustomizeRequestOption
WithTmpfsMount configures a tmpfs volume with specific size for the ingestor
Types ¶
type IngestorContainer ¶
type IngestorContainer struct {
testcontainers.Container
}
func Run ¶
func Run(ctx context.Context, img string, opts ...testcontainers.ContainerCustomizer) (*IngestorContainer, error)
type IngestorStatus ¶ added in v0.2.0
type IngestorStatus struct {
TotalPods int // Total number of ingestor pods
RunningPods int // Number of running pods
UnhealthyPods int // Number of pods not in running state
PodStatuses map[string]string // Map of pod name to status
RestartCounts map[string]int32 // Map of pod name to restart count
ContainerState map[string][]string // Map of pod name to container states
}
IngestorStatus contains details about the ingestor pods
func VerifyIngestorRunning ¶ added in v0.2.0
func VerifyIngestorRunning(ctx context.Context, restConfig *rest.Config) (bool, *IngestorStatus, error)
VerifyIngestorRunning checks if ingestor pods are running properly
type KustoTableSchema ¶
type KustoTableSchema struct{}
func (*KustoTableSchema) CslColumns ¶
func (k *KustoTableSchema) CslColumns() []string
func (*KustoTableSchema) TableName ¶
func (k *KustoTableSchema) TableName() string
Source Files
Click to show internal directories.
Click to hide internal directories.