func()

in internal/kusto/ingest.go [43:57]

• 13 lines of code
• 3 McCabe index (conditional complexity)

func (s ingestorBuildSettings) createIngestor(
	target KustoTargetOptions,
	auth AuthOptions,
) (ingest.Ingestor, error) {
	if s.CreateIngestor != nil {
		return s.CreateIngestor(target, auth)
	}

	queryClient, err := s.createQueryClient(target, auth)
	if err != nil {
		return nil, err
	}

	return ingest.New(queryClient, target.Database, target.Table)
}